分析查询结果以将其插入另一个数据库

使用 executemany() 以及参数化查询。假设上一个查询的结果存储为名为 results :

query = """INSERT INTO  auth_user.auth_user
           (last_login, is_superuser, data_joined, is_active)
           VALUES (%s, %s, %s, %s)"""

# If your driver's cursors don't work as context managers, wrap with
# contextlib.closing
with conn.cursor() as cursor:
    cursor.executemany(query, results)

conn.commit()

您的驱动程序知道如何传递常用的python对象,例如 date , datetime ,字符串和数字(当使用参数化查询时)。

取决于使用中的驾驶员 执行管理() 可以优化传递多个值元组,也可以不优化传递多个值元组。例如 MySQL Connector 和 PyMySQL 优化插入语句。

你的结果是元组…只需生成一个合适的sql查询,然后 execute() 它:

query = 'INSERT INTO auth_user.auth_user'                       \
          ' (last_login, is_superuser, data_joined, is_active)' \
          ' VALUES (%s, %s, %s, %s);'

for result in results:
    cursor.execute(query, result)