Java学习：Java Bean 自动生成 INSERT SQL 及 JDBC 操作优化

功能说明
将Java Bean类转换为标准的INSERT SQL语句模板，支持：

• 自动转换驼峰命名 → 下划线命名
  
• 动态适配全部字段
  
• 生成参数占位符(?)
  

1. public static String generateInsert(Class<?> beanClass){
2.       //基础结构初始化   
3.       StringBuilder sql = new StringBuilder("insert into ");
4.         //表名转换
5.         String tableName = convertToSnake(beanClass.getSimpleName());
6.         sql.append(tableName).append("(");
8.         //Bean 对象中的所有字段 - 注意：Bean对象的字段与数据表的字段————对应
9.         Field[] declaredFields = beanClass.getDeclaredFields();
10.         for (Field declaredField : declaredFields) {
11.             sql.append(convertToSnake(declaredField.getName())).append(",");
12.         }
13.         //去除最后一个逗号
14.         sql.deleteCharAt(sql.length()-1);
16.         sql.append(") values (");
18.         //参数占位符生成
19.         for (int i = 0; i < declaredFields.length; i++) {
20.             sql.append("?").append(",");
21.         }
22.         sql.deleteCharAt(sql.length()-1);
23.         sql.append(")");
25.         return sql.toString();
26.     }

复制代码

自动生成添加SQL,并实现JDBC 添加操作

1.   public static int insert(Object model){
2.         int row = 0;
3.         String sql = SqlGenerate.generateInsert(model.getClass());
5.         Connection connection = DruidUtil.getConnection();
7.         PreparedStatement pst = null;
9.         try {
10.             pst = connection.prepareStatement(sql);
12.             //第四：填充数据
13.             //1.获取Bean对象的 Class对象
14.             Class<?> clazz = model.getClass();
16.             //2.获取Bean对象的所有字段
17.             Field[] fields = clazz.getDeclaredFields();
19.             //3.循环遍历所有的字段，读取字段数据，并填充占位符
20.             for (int i = 0; i < fields.length; i++) {
21.                 fields[i].setAccessible(true);
22.                 //3.1)获取当前遍历字段的数据
23.                 Object currentFieldData = fields[i].get(model);
24.                 //3.2)填充占位符
25.                 pst.setObject(i + 1,currentFieldData);
26.             }
28.             //第五:执行SQL语句
29.             row = pst.executeUpdate();
31.         } catch (Exception e) {
32.             throw new RuntimeException(e);
33.         }
34.         return row;
35.     }

复制代码

测试效果:

1.    // 第一：定义一个员工对象，并初始化相关的信息
2.         Staffs staff = new Staffs();
4.         staff.setId(6);
5.         staff.setName("王八");
6.         staff.setAge(22);
7.         staff.setPhone("110");
8.         staff.setStaPos("项目经理");
9.         staff.setAddTime(LocalDateTime.now());
10.         staff.setUpdateTime(LocalDateTime.now());
12.         System.out.println(DbUtil.insert(staff));

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。