首页 > 代码库 > 使用JDBC的批处理功能
使用JDBC的批处理功能
1 package cn.itcast.jdbc; 2 3 import java.sql.Connection; 4 import java.sql.Date; 5 import java.sql.PreparedStatement; 6 import java.sql.ResultSet; 7 import java.sql.SQLException; 8 import java.sql.Statement; 9 10 public class BatchTest {11 12 public static void main(String[] args) throws SQLException {13 /*for (int i = 0; i < 1000; i++) {14 create(i);15 }*/16 createBatch();17 }18 19 static int create(int i) throws SQLException {20 Connection conn = null;21 PreparedStatement ps = null;22 ResultSet rs = null;23 24 try {25 conn = jdbcUtils.getConnection();26 27 String sql = "insert into user(name,birthday,money) values(?,?,?)";28 29 ps = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);30 ps.setString(1, "name" + i);31 ps.setDate(2, (java.sql.Date) new Date(System.currentTimeMillis()));32 ps.setFloat(3, 1000F + i);33 34 ps.executeUpdate();35 36 rs = ps.getGeneratedKeys();37 int id = 0;38 39 if (rs.next())40 id = rs.getInt(1);41 42 return id;43 44 } finally {45 jdbcUtils.free(rs, ps, conn);46 }47 }48 49 static void createBatch() throws SQLException {50 Connection conn = null;51 PreparedStatement ps = null;52 ResultSet rs = null;53 54 try {55 conn = jdbcUtils.getConnection();56 57 String sql = "insert into user(name,birthday,money) values(?,?,?)";58 59 ps = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);60 61 for (int i = 0; i < 1000; i++) {62 ps.setString(1, "name" + i);63 ps.setDate(2, new Date(System.currentTimeMillis()));64 ps.setFloat(3, 1000F + i);65 66 ps.addBatch();67 }68 69 int[] is = ps.executeBatch();70 71 } finally {72 jdbcUtils.free(rs, ps, conn);73 }74 }75 76 }
使用JDBC的批处理功能
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。