批量插入、修改：传入sql
private void deal(List<String> datali) { try { Connection conn = MysqlConnPool.getInstance().getConnection(); conn.setAutoCommit(false); PreparedStatement psm; psm = conn.prepareStatement(""); for (String sql : datali) { psm.addBatch(sql); } psm.executeBatch(); conn.commit(); psm.close(); conn.setAutoCommit(true); conn.close(); } catch (SQLException e) { e.printStackTrace(); } }获取数据
private void getMysqlList() { try {// conn.create Connection conn = MysqlConnPool.getInstance().getConnection(); Statement stmt = null; // 表示数据库更新操作 ResultSet result = null; // 表示接受数据库查询到的结果 stmt = conn.createStatement(); // tatement接口需要通过connection接口进行实例化操作 result = stmt.executeQuery("SELECT id,company FROM COMPANY_ALL WHERE MARK=0 LIMIT 10000"); // 执行sql语句，结果集放在result中 while (result.next()) { // 判断是否还有下一行 dataList.add("update COMPANY_ALL set sm3 = '" + SM3Util.encodeSM3(result.getString("company")) + "',mark=1 where id = " + result.getInt("id")); } result.close(); stmt.close(); conn.close(); } catch (Exception e) { try { e.printStackTrace(); System.out.println("mysql 链接异常 sleep5s"); Thread.sleep(50000); } catch (InterruptedException e1) { e1.printStackTrace(); } } }