锐客网

  1. 首页 > it技术 > >

利用Java实体bean对象批量数据传输处理方案小结

javaBean在MVC设计模型中是model，又称模型层，在一般的程序中，我们称它为数据层，就是用来设置数据的属性和一些行为，然后我会提供获取属性和设置属性的get/set方法JavaBean是一种JAVA语言写成的可重用组件。为写成JavaBean，类必须是具体的和公共的，并且具有无参数的构造器。
下面通过本文给大家分享利用Java实体bean对象批量数据传输处理的解决方案。
需求 现在有两方数据库表结构相同，一方A、另一个方B，现想从A处查询出多个表的数据，传输到B地保存起来。
解决方案1 最简单粗暴的方法就是，查询出A处相关表的数据封装到实体对象中，之后放到List集合中，再传递给B处，B处再遍历集合，将数据保存到B处。但是此处的问题是想要再添加一个表的数据时，需要改查询的代码还需要改保存的代码，非常麻烦，所以不建议使用。
方案2 新建一个需要准备哪些数据的实体类对象
待查询的猫

@Data@AllArgsConstructor@NoArgsConstructorpublic class Cat {private String id; private String food; private String weight; private String height; }

待查询的狗
@Data@AllArgsConstructorpublic class Dog {private String id; private String food; private String weight; private String height; }

待查询的猪
@Data@AllArgsConstructorpublic class Pig {private String id; private String food; private String weight; private String height; private String pid; }

