devbox
weixin_40725706
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

springboot整合elasticsearch 实现增删改查_elasticsearch ,springboot中操作文档的增删改查

作者：weixin_40725706 | 2024-02-08 11:08:57

赞

踩

elasticsearch ,springboot中操作文档的增删改查

目前实现的功能有查询单个实体类,通过条件查询List,单个新增,批量新增,通过id删除,批量删除，

单个修改,

项目用到的类

pom.xml

  1.     <dependency>
  2.             <groupId>org.springframework.boot</groupId>
  3.             <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  4.     </dependency>

 配置文件

  1. spring:
  2.   data:
  3.     elasticsearch:
  4.       repositories:
  5.         enabled: true
  6.       cluster-name: my-es
  7.       cluster-nodes: 42.194.130.93:9300
  8. environment: 开发环境
  9. ev:
  10.   expressIndex: express_dev

 

ExpressIndexService类

  1.    /**
  2.      * 批量创建索引
  3.      * @param expressList
  4.      */
  5.     void batchCreateIndex(List<ExpressDO> expressList);
  6.  
  7.     /**
  8.      * 批量创建索引
  9.      * @param express
  10.      */
  11.     void createIndex(ExpressDO express);
  12.  
  13.     /**
  14.      * 批量删除索引
  15.      */
  16.     void deleteAllIndex();
  17.  
  18.     /**
  19.      * 删除索引
  20.      */
  21.     void deleteIndex(Long id);
  22.  
  23.     /**
  24.      * 修改索引
  25.      * @param express
  26.      */
  27.     void updateIndex(ExpressDO express);
  28.  
  29.     /**
  30.      * 查询索引
  31.      * @param
  32.      */
  33.     ExpressDO seletctIndex(Long id);
  34.  
  35.     /**
  36.      * 查询索引列表
  37.      * @param
  38.      */
  39.     List<ExpressDO> seletctAllIndex(ExpressDO express, EsPager pager);
ExpressIndexServiceImpl类

  1. package com.bootdo.es.service.impl;
  2.  
  3. import com.bootdo.es.domain.EsPager;
  4. import com.bootdo.es.domain.ExpressIndex;
  5. import com.bootdo.es.service.ExpressIndexRepository;
  6. import com.bootdo.es.service.ExpressIndexService;
  7. import com.bootdo.system.domain.ExpressDO;
  8.  
  9. import com.bootdo.system.util.BeanUtils;
  10. import org.apache.commons.lang.StringUtils;
  11. import org.elasticsearch.index.query.BoolQueryBuilder;
  12. import org.elasticsearch.index.query.QueryBuilders;
  13. import org.elasticsearch.search.sort.SortBuilders;
  14. import org.elasticsearch.search.sort.SortOrder;
  15. import org.springframework.beans.factory.annotation.Autowired;
  16. import org.springframework.data.domain.Page;
  17. import org.springframework.data.domain.PageRequest;
  18. import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
  19. import org.springframework.stereotype.Service;
  20.  
  21. import java.util.ArrayList;
  22. import java.util.List;
  23. import java.util.Optional;
  24.  
  25. @Service
  26. public class ExpressIndexServiceImpl implements ExpressIndexService {
  27.  
  28.     @Autowired
  29.     private ExpressIndexRepository expressIndexRepository;
  30.  
  31.     /**
  32.      * 批量创建索引
  33.      * @param expressList
  34.      */
  35.     @Override
  36.     public void batchCreateIndex(List<ExpressDO> expressList) {
  37.         List<ExpressIndex> expressAddIndexList = BeanUtils.cloneList(expressList, ExpressIndex.class);
  38.         expressIndexRepository.saveAll(expressAddIndexList);
  39.     }
  40.  
  41.     /**
  42.      * 创建索引
  43.      * @param express
  44.      */
  45.     @Override
  46.     public void createIndex(ExpressDO express) {
  47.         ExpressIndex expressIndex = BeanUtils.clone(express,ExpressIndex.class);
  48.         expressIndexRepository.save(expressIndex);
  49.     }
  50.  
  51.     /**
  52.      * 批量删除索引
  53.      * @param
  54.      */
  55.     @Override
  56.     public void deleteAllIndex() {
  57.         expressIndexRepository.deleteAll();
  58.     }
  59.  
  60.     /**
  61.      * 删除索引
  62.      * @param
  63.      */
  64.     @Override
  65.     public void deleteIndex(Long id) {
  66.         expressIndexRepository.deleteById(id);
  67.     }
  68.  
  69.     /**
  70.      * 修改索引
  71.      * @param
  72.      */
  73.     @Override
  74.     public void updateIndex(ExpressDO express) {
  75.         //删除索引
  76.         expressIndexRepository.deleteById(Long.valueOf(express.getMealid()));
  77.         //创建索引
  78.         ExpressIndex expressIndex = BeanUtils.clone(express,ExpressIndex.class);
  79.         expressIndexRepository.save(expressIndex);
  80.     }
  81.  
  82.     /**
  83.      * 查询索引列表
  84.      * @param
  85.      */
  86.    @Override
  87.     public List<ExpressDO> seletctAllIndex(ExpressDO express, EsPager pager) {
  88.        // 构建查询条件
  89.        NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder();
  90.        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
  91.  
  92.        if (StringUtils.isNotEmpty(express.getUsername())) {
  93.            // 创建模糊查询语句 ES中must和should不能同时使用 同时使用should失效 嵌套多个must 将should条件拼接在一个must中即可
  94.            BoolQueryBuilder shouldQuery = QueryBuilders.boolQuery()
  95.                    .should(QueryBuilders.wildcardQuery("username", "*"+express.getUsername()+"*"))
  96.                    .should(QueryBuilders.wildcardQuery("phone", "*"+express.getUsername()+"*"));
  97.            boolQueryBuilder.must(shouldQuery);
  98.        }
  99.        queryBuilder.withSort(SortBuilders.fieldSort("createdate").order(SortOrder.ASC)); //排序
  100.        if(null != express.getAddress()){
  101.            boolQueryBuilder.must(QueryBuilders.termQuery("address", express.getAddress())); //条件查询
  102.        }
  103.        queryBuilder.withQuery(boolQueryBuilder);
  104.  
  105.        //页码设置
  106.        int pagetSize = pager.getPageSize();
  107.        queryBuilder.withPageable(PageRequest.of(pager.getPageNo() - 1,pagetSize));
  108.        Page<ExpressIndex> pageList = expressIndexRepository.search(queryBuilder.build());
  109.        List<ExpressDO> list = BeanUtils.cloneList(pageList.getContent(), ExpressDO.class) ;
  110.        return list;
  111.  
  112.     }
  113.  
  114.     /**
  115.      * 查询索引
  116.      * @param
  117.      */
  118.     @Override
  119.     public ExpressDO seletctIndex(Long id) {
  120.         Optional<ExpressIndex> expressIndex =  expressIndexRepository.findById(id);
  121.         if(expressIndex != null){
  122.             ExpressDO expressDO = BeanUtils.clone(expressIndex.get(),ExpressDO.class);
  123.             return expressDO;
  124.         }
  125.         return new ExpressDO();
  126.  
  127.     }
  128. }
