zoukankan      html  css  js  c++  java
  • 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);
            }
        }
    }

  • 相关阅读:
    Azure存储账户的日志分析方法
    导出zabbix监控数据
    centos7下kubernetes(18。kubernetes-健康检查)
    centos7下kubernetes(17。kubernetes-回滚)
    unity接入安卓SDK,与安卓相互通信
    (转)坐标 旋转 计算
    矩阵运算试验
    photonServer学习之连接数据库
    C#委托链
    git命令大全
  • 原文地址:https://www.cnblogs.com/flying607/p/3462315.html
Copyright © 2011-2022 走看看