javabean是对面向对象思想的一种具体实施的表现,本文重点给大家介绍利用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 @NoArgsConstructor public class Cat { private String id; private String food; private String weight; private String height; }待查询的狗
@Data @AllArgsConstructor public class Dog { private String id; private String food; private String weight; private String height; }待查询的猪
@Data @AllArgsConstructor public class Pig { private String id; private String food; private String weight; private String height; private String pid; }自定义传输实体对象，这里定义了需要查询那些集合对象
@Data @AllArgsConstructor @NoArgsConstructor public class CustomDataTransferDTO{ /** * =============================================================== * 数据查询结果 * =============================================================== */ /** * 待查询的猫信息 */ private List catList; /** * 待查询的狗信息 通过注解来明确关联关系 */ @CustomAnnotation.connectTable(tablePath = "com.study.customdatatransfer.Pig") private List dogList; /** * 待查询的猪信息 */ @Ignore private List pigList; 2，新建参数关系类
公共参数关系类
/** * 这里为共通参数信息设置 * @author jieya */ @Data @AllArgsConstructor @NoArgsConstructor public class CommonParameterDTO { /** * =============================================================== * 这里配置所有集合查询的公共查询条件 * =============================================================== */ /** * 主键信息 */ public String id; }自定义查询参数
/** * 自定义查询条件及关联表信息查询实体对象 * @author Administrator */ @Data @AllArgsConstructor @NoArgsConstructor public class TableAndParamsDTO { /** * 主表名 这里是查询那个实体对象的数据，这里的table值一定要和CustomDataTransferDTO中的List的泛型对上 */ @CustomAnnotation.Table private String table; /** * =============================================================== * 自定义参数 * =============================================================== */ /** * 自定义查询参数 search 标记这是一个查询参数 */ @CustomAnnotation.search private 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 执行完成之后，就可以获取到咱们需要的数据了。
4.获取到数据后，发送给另一端，进行解析保存
/** * 保存待处理数据 * * @param obj */ @Override public 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对象数据传输的资料请关注html中文网其它相关文章！
以上就是利用Java实体bean对象批量数据传输处理方案小结的详细内容，更多请关注0133技术站其它相关文章！