ExpressIndexRepository类
  1. package com.bootdo.es.service;
  2.  
  3. import com.bootdo.es.domain.ExpressIndex;
  4. import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
  5.  
  6.  
  7. public interface ExpressIndexRepository extends ElasticsearchRepository<ExpressIndex,Long> {
  8. }

EV类

  1. package com.bootdo.es.domain;
  2.  
  3. import org.springframework.beans.factory.annotation.Value;
  4. import org.springframework.context.annotation.Bean;
  5. import org.springframework.stereotype.Component;
  6.  
  7. @Component
  8. public class EV {
  9.  
  10.     @Value("${ev.expressIndex}")
  11.     private String expressIndex;
  12.  
  13. /*    @Value("${ev.courseChapterIndex}")
  14.     private String courseChapterIndex;
  15.     @Value("${ev.courseItemIndex}")
  16.     private String courseItemIndex;*/
  17.  
  18.     @Bean
  19.     public String expressIndex(){
  20.         return expressIndex;
  21.     }
  22.  
  23. /*    @Bean
  24.     public String courseChapterIndex(){
  25.         return courseChapterIndex;
  26.     }
  27.     @Bean
  28.     public String courseItemIndex(){
  29.         return courseItemIndex;
  30.     }*/
  31.  
  32. }
EsPager类
  1. package com.bootdo.es.domain;
  2.  
  3.  
  4. import java.io.Serializable;
  5.  
  6. /**
  7.  * 分页对象
  8.  * @author dengzw
  9.  * 2018-6-4 下午9:26:15
  10.  *
  11.  */
  12. public class EsPager extends Pager implements Serializable{
  13.  
  14.  
  15. 	
  16. }
