JDBC在Java代码中批量往Mysql数据库中插入数据

桃扇骨 2023-02-09 14:12 121阅读 0赞

直接上代码，代码中注释很详细。

/*
    * 要求：
    * Java中批量插入数据到MySQL数据库。
    * */
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    
    public class mysqlBathedTest {
        public static void main(String[] args) {
            Connection conn = null;
            PreparedStatement ppstatement = null;
            ResultSet resultSet = null;
            JDBCUtils jdbcUtils = new JDBCUtils();
            try{
                //注册驱动，加载驱动，连接数据库，由于需要批量处理，所以在配置连接
                // 数据库的时候需要添加批量处理参数声明，即rewriteBatchedStatements=true
                conn = jdbcUtils.getConnection();
                //statement执行sql语句存在注入漏洞，所以用preparedStatement执行sql语句预声明
                String sql = "insert into bathed values(null,?)";
                //声明
                ppstatement = conn.prepareStatement(sql);
                //我们记录一下开始的时间节点，看下执行需要的时间
                long begin = System.currentTimeMillis();
                //循环插入
                for(int i=1;i<=10000;i++){
                    //往sql语句加入差数
                    ppstatement.setString(1,"name"+i);
                    //加入批量
                    ppstatement.addBatch();
                    if(i%1000==0){
                        //为了提高效率，我们每1000条语句就执行批量插入
                        ppstatement.executeBatch();
                        //插入后释放一下资源，防止内存不足
                        ppstatement.clearBatch();
                    }
                }
                //插入完成，记录下结束时间，打印处理时间
                long end = System.currentTimeMillis();
                System.out.println("消耗时间："+(end-begin));
    
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                //资源释放
                jdbcUtils.relResource(conn,ppstatement,resultSet);
            }
        }
    }