请允许我成为你的夏季——shiro、jdbcInsertall

 1 /**
 2      * 执行数据库插入操作
 3      *
 4      * @param datas     插入数据表中key为列名和value为列对应的值的Map对象的List集合
 5      * @param tableName 要插入的数据库的表名
 6      * @return 影响的行数
 7      * @throws SQLException SQL异常
 8      */
 9     public int insertAll(String tableName, List<Map<String, Object>> datas) throws SQLException {
10         /**影响的行数**/
11         int affectRowCount = -1;
12         Connection connection = null;
13         PreparedStatement preparedStatement = null;
14         try {
15             /**从数据库连接池中获取数据库连接**/
16             connection = getConnectionTwo();
17 
18 
19             Map<String, Object> valueMap = datas.get(0);
20             /**获取数据库插入的Map的键值对的值**/
21             Set<String> keySet = valueMap.keySet();
22             Iterator<String> iterator = keySet.iterator();
23             /**要插入的字段sql，其实就是用key拼起来的**/
24             StringBuilder columnSql = new StringBuilder();
25             /**要插入的字段值，其实就是？**/
26             StringBuilder unknownMarkSql = new StringBuilder();
27             Object[] keys = new Object[valueMap.size()];
28             int i = 0;
29             while (iterator.hasNext()) {
30                 String key = iterator.next();
31                 keys[i] = key;
32                 columnSql.append(i == 0 ? "" : ",");
33                 columnSql.append(key);
34 
35                 unknownMarkSql.append(i == 0 ? "" : ",");
36                 unknownMarkSql.append("?");
37                 i++;
38             }
39             /**开始拼插入的sql语句**/
40             StringBuilder sql = new StringBuilder();
41             sql.append("INSERT INTO ");
42             sql.append(tableName);
43             sql.append(" (");
44             sql.append(columnSql);
45             sql.append(" )  VALUES (");
46             sql.append(unknownMarkSql);
47             sql.append(" )");
48 
49             /**执行SQL预编译**/
50             preparedStatement = connection.prepareStatement(sql.toString());
51             /**设置不自动提交，以便于在出现异常的时候数据库回滚**/
52             connection.setAutoCommit(false);
53             System.out.println(sql.toString());
54             for (int j = 0; j < datas.size(); j++) {
55                 for (int k = 0; k < keys.length; k++) {
56                     preparedStatement.setObject(k + 1, datas.get(j).get(keys[k]));
57                 }
58                 preparedStatement.addBatch();
59             }
60             int[] arr = preparedStatement.executeBatch();
61             connection.commit();
62             affectRowCount = arr.length;
63             System.out.println("成功了插入了" + affectRowCount + "行");
64             System.out.println();
65         } catch (Exception e) {
66             if (connection != null) {
67                 connection.rollback();
68             }
69             e.printStackTrace();
70             throw e;
71         } finally {
72             if (preparedStatement != null) {
73                 preparedStatement.close();
74             }
75             if (connection != null) {
76                 connection.close();
77             }
78         }
79         return affectRowCount;
80     }