ExpressIndex类
  1. package com.bootdo.es.domain;
  2.  
  3. import org.springframework.data.annotation.Id;
  4. import org.springframework.data.elasticsearch.annotations.Document;
  5. import org.springframework.data.elasticsearch.annotations.Field;
  6. import org.springframework.data.elasticsearch.annotations.FieldType;
  7.  
  8. import java.io.Serializable;
  9. import java.math.BigDecimal;
  10. import java.util.Date;
  11.  
  12. @Document(indexName = "#{@expressIndex}", type = "docs", shards = 1, replicas = 1)
  13. public class ExpressIndex implements Serializable {
  14.  
  15.     @Id
  16.     private Integer mealid;
  17.  
  18.     //下单人姓名
  19.     @Field(type = FieldType.Text, analyzer = "username")
  20.     private String username;
  21.  
  22.     //下单人手机号
  23.     @Field(type = FieldType.Text, analyzer = "phone")
  24.     private String phone;
  25.  
  26.     //订单号
  27.     @Field(type = FieldType.Text, analyzer = "orderno")
  28.     private String orderno;
  29.  
  30.     //取件码
  31.     @Field(type = FieldType.Text, analyzer = "pickcodce")
  32.     private String pickcodce;
  33.  
  34.     //价格
  35.     @Field(type = FieldType.Double, analyzer = "price")
  36.     private BigDecimal price;
  37.  
  38.     //订单物品
  39.     @Field(type = FieldType.Text, analyzer = "goods")
  40.     private String goods;
  41.  
  42.     //收件人姓名
  43.     @Field(type = FieldType.Text, analyzer = "collectname")
  44.     private String collectname;
  45.  
  46.     //收件人手机号
  47.     @Field(type = FieldType.Text, analyzer = "collectphone")
  48.     private String collectphone;
  49.  
  50.     //始发地
  51.     @Field(type = FieldType.Text, analyzer = "start")
  52.     private String start;
  53.  
  54.     //目的地
  55.     @Field(type = FieldType.Text, analyzer = "address")
  56.     private String address;
  57.  
  58.     //订单状态 1待接单,2已接单,3已完成
  59.     @Field(type = FieldType.Integer, analyzer = "status")
  60.     private Integer status;
  61.  
  62.     //类型 1快递,2外卖,3跑腿
  63.     @Field(type = FieldType.Integer, analyzer = "type")
  64.     private Integer type;
  65.  
  66.     //快递类型 1代寄,2代取
  67.     @Field(type = FieldType.Integer, analyzer = "expresstype")
  68.     private Integer expresstype;
  69.  
  70.     //接单时间
  71.     @Field(type = FieldType.Date, analyzer = "receivingdate")
  72.     private Date receivingdate;
  73.  
  74.     //接单人
  75.     @Field(type = FieldType.Long, analyzer = "receivinguserid")
  76.     private Long receivinguserid;
  77.  
  78.     //修改时间
  79.     @Field(type = FieldType.Date, analyzer = "updatedate")
  80.     private Date updatedate;
  81.  
  82.     //创建时间
  83.     @Field(type = FieldType.Date, analyzer = "createdate")
  84.     private Date createdate;
  85.  
  86.     @Field(type = FieldType.Text, analyzer = "receivingName")
  87.     private String receivingName;
  88.  
  89.     @Field(type = FieldType.Text, analyzer = "mobile")
  90.     private String mobile;
  91.  
  92.     public Integer getMealid() {
  93.         return mealid;
  94.     }
  95.  
  96.     public void setMealid(Integer mealid) {
  97.         this.mealid = mealid;
  98.     }
  99.  
  100.     public String getUsername() {
  101.         return username;
  102.     }
  103.  
  104.     public void setUsername(String username) {
  105.         this.username = username;
  106.     }
  107.  
  108.     public String getPhone() {
  109.         return phone;
  110.     }
  111.  
  112.     public void setPhone(String phone) {
  113.         this.phone = phone;
  114.     }
  115.  
  116.     public String getOrderno() {
  117.         return orderno;
  118.     }
  119.  
  120.     public void setOrderno(String orderno) {
  121.         this.orderno = orderno;
  122.     }
  123.  
  124.     public String getPickcodce() {
  125.         return pickcodce;
  126.     }
  127.  
  128.     public void setPickcodce(String pickcodce) {
  129.         this.pickcodce = pickcodce;
  130.     }
  131.  
  132.     public BigDecimal getPrice() {
  133.         return price;
  134.     }
  135.  
  136.     public void setPrice(BigDecimal price) {
  137.         this.price = price;
  138.     }
  139.  
  140.     public String getGoods() {
  141.         return goods;
  142.     }
  143.  
  144.     public void setGoods(String goods) {
  145.         this.goods = goods;
  146.     }
  147.  
  148.     public String getCollectname() {
  149.         return collectname;
  150.     }
  151.  
  152.     public void setCollectname(String collectname) {
  153.         this.collectname = collectname;
  154.     }
  155.  
  156.     public String getCollectphone() {
  157.         return collectphone;
  158.     }
  159.  
  160.     public void setCollectphone(String collectphone) {
  161.         this.collectphone = collectphone;
  162.     }
  163.  
  164.     public String getStart() {
  165.         return start;
  166.     }
  167.  
  168.     public void setStart(String start) {
  169.         this.start = start;
  170.     }
  171.  
  172.     public String getAddress() {
  173.         return address;
  174.     }
  175.  
  176.     public void setAddress(String address) {
  177.         this.address = address;
  178.     }
  179.  
  180.     public Integer getStatus() {
  181.         return status;
  182.     }
  183.  
  184.     public void setStatus(Integer status) {
  185.         this.status = status;
  186.     }
  187.  
  188.     public Integer getType() {
  189.         return type;
  190.     }
  191.  
  192.     public void setType(Integer type) {
  193.         this.type = type;
  194.     }
  195.  
  196.     public Integer getExpresstype() {
  197.         return expresstype;
  198.     }
  199.  
  200.     public void setExpresstype(Integer expresstype) {
  201.         this.expresstype = expresstype;
  202.     }
  203.  
  204.     public Date getReceivingdate() {
  205.         return receivingdate;
  206.     }
  207.  
  208.     public void setReceivingdate(Date receivingdate) {
  209.         this.receivingdate = receivingdate;
  210.     }
  211.  
  212.     public Long getReceivinguserid() {
  213.         return receivinguserid;
  214.     }
  215.  
  216.     public void setReceivinguserid(Long receivinguserid) {
  217.         this.receivinguserid = receivinguserid;
  218.     }
  219.  
  220.     public Date getUpdatedate() {
  221.         return updatedate;
  222.     }
  223.  
  224.     public void setUpdatedate(Date updatedate) {
  225.         this.updatedate = updatedate;
  226.     }
  227.  
  228.     public Date getCreatedate() {
  229.         return createdate;
  230.     }
  231.  
  232.     public void setCreatedate(Date createdate) {
  233.         this.createdate = createdate;
  234.     }
  235.  
  236.     public String getReceivingName() {
  237.         return receivingName;
  238.     }
  239.  
  240.     public void setReceivingName(String receivingName) {
  241.         this.receivingName = receivingName;
  242.     }
  243.  
  244.     public String getMobile() {
  245.         return mobile;
  246.     }
  247.  
  248.     public void setMobile(String mobile) {
  249.         this.mobile = mobile;
  250.     }
  251. }
