JDBC 批处理
public class BatchTest {
/**
* @param args
* @throws SQLException
*/
public static void main(String[] args) throws SQLException {
long start = System.currentTimeMillis();
for (int i = 0; i < 100; i++)
create(i);
long end = System.currentTimeMillis();
System.out.println("create:" + (end - start));
start = System.currentTimeMillis();
createBatch();
end = System.currentTimeMillis();
System.out.println("createBatch:" + (end - start));
}
static void create(int i) throws SQLException {
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conn = JdbcUtils.getConnection();
String sql = "insert into user(name,birthday, money) values (?, ?, ?) ";
ps = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
ps.setString(1, "no batch name" + i);
ps.setDate(2, new Date(System.currentTimeMillis()));
ps.setFloat(3, 100f + i);
ps.executeUpdate();
} finally {
JdbcUtils.free(rs, ps, conn);
}
}
static void createBatch() throws SQLException {
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conn = JdbcUtils.getConnection();
String sql = "insert into user(name,birthday, money) values (?, ?, ?) ";
ps = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
for (int i = 0; i < 100; i++) {
ps.setString(1, "batch name" + i);
ps.setDate(2, new Date(System.currentTimeMillis()));
ps.setFloat(3, 100f + i);
ps.addBatch();//sql语句封包一起发送到数据库服务器
}
int[] is = ps.executeBatch();
} finally {
JdbcUtils.free(rs, ps, conn);
}
}
}
相关文章
- 开涛spring3(7.2) - 对JDBC的支持 之 7.2 JDBC模板类
- Sharding-JDBC 从入门到精通 -2
- 【Java编程】建立一个简单的JDBC连接-Drivers, Connection, Statement and PreparedStatement
- 报错:Sqoop2 Error message: Class not found JDBC Driver Class: com.mysql.jdbc.Driver
- 22JavaWeb基础 - JDBC事务
- 微服务,微架构[二]之springboot集成jdbc
- jdbc连接数据库使用sid和service_name的区别
- 基于zeppelin JDBC Interpreter进行jdbc数据源的可视化交互分析时,如何设置参数
- 实现简易JDBC框架
- JDBC 连接 MySQL 异常:com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: Public Key Retrieval is not allowed
- Tomcat 的 JDBC 连接池
- The web application [] registered JDBC driver [com.mysql.jdbc.Driver] but failed to unregister
- JDBC ResultSet分析
- JDBC批处理---(java 对数据库的回滚) .
- JDBC事务和数据库事务嵌套的讨论 .
- Java JDBC批处理插入数据操作
- Java面向对象(四)学习笔记 JDBC
- 【数据库】JDBC下PrepareStatement测试类的添、删、改 和 查的方法
- JDBC批处理executeBatch
- hive JDBC客户端启动
- [已解决]报错:Error: Could not open client transport with JDBC Uri: jdbc:hive2://hadoop102:10000
- Java新手入门200例124之用JDBC连接Mysql数据库