MySQL快速插入/更新大量记录
最近的项目中需要将几个dump文件(文本格式、1~2G)的记录导入到mysql数据库中,由于数据量比较大(几百万、上千万条记录),有插
最近的项目中需要将几个dump文件(文本格式、1~2G)的记录导入到mysql数据库中,由于数据量比较大(几百万、上千万条记录),有插入记录,也有更新记录的,导致插入\更新速度比较慢。
一开始,将单条sql语句交给mysql执行,测试下来,最快一次也要一个半小时。于是想办法改进之。
(1)针对插入记录,使用sql语句一次插入多条记录。实例:
INSERT INTO tbl_name (a,b,c) VALUES(1,2,3),(4,5,6),(7,8,9);
具体参见sql语法:
在程序中,使用循环拼接sql语句,然后一次性丢给myql_query()处理即可。
需要注意的是,sql语句不是越长越好,太长了可能会超出mysql限制(听同事介绍,mysql的限制是63M)。
我在实测中,我限制sql长度在10M:
for(...)
{
m_strSQL += ...;
if (m_strSQL.length() > 10485760) //10M
{
m_pMysqlStatement->execute(m_strSQL.substr(0, m_strSQL.length() - 1));
m_strSQL= "INSERT INTO location (locationid, name, alternatename) VALUES ";
}
}
测试结果为:
8267787条记录,耗时754秒(数据库在局域网内的不同机器上),基本满足要求。
(2)对于更新记录,由于update语法不支持一次更新多条记录,无法使用类似“INSERT INTO tbl_name (a,b,c) VALUES(1,2,3),(4,5,6),(7,8,9);”的形式进行更新,,只能拼接多条sql语句一起更新:
update location set languages = 'zh' where locationid = '12344';update location set postalcode = '14343' where locationid = '3455';
但是这样一来,问题出现了:
(I)在连接数据库时需要启用multi-query支持,允许一次执行多条sql语句。参见:
(II)还需要处理resultset的释放问题,否则mysql会报错:"Commands out of sync; you can't run this command now"
(III)针对update语句,虽然并没有resultset返回,但仍然需要释放。而由于未知原因(可能是sql语句太长?),释放resultset非常耗时,最终算下来得不偿失。
下一篇: 一台MySQL数据库启动多个实例
推荐阅读
-
MySQL入门(四) 数据表的数据插入、更新、删除
-
Mysql快速插入千万条数据的实战教程
-
PHP实现MySQL更新记录的代码
-
MySQL数据库迁移快速导出导入大量数据
-
MySQL实现无数据插入,有数据更新的实例教程
-
python更新插入mySQL数据库教程
-
使用PreparedStatement对象快速插入MySQL100万条数据
-
C# ASP.NET+MySQL数据库命名了1个long字段,和C#的保留字重名,并且和MySQL数据库的关键字重名,如何用Parameters.AddWithValue方法插入新记录到数据库
-
记一次更新Mysql表记录时,PreparedStatement.setTimestamp抛出NullPointerException的问题
-
MySQL中获取刚插入记录的自增长主键的方法