python - 如何使用 pymysql 运行批量插入查询？

Question

如何使用 pymysql 运行插入查询脚本文件？

我做了一个大数据的插入查询脚本文件。 (数据行数:50,000)

文件名为 bulkinsert.sql，其中包含如下查询。

INSERT INTO test( dt, user, usertype, ip) VALUES 
("2016-05-01", 3103945, , 1, "175.195.249.217"), 
("2016-05-01", 3103946, , 1, "175.195.249.218"), 
("2016-05-01", 3103947, , 1, "175.195.249.219"), 
................
................
................
("2016-05-01", 3104000, , 1, "175.195.249.500");

我用的是pymysql，但找不到直接插入或运行sql文件的方法。如下所示。

cursor.execute(bulkinsert.sql)

我看他们的指南的时候，我要看sql语句，然后执行。但是我的数据行数太多，无法阅读。他们有什么方法可以在 pymysql 中导入或运行 sql 脚本吗？

Answer 1

如果您不需要执行的输出，也许子流程是另一种方法。PS:将 Password 关键字替换为您自己的关键字。

from subprocess import Popen, PIPE
process = Popen(['mysql', db, '-u', user, '-pPassword'],
                stdout=PIPE, stdin=PIPE)
output = process.communicate('source ' + filename)[0]