【发布时间】:2017-08-22 18:05:42
【问题描述】:
我一直在编写 Python 脚本。这个脚本应该填充一个从 select 语句中获取值的 MySQL 表。
问题是当我从 select 语句中获取值时,insert into 语句无法正常工作并且没有插入所有记录。我在 MySQL WorkBench 中检查了相同的 select 语句,并返回了我想放入目标表中的正确记录数。 select语句是这样的,预期的行数超过100.000(是一个大数据库):
SELECT MAX(c1),MAX(c2),MAX(c3),MAX(c4),c5,c6,MAX(c7)
FROM Table1 as t1
INNER JOIN Table2 as t2 ON t1.Id = t2.Id
INNER JOIN Table3 as t3 ON t1.Id = t3.Id
WHERE c4 NOT LIKE '%A%'
GROUP BY t1.c1;
此选择语句应返回不包含“A”字符的记录。
这是我的 Python 代码:
import MySQLdb
db = MySQLdb.connect(host,user,pass,dbName)
cursor = db.cursor()
cursor.execute("SELECT MAX(c1),MAX(c2),MAX(c3),MAX(c4),c5,c6,MAX(c7)
FROM Table1 as t1
INNER JOIN Table2 as t2 ON t1.Id = t2.Id
INNER JOIN Table3 as t3 ON t1.Id = t3.Id
WHERE c4 NOT LIKE '%A%'
GROUP BY t1.c1")
results = cursor.fetchall()
for row in results:
cursor.execute("INSERT INTO DestinationTable(col1,col2,col3,col4,col5,col6)VALUES('%s','%s','%s','%s','%s','%s')"
%(str(row[1]),str(row[2]),str(row[3]),str(row[4]),str(row[5]),str(row[6]))
db.commit()
我认为问题出在 Insert into 语句中,但我不确定。
【问题讨论】:
-
您是否有理由不使用
INSERT INTO ... SELECT ...all in one execute call? -
我认为你的提议是一个缓慢的陈述,我不知道它是否是最佳的......也许我错了对不起
-
避免循环,所有进程都在 MySQL 引擎中处理。
-
谢谢芭菲,我去试试