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);
            }
        }
    }

  • 相关阅读:
    文件操作
    join,列表和字典用for循环的删除,集合,深浅拷贝
    java多线程基础
    nginx应用及性能调优
    nginx 基本功能
    SpringBoot2.x 启动过程详解
    shell脚本的基本使用
    使用 maven 的 `wagon-maven-plugin`插件 快速部署 到不同的 环境
    Netty笔记(7)
    Netty笔记(6)
  • 原文地址:https://www.cnblogs.com/flying607/p/3462315.html
Copyright © 2011-2022 走看看