【利用Java实体bean对象批量数据传输处理方案小结】自定义传输实体对象，这里定义了需要查询那些集合对象
@Data@AllArgsConstructor@NoArgsConstructorpublic class CustomDataTransferDTO{/*** ===============================================================*数据查询结果* ===============================================================*//*** 待查询的猫信息*/private List catList; /*** 待查询的狗信息 通过注解来明确关联关系*/@CustomAnnotation.connectTable(tablePath = "com.study.customdatatransfer.Pig")private List dogList; /*** 待查询的猪信息*/@Ignoreprivate List pigList;

2，新建参数关系类
公共参数关系类
/** * 这里为共通参数信息设置 * @author jieya */@Data@AllArgsConstructor@NoArgsConstructorpublic class CommonParameterDTO {/*** ===============================================================*这里配置所有集合查询的公共查询条件* ===============================================================*//*** 主键信息*/public String id; }

自定义查询参数
/** * 自定义查询条件及关联表信息查询实体对象 * @author Administrator */@Data@AllArgsConstructor@NoArgsConstructorpublic class TableAndParamsDTO {/*** 主表名 这里是查询那个实体对象的数据，这里的table值一定要和CustomDataTransferDTO中的List的泛型对上*/@CustomAnnotation.Tableprivate String table; /*** ===============================================================*自定义参数* ===============================================================*//*** 自定义查询参数search 标记这是一个查询参数*/@CustomAnnotation.searchprivate String food; /*** connectSearchTerm(term = "id")这个标记为这是连表查询的副表，主表的id等于副表的pid*/@CustomAnnotation.connectSearchTerm(term = "id")private String pid; }

新建自定义处理主方法
/** * 自定义数据处理主方法 * * @author Administrator */public class CustomDataMain {private static final List catList = new ArrayList<>(); private static final List dogList = new ArrayList<>(); private static final List pigList = new ArrayList<>(); private static List tableAndParamsList = new ArrayList(); private static CommonParameterDTO commonParameter = new CommonParameterDTO(); static {catList.add(new Cat("1", "面包1", "10", "12")); catList.add(new Cat("2", "面包2", "10", "12")); catList.add(new Cat("3", "面包3", "10", "12")); catList.add(new Cat("4", "面包4", "10", "12")); dogList.add(new Dog("1", "米饭1", "10", "12")); dogList.add(new Dog("2", "米饭2", "10", "12")); dogList.add(new Dog("3", "米饭3", "10", "12")); dogList.add(new Dog("4", "米饭4", "10", "12")); pigList.add(new Pig("1", "麻辣烫1", "10", "12", "1")); pigList.add(new Pig("2", "麻辣烫2", "10", "12", "2")); pigList.add(new Pig("3", "麻辣烫3", "10", "12", "3")); pigList.add(new Pig("4", "麻辣烫4", "10", "12", "4")); }public static void main(String[] args) throws Exception {// 共通参数commonParameter.setId("1"); //TableAndParamsDTO tableAndParamsDTO = new TableAndParamsDTO(); tableAndParamsDTO.setTable("Pig"); tableAndParamsDTO.setFood("麻辣烫1"); tableAndParamsDTO.setPid("id"); tableAndParamsList.add(tableAndParamsDTO); findCustomData(CustomDataTransferDTO.class); }public static Object findCustomData(Class clazz) throws Exception {// 实例化数据传输类Object obj = clazz.newInstance(); // 首先得到pojo所定义的字段Field[] fields = clazz.getDeclaredFields(); for (Field curField : fields) {// 设置字段可访问（必须，否则报错）curField.setAccessible(true); // 如果if (!curField.isAnnotationPresent(Ignore.class)) {CustomAnnotation.connectTable annotation = curField.getAnnotation(CustomAnnotation.connectTable.class); String sideTablePath = null; if (annotation != null) {sideTablePath = annotation.tablePath(); }Class curFieldType = curField.getType(); // 集合List元素if (curFieldType.equals(List.class)) {// 当前集合的泛型类型Type genericType = curField.getGenericType(); if (null == genericType) {continue; }if (genericType instanceof ParameterizedType) {ParameterizedType pt = (ParameterizedType) genericType; // 得到泛型里的class类型对象Class actualTypeArgument = (Class) pt.getActualTypeArguments()[0]; // 获取完整路径信息String tablePath = actualTypeArgument.getName(); // 获取实体对象名称String tableName = actualTypeArgument.getSimpleName(); // 获取该实体对象设置的自定义信息TableAndParamsDTO tableAndParams = tableAndParamsList.stream().filter(o -> o.getTable().equals(tableName)).findAny().orElse(null); // 拼接hql和执行获取数据obj = connectSqlAndExexute(obj, clazz, tablePath, tableAndParams, sideTablePath); }} else {System.out.println(curField.getName() + "--暂不支持的类型--" + curFieldType.getSimpleName()); }} else {System.out.println("Ignore----"); }}return null; }/*** 连接sql并获取数据** @param obj* @param clazz* @param tablePath* @param tableAndParams* @param sideTablePath* @return* @throws Exception*/private static Object connectSqlAndExexute(Object obj, Class clazz, String tablePath,TableAndParamsDTO tableAndParams, String sideTablePath) throws Exception {int lastIndex = tablePath.lastIndexOf("."); String tableName = tablePath.substring(lastIndex + 1); List param = new ArrayList<>(); // 查询语句StringBuilder selectBuilder = new StringBuilder(" select * from " + tableName + " where 1=1"); // 查询条件StringBuilder whereBuilder = new StringBuilder(); // 拼接共通参数if (commonParameter != null) {// 拼接共通参数Field[] fields = commonParameter.getClass().getDeclaredFields(); for (Field curField : fields) {// 设置字段可访问（必须，否则报错）curField.setAccessible(true); String name = curField.getName(); whereBuilder.append(" and " + name + "=?"); Object vlaue = ReflectionUtil.getVlaue(commonParameter, name, ""); param.add(vlaue); }}// 如果设置了表和特殊参数则按照特殊情况处理，否则使用共通参数拼接条件if (tableAndParams != null) {//遍历该实体对象设置的配置信息// 获取主表String table = tableAndParams.getTable(); // 拼接自定义经营范围Field[] fields = tableAndParams.getClass().getDeclaredFields(); for (Field field : fields) {// 判断是否为查询条件if (field.isAnnotationPresent(CustomAnnotation.search.class)) {whereBuilder.append(" and " + field.getName() + "=?"); Object vlaue = ReflectionUtil.getVlaue(tableAndParams, field.getName(), ""); param.add(vlaue); }// 关联查询if (field.isAnnotationPresent(CustomAnnotation.connectSearchTerm.class)) {String name = field.getName(); String values = GsUtils.blankNull(ReflectionUtil.getVlaue(tableAndParams, name, "")); String[] split = values.split(","); String sideWhere = ""; for (int i = 0; i < split.length; i++) {sideWhere += " and " + name + " in("; sideWhere += "'" + split[i] + "'" + ","; }; sideWhere = sideWhere.substring(0, sideWhere.length() - 1); sideWhere += " )"; whereBuilder.append(sideWhere); }}}// 获取查询对象的class对象Class tableClazz = Class.forName(tablePath); // hql不为空和hql中不包含and符号时，禁止执行sql，防止全库扫描if (StringUtils.isEmpty(whereBuilder.toString())) {throw new Exception("hql错误，因不存在and查询条件,会导致全库扫描" + selectBuilder.toString()); }// TODO 执行sql 将查询到数据封装到list对象中// List list = baseDao.findByHql(selectBuilder.toString()+whereBuilder.toString(),tableClazz,param); // TODO 这段代码为无用的为获取数据的代码List list = findDataInfo(tableName,whereBuilder,param); // 将查询到的信息添加到传输文件实体对象中if (list != null && list.size() > 0) {obj = ReflectionUtil.setValue(obj, clazz, tableName, list); }// 连表查询if (sideTablePath != null) {String sideTableName = Class.forName(sideTablePath).getSimpleName(); // 获取该实体对象设置的自定义信息TableAndParamsDTO sideTableAndParams = tableAndParamsList.stream().filter(o -> o.getTable().equals(sideTableName)).findAny().orElse(null); // 拼接自定义经营范围Field[] sideFields = sideTableAndParams.getClass().getDeclaredFields(); for (Field field : sideFields) {// 关联查询if (field.isAnnotationPresent(CustomAnnotation.connectSearchTerm.class)) {String term = field.getAnnotation(CustomAnnotation.connectSearchTerm.class).term(); String sideParam = ""; for (Object obj1 : list) {Object value = https://www.it610.com/article/ReflectionUtil.getVlaue(obj1, (String) term,""); if (value != null) {sideParam += value + ","; }}if (StringUtils.isEmpty(sideParam)) {throw new Exception("关联表但为获取到关联条件信息" + selectBuilder.toString()); }// 将值设置到对象中field.setAccessible(true); field.set(sideTableAndParams, sideParam); }}// 拼接hql和执行获取数据obj = connectSqlAndExexute(obj, clazz, sideTablePath, sideTableAndParams, null); }System.out.println("tableAndParams:" + tableAndParams + "commonParams:" + commonParameter + "执行sql语句：" + selectBuilder.toString() + whereBuilder.toString() + "查询条件：" + param + "查询结果：" + list); return obj; }private static List findDataInfo(String tableName, StringBuilder whereBuilder, List param) {List list = new ArrayList(); if("Cat".equals(tableName)){list.add(catList.get(0)); return list; }if("Dog".equals(tableName)){list.add(dogList.get(0)); return list; }return list; }}
执行完成之后，就可以获取到咱们需要的数据了。
4.获取到数据后，发送给另一端，进行解析保存
/*** 保存待处理数据** @param obj*/@Overridepublic void saveOtherInfo(Object obj) throws Exception {// 首先得到pojo所定义的字段Field[] fields = obj.getClass().getDeclaredFields(); for (Field curField : fields) {// 设置字段可访问（必须，否则报错）curField.setAccessible(true); Class curFieldType = curField.getType(); // 集合List元素if (curFieldType.equals(List.class)) {// 当前集合的泛型类型Type genericType = curField.getGenericType(); if (null == genericType) {continue; }if (genericType instanceof ParameterizedType) {Object object = ReflectionUtil.getVlaue(obj,(String) curField.getName(),""); if(object!=null){List list = (List)object; for (int i=0; i
这样两端进行数据传输就完成了，或中间使用消息中间件进行传输也是可以的。
以上就是利用Java实体bean对象批量数据传输处理的详细内容，更多关于java bean对象数据传输的资料请关注脚本之家其它相关文章！

    推荐阅读


    上一篇：Java中的ThreadLocal详解

    下一篇：Java之线程编程的4种方法实现案例讲解