您好,欢迎访问一九零五行业门户网

[转载]mysql插入大量数据_MySQL

bitscn.com
mysql的批量数据格式,
比如
insert into tables (lable1,lable2,lable3,...) 
values(num11,num12,num13,...), 
(num21,num22,num23,...),
....
(numn1,numn2,numn3,..);
我在前文中叙述的,每个账户的每个采集点就会生成几百个数据,这几百个数据我组合成上述一条语句,20多个账户多个采集点我一共生成上述语句300--800多条,每条的数据项300-500个,所以每次插入的数据共计10000--50000条。
我把每条insert语句都保存在一个sqlstringlist之中,又 在网上找点资料,采用了事务处理方式,本来我的事务方式是所有sql语句放在一个事务里,但有热心朋友告知“每当执行1000条dbcommand就提交(commit)事务,然后再次开启事务,这样比较好。把过多的命令放在一个事务中,一旦超过物理内存分配限制,你的程序会变得很慢很慢。”
所以我后来修改了一下,每500条语句重启一次事务。c#代码如下:
1: public static void executesqltran(list sqlstringlist)
2: {
3: using (mysqlconnection conn = new mysqlconnection(mysqlhelper.connstr))
4: {
5: conn.open();
6: mysqlcommand cmd = new mysqlcommand();
7: cmd.connection = conn;
8: mysqltransaction tx = conn.begintransaction();
9: cmd.transaction = tx;
10: try
11: {
12: for (int n = 0; n 1)
16: {
17: cmd.commandtext = strsql;
18: cmd.executenonquery();
19: }
20: //后来加上的
21: if (n > 0 && (n % 500 == 0 || n == sqlstringlist.count - 1))
22: {
23: tx.commit();
24: tx = conn.begintransaction();
25: }
26: }
27: //tx.commit();//原来一次性提交
28: }
29: catch (system.data.sqlclient.sqlexception e)
30: {
31: tx.rollback();
32: throw new exception(e.message);
33: }
34: }
35: }
bitscn.com
其它类似信息

推荐信息