Pager类
  1. package com.bootdo.es.domain;
  2. import java.io.Serializable;
  3. import java.util.List;
  4.  
  5. /**
  6.  * @Description: 分页对象
  7.  * @Author : zhuzq
  8.  * @Date: 2020/8/7 15:21
  9.  * @return:
  10.  **/
  11. public class Pager<C> implements Serializable{
  12.  
  13. 	private static final long serialVersionUID = 1L;
  14. 	private int pageSize = 10;		// 每页多少条
  15. 	private int pageNo = 1; 		// 第几页
  16. 	private int totalPages = 10;	// 总的页数
  17. 	private int totalSize = 0;	// 总的记录数
  18. 	private List<?> list ;
  19.  
  20. 	public Pager() {
  21. 	}
  22.  
  23. 	public Pager(int pageNo, int pageSize) {
  24. 		super();
  25. 		this.pageSize = pageSize;
  26. 		this.pageNo = pageNo;
  27. 	}
  28.  
  29. 	public int getBegin() {
  30. 		return (this.getPageNo() - 1) * this.getPageSize();
  31. 	}
  32.  
  33. 	public int getEnd() {
  34. 		return (this.getPageNo() - 1) * this.getPageSize() + this.getPageSize();
  35. 	}
  36.  
  37. 	public int getPageSize() {
  38. 		return pageSize;
  39. 	}
  40.  
  41. 	public void setPageSize(int pageSize) {
  42. 		if (pageSize < 1) {
  43. 			this.pageSize = 10;
  44. 		} else {
  45. 			this.pageSize = pageSize;
  46. 		}
  47. 	}
  48.  
  49. 	public int getPageNo() {
  50. 		if (this.pageNo > this.getTotalPages() && this.getTotalSize() > 0) {
  51. 			this.pageNo = this.getTotalPages(); // 如果当前页大于最大页数，则等于最大页数
  52. 			//this.pageNo = -1; //修改这里用户手机客户端.
  53. 		}
  54. 		return pageNo;
  55. 	}
  56.  
  57.  
  58. 	public void setPageNo(int pageNo) {
  59. 		if (pageNo < 1) {
  60. 			this.pageNo = 1;
  61. 		} else {
  62. 			this.pageNo = pageNo;
  63. 		}
  64. 	}
  65.  
  66. 	public int getTotalPages() {
  67. 		totalPages = totalPages < 1 ? 1 : totalPages;
  68. 		totalPages = getTotalSize() % getPageSize() == 0 ? (getTotalSize() / getPageSize()) : (getTotalSize() / getPageSize() + 1);
  69. 		return totalPages;
  70. 	}
  71.  
  72. 	public void setTotalPages(int totalPages) {
  73. 		this.totalPages = totalPages;
  74. 	}
  75.  
  76. 	public int getTotalSize() {
  77. 		return totalSize;
  78. 	}
  79.  
  80. 	public void setTotalSize(int totalSize) {
  81. 		this.totalSize = totalSize;
  82. 	}
  83.  
  84. 	public List<?> getList() {
  85. 		return list;
  86. 	}
  87.  
  88. 	public void setList(List<?> list) {
  89. 		this.list = list;
  90. 	}
  91.  
  92. 	@Override
  93. 	public String toString() {
  94. 		return "Pager{" +
  95. 				"pageSize=" + pageSize +
  96. 				", pageNo=" + pageNo +
  97. 				", totalPages=" + totalPages +
  98. 				", totalSize=" + totalSize +
  99. 				", list=" + list +
  100. 				'}';
  101. 	}
  102. }
BeanUtils复制拷贝类
  1. package com.bootdo.system.util;
  2.  
  3. import java.beans.BeanInfo;
  4. import java.beans.IntrospectionException;
  5. import java.beans.Introspector;
  6. import java.beans.PropertyDescriptor;
  7. import java.lang.reflect.Field;
  8. import java.lang.reflect.InvocationTargetException;
  9. import java.lang.reflect.Method;
  10. import java.util.ArrayList;
  11. import java.util.Collection;
  12. import java.util.Date;
  13. import java.util.HashMap;
  14. import java.util.HashSet;
  15. import java.util.List;
  16. import java.util.Map;
  17. import java.util.Map.Entry;
  18. import java.util.Set;
  19.  
  20. import org.apache.commons.beanutils.BeanMap;
  21. import org.apache.commons.beanutils.PropertyUtils;
  22. import org.apache.commons.lang3.StringUtils;
  23. import org.slf4j.Logger;
  24. import org.slf4j.LoggerFactory;
  25. import org.springframework.util.ClassUtils;
  26. import org.springframework.util.CollectionUtils;
  27.  
  28. import com.alibaba.fastjson.JSONObject;
  29.  
  30.  
  31. /**
  32.  * 摘要：Bean拷贝工具类
  33.  * @author Williams.li
  34.  * @version 1.0
  35.  * @Date 2016年12月21日
  36.  */
  37. public class BeanUtils extends org.apache.commons.beanutils.BeanUtils{
  38. 	private static final Logger logger = LoggerFactory.getLogger(BeanUtils.class);
  39. 	
  40. 	@SuppressWarnings("rawtypes")
  41. 	private static Map<Class, List<Field>> fieldsMap = new HashMap<Class, List<Field>>();
  42. 	
  43. 	/**
  44. 	 * 拷贝list列表(排除Null)
  45. 	 * @param sourceList    源列表
  46. 	 * @param targetClass   目标class
  47. 	 */
  48. 	public static <T> List<T> copyList(List<?> sourceList, Class<T> targetClass) {
  49. 		if(null == sourceList || sourceList.size() == 0){
  50. 			return null;
  51. 		}
  52. 		try{
  53. 			List<T> targetList = new ArrayList<T>(sourceList.size());
  54. 			for(Object source : sourceList){
  55. 				T target = targetClass.newInstance();
  56. 				BeanUtils.copyNotNull(target,source);
  57. 				targetList.add(target);
  58. 			}
  59. 			return targetList;
  60. 		}catch(Exception e){
  61. 			logger.error(e.getMessage(),e);
  62. 			return null;
  63. 		}
  64. 	}
  65.  
  66. 	/**
  67. 	 * 拷贝Object(排除Null)
  68. 	 * @param target 目标
  69. 	 * @param orig 源
  70. 	 */
  71. 	public static <T> T copyNotNull(Class<T> targetClass, Object orig) {
  72. 		if( null == orig){
  73. 			return null;
  74. 		}
  75. 		try {
  76. 			T target = targetClass.newInstance();
  77. 			return copy(target, orig, false);
  78. 		}catch(Exception e){
  79. 			logger.error(e.getMessage(),e);
  80. 			return null;
  81. 		}
  82. 	}
  83. 	
  84. 	/**
  85. 	 * 拷贝Object(排除Null)
  86. 	 * @param target 目标
  87. 	 * @param orig 源
  88. 	 */
  89. 	public static <T> T copyNotNull(T target, Object orig) {
  90. 		if(null == target || null == orig){
  91. 			return null;
  92. 		}
  93. 		return copy(target, orig, false);
  94. 	}
  95. 	
  96. 	
  97.  
  98. 	@SuppressWarnings("unchecked")
  99. 	public static <T> T copy(T target, Object orig, boolean includedNull, String... ignoreProperties) {
  100. 		if(null == target || null == orig){
  101. 			return null;
  102. 		}
  103. 		try {
  104. 			if (includedNull && ignoreProperties == null) {
  105. 				PropertyUtils.copyProperties(target, orig);
  106. 			} else {
  107. 				List<String> ignoreFields = new ArrayList<String>();
  108. 				if (ignoreProperties != null) {
  109. 					for (String p : ignoreProperties) {
  110. 						ignoreFields.add(p);
  111. 					}
  112. 				}
  113. 				if (!includedNull) {
  114. 					Map<String, Object> parameterMap = new BeanMap(orig);
  115. 					for (Entry<String, Object> entry : parameterMap.entrySet()) {
  116. 						if (entry.getValue() == null || "".equals(entry.getValue())) {
  117. 							String fieldName = entry.getKey();
  118. 							if (!ignoreFields.contains(fieldName)) {
  119. 								ignoreFields.add(fieldName);
  120. 							}
  121. 						}
  122. 					}
  123. 				}
  124. 				org.springframework.beans.BeanUtils.copyProperties(orig, target,
  125. 						ignoreFields.toArray(new String[ignoreFields.size()]));
  126. 			}
  127. 			return target;
  128. 		} catch (Exception e) {
  129. 			logger.error(e.getMessage(), e);
  130. 		}
  131. 		return null;
  132. 	}
  133.  
  134. 	public static List<Field> getAllFields(Class<?> clazz) {
  135. 		if (!ClassUtils.isCglibProxyClass(clazz)) {
  136. 			List<Field> result = fieldsMap.get(clazz);
  137. 			if (result == null) {
  138. 				result = _getAllFields(clazz);
  139. 				fieldsMap.put(clazz, result);
  140. 			}
  141. 			return result;
  142. 		} else {
  143. 			return _getAllFields(clazz);
  144. 		}
  145. 	}
  146.  
  147. 	private static List<Field> _getAllFields(Class<?> clazz) {
  148. 		List<Field> fieldList = new ArrayList<Field>();
  149. 		for (Field field : clazz.getDeclaredFields()) {
  150. 			fieldList.add(field);
  151. 		}
  152. 		Class<?> c = clazz.getSuperclass();
  153. 		if (c != null) {
  154. 			fieldList.addAll(getAllFields(c));
  155. 		}
  156. 		return fieldList;
  157. 	}
  158.  
  159. 	/**
  160. 	 * Get field in class and its super class
  161. 	 * 
  162. 	 * @param clazz
  163. 	 * @param fieldName
  164. 	 * @return
  165. 	 */
  166. 	public static Field getField(Class<?> clazz, String fieldName) {
  167. 		for (Field field : clazz.getDeclaredFields()) {
  168. 			if (field.getName().equals(fieldName)) {
  169. 				return field;
  170. 			}
  171. 		}
  172. 		Class<?> c = clazz.getSuperclass();
  173. 		if (c != null) {
  174. 			return getField(c, fieldName);
  175. 		}
  176. 		return null;
  177. 	}
  178.  
  179. 	/**
  180. 	 * 字符数组合并 注：接受多个数组参数的输入，合并成一个数组并返回。
  181. 	 * 
  182. 	 * @param arr
  183. 	 *            输入的数组参数，一个或若干个
  184. 	 * @return
  185. 	 */
  186. 	public static String[] getMergeArray(String[]... arr) {
  187. 		if (arr == null)
  188. 			return null;
  189. 		int length = 0;
  190. 		for (Object[] obj : arr) {
  191. 			length += obj.length;
  192. 		}
  193. 		String[] result = new String[length];
  194. 		length = 0;
  195. 		for (int i = 0; i < arr.length; i++) {
  196. 			System.arraycopy(arr[i], 0, result, length, arr[i].length);
  197. 			length += arr[i].length;
  198. 		}
  199. 		return result;
  200. 	}
  201.  
  202. 	public static <T> T clone(Object obj, Class<T> targetClazz) {
  203. 		try {
  204. 			return copy(targetClazz.newInstance(), obj, false);
  205. 		} catch (Exception e) {
  206. 			logger.error(e.getMessage(), e);
  207. 		}
  208. 		return null;
  209. 	}
  210.  
  211.  
  212. 	
  213. 	public static <M> List<M> cloneList(List<?> srcList, Class<M> targetClazz) {
  214. 		return ListUtil.clone(srcList, targetClazz);
  215. 	}
  216.  
  217. 	@SuppressWarnings("unchecked")
  218. 	public static <T> List<T> createList(T... objs) {
  219. 		return ListUtil.createList(objs);
  220. 	}
  221.  
  222. 	/**
  223. 	 * 功能：将bean对象转换为url参数
  224. 	 */
  225. 	public static String  bean2urlparam(Object obj){
  226. 		try{
  227. 			StringBuilder builder = new StringBuilder();
  228. 			BeanInfo beanInfo = Introspector.getBeanInfo(obj.getClass());  
  229. 	        PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();  
  230. 	        for (PropertyDescriptor property : propertyDescriptors) {  
  231. 	             String propKey = property.getName();
  232. 	             if(!"class".equals(propKey)){
  233. 	            	 Object propVal = PropertyUtils.getProperty(obj, propKey);
  234. 	            	 if(propVal  != null && StringUtil.isNotEmpty(propVal.toString())){
  235. 	            		 builder.append(propKey).append("=").append(propVal).append("&");
  236. 	            	 }
  237. 	             }
  238. 	        }
  239. 	        if(builder.length() > 0){
  240. 	        	return builder.deleteCharAt(builder.length()-1).toString();
  241. 	        }
  242. 		}catch(Exception e){
  243. 			logger.error(e.getMessage(), e);
  244. 		}
  245. 		return null;
  246. 	}
  247. 	
  248. 	/**
  249. 	 * 功能：将url中的对应obj中的属性参数值替换
  250. 	 */
  251. 	public static String  bean2urlparam(Object obj,String param){
  252. 		try{
  253. 			BeanInfo beanInfo = Introspector.getBeanInfo(obj.getClass());  
  254. 	        PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
  255. 	        String newStr = param;
  256. 	        for (PropertyDescriptor property : propertyDescriptors) {  
  257. 	             String propKey = property.getName();
  258. 	             if(!"class".equals(propKey)){
  259. 	            	 Object propVal = PropertyUtils.getProperty(obj, propKey);
  260. 	            	 if(propVal  != null && StringUtil.isNotEmpty(propVal.toString())){
  261. 	            		 newStr = newStr.replaceAll("="+propKey,"="+propVal.toString());
  262. 	            		 continue;
  263. 	            	 }
  264. 	             }
  265. 	        }
  266. 	        return newStr;
  267. 		}catch(Exception e){
  268. 			logger.error(e.getMessage(), e);
  269. 		}
  270. 		return null;
  271. 	}
  272. 	
  273. 	/**
  274. 	 * 功能：将url中的对应obj和map中的属性参数值替换
  275. 	 */
  276. 	public static String  bean2urlparam(Object obj,String param,Map<String,Object> plus){
  277. 		try{
  278. 			String newParam = bean2urlparam(obj,param);
  279. 			if(!CollectionUtils.isEmpty(plus)){
  280. 				for(Entry<String,Object> entry : plus.entrySet()){
  281. 					Object propVal = entry.getValue();
  282. 					if(propVal  != null && StringUtil.isNotEmpty(propVal.toString())){
  283. 						newParam = newParam.replaceAll("="+entry.getKey(),"="+propVal.toString());
  284. 					}
  285. 				}
  286. 			}
  287. 			if(newParam.indexOf("#")  != -1){
  288. 				newParam = newParam.replaceAll("#","");
  289. 			}
  290. 			return newParam;
  291. 		}catch(Exception e){
  292. 			logger.error(e.getMessage(), e);
  293. 			return null;
  294. 		}
  295. 	}
  296. 	
  297. 	/**
  298. 	 * 功能：将URL参数转换为map
  299. 	 */
  300. 	public static Map<String,String>  urlparam2map(String param){
  301. 		if(StringUtils.isNotEmpty(param)){
  302. 			Map<String,String> map = null;
  303. 			String[] arr = StringUtils.split(param, "&");
  304. 			if(arr != null && arr.length > 0){
  305. 				map = new HashMap<String,String>();
  306. 				for(String item : arr){
  307. 					String[] eqArr = item.split("=");
  308. 					map.put(eqArr[0], eqArr[1]);
  309. 				}
  310. 				return map;
  311. 			}
  312. 		}
  313. 		return null;
  314. 	}
  315. 	
  316. 	/**
  317. 	 * 功能：将URL参数转换为JSONObject
  318. 	 */
  319. 	public static JSONObject urlparam2json(String param){
  320. 		JSONObject paramJSON = new JSONObject();
  321. 		if(StringUtils.isNotEmpty(param)){
  322. 			String[] arr = StringUtils.split(param, "&");
  323. 			if(arr != null && arr.length > 0){
  324. 				for(String item : arr){
  325. 					String[] eqArr = item.split("=");
  326. 					paramJSON.put(eqArr[0], eqArr[1]);
  327. 				}
  328. 			}
  329. 		}
  330. 		return paramJSON;
  331. 	}
  332. 	
  333. 	/**
  334. 	 * 将一个 Map 对象转化为一个 JavaBean
  335. 	 * 
  336. 	 * @param clazz
  337. 	 *            要转化的类型
  338. 	 * @param map
  339. 	 *            包含属性值的 map
  340. 	 * @return 转化出来的 JavaBean 对象
  341. 	 * @throws IntrospectionException
  342. 	 *             如果分析类属性失败
  343. 	 * @throws IllegalAccessException
  344. 	 *             如果实例化 JavaBean 失败
  345. 	 * @throws InstantiationException
  346. 	 *             如果实例化 JavaBean 失败
  347. 	 * @throws InvocationTargetException
  348. 	 *             如果调用属性的 setter 方法失败
  349. 	 */
  350. 	@SuppressWarnings("rawtypes")
  351. 	public static <T> T toBean(Class<T> clazz, Map map) {
  352. 		T obj = null;
  353. 		try {
  354. 			BeanInfo beanInfo = Introspector.getBeanInfo(clazz);
  355. 			obj = clazz.newInstance(); // 创建 JavaBean 对象
  356.  
  357. 			// 给 JavaBean 对象的属性赋值
  358. 			PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
  359. 			for (int i = 0; i < propertyDescriptors.length; i++) {
  360. 				PropertyDescriptor descriptor = propertyDescriptors[i];
  361. 				String propertyName = descriptor.getName();
  362. 				if (map.containsKey(propertyName)) {
  363. 					// 下面一句可以 try 起来，这样当一个属性赋值失败的时候就不会影响其他属性赋值。
  364. 					Object value = map.get(propertyName);
  365. 					if ("".equals(value)) {
  366. 						value = null;
  367. 					}
  368. 					Object[] args = new Object[1];
  369. 					args[0] = value;
  370. 					try {
  371. 						descriptor.getWriteMethod().invoke(obj, args);
  372. 					} catch (InvocationTargetException e) {
  373. 						logger.info("字段映射失败");
  374. 					}
  375. 				}
  376. 			}
  377. 		} catch (IllegalAccessException e) {
  378. 			logger.info("实例化 JavaBean 失败");
  379. 		} catch (IntrospectionException e) {
  380. 			logger.info("分析类属性失败");
  381. 		} catch (IllegalArgumentException e) {
  382. 			logger.info("映射错误");
  383. 		} catch (InstantiationException e) {
  384. 			logger.info("实例化 JavaBean 失败");
  385. 		}
  386. 		return (T) obj;
  387. 	}
  388.  
  389. 	/**
  390. 	 * 将一个 JavaBean 对象转化为一个 Map
  391. 	 * 
  392. 	 * @param bean
  393. 	 *            要转化的JavaBean 对象
  394. 	 * @return 转化出来的 Map 对象
  395. 	 * @throws IntrospectionException
  396. 	 *             如果分析类属性失败
  397. 	 * @throws IllegalAccessException
  398. 	 *             如果实例化 JavaBean 失败
  399. 	 * @throws InvocationTargetException
  400. 	 *             如果调用属性的 setter 方法失败
  401. 	 */
  402. 	public static Map<String,Object> toMap(Object bean) {
  403. 		Class<? extends Object> clazz = bean.getClass();
  404. 		Map<String, Object> returnMap = new HashMap<String, Object>();
  405. 		BeanInfo beanInfo = null;
  406. 		try {
  407. 			beanInfo = Introspector.getBeanInfo(clazz);
  408. 			PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
  409. 			for (int i = 0; i < propertyDescriptors.length; i++) {
  410. 				PropertyDescriptor descriptor = propertyDescriptors[i];
  411. 				String propertyName = descriptor.getName();
  412. 				if (!propertyName.equals("class")) {
  413. 					Method readMethod = descriptor.getReadMethod();
  414. 					Object result = null;
  415. 					result = readMethod.invoke(bean, new Object[0]);
  416. 					if (null != propertyName) {
  417. 						propertyName = propertyName.toString();
  418. 					}
  419. 					if (null != result) {
  420. 						if(result instanceof Date){
  421. 							result = DateUtil.getDateFormat((Date)result);
  422. 						}else{
  423. 							result = result.toString();
  424. 						}
  425. 					}
  426. 					returnMap.put(propertyName, result);
  427. 				}
  428. 			}
  429. 		} catch (IntrospectionException e) {
  430. 			logger.info("分析类属性失败");
  431. 		} catch (IllegalAccessException e) {
  432. 			logger.info("实例化 JavaBean 失败");
  433. 		} catch (IllegalArgumentException e) {
  434. 			logger.info("映射错误");
  435. 		} catch (InvocationTargetException e) {
  436. 			logger.info("调用属性的 setter 方法失败");
  437. 		}
  438. 		return returnMap;
  439. 	}
  440. 	
  441.  
  442. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/weixin_40725706/article/detail/68758
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号