优质文章和精品资源, 第一时间送达

format_png

关注公众号后台回复资源获取实战教学资料+视频

String sql = "insert into testdb.tuser (name, remark, createtime, updatetime) values (?, ?, ?, ?)";
for(int i = 0; i < m; i++) {
//从池中获取连接
Connection conn = myBroker.getConnection();
PreparedStatement pstmt = conn.prepareStatement(sql);
for(int k = 0; k < n; k++) {
        pstmt.setString(1, RandomToolkit.generateString(12));
        pstmt.setString(2, RandomToolkit.generateString(24));
        pstmt.setDate(3, newDate(System.currentTimeMillis()));
        pstmt.setDate(4, newDate(System.currentTimeMillis()));
//加入批处理
        pstmt.addBatch();
}
    pstmt.executeBatch(); //执行批处理
    pstmt.close();
    myBroker.freeConnection(conn); //连接归池
}

多值插入SQL

普通插入SQL：INSERT INTO TBL_TEST (id) VALUES(1)

多值插入SQL：INSERT INTO TBL_TEST (id) VALUES (1), (2), (3)

使用多值插入SQL，SQL语句的总长度减少，即减少了网络IO，同时也降低了连接次数，数据库一次SQL解析，能够插入多条数据。

事务(N条提交一次)

在一个事务中提交大量INSERT语句可以提高性能。

1、将表的存储引擎修改为myisam 2、将 sql 拼接成字符串，每 1000 条左右提交事务。

执行多条SQL语句，实现数据库事务。
mysql数据库

多条SQL语句

public void ExecuteSqlTran(List SQLStringList)
{

using (MySqlConnection conn = new MySqlConnection(connectionString))
{
    if (DBVariable.flag)
    {
        conn.Open();
        MySqlCommand cmd = new MySqlCommand();
        cmd.Connection = conn;
        MySqlTransaction tx = conn.BeginTransaction();
        cmd.Transaction = tx;
        try
        {
            for (int n = 0; n < SQLStringList.Count; n++)
            {
                string strsql = SQLStringList[n].ToString();
                if (strsql.Trim().Length > 1)
                {
                    cmd.CommandText = strsql;
                    cmd.ExecuteNonQuery();
                }
                //后来加上的  
                if (n > 0 && (n % 1000 == 0 || n == SQLStringList.Count - 1))
                {
                    tx.Commit();
                    tx = conn.BeginTransaction();
                }
            }
            //tx.Commit();//原来一次性提交  
        }
        catch (System.Data.SqlClient.SqlException E)
        {
            tx.Rollback();
            throw new Exception(E.Message);
        }
    }
}