sql >> Base de Datos >  >> RDS >> Mysql

¿Cómo puedo insertar una lista devuelta de la consulta pyodbc mssql en mysql a través del procedimiento almacenado usando pymysql?

No puede hacer eso con su procedimiento almacenado tal como está escrito. Solo insertará una fila a la vez, por lo que para insertar n filas tendrías que llamarlo n veces.

Además, que yo sepa, no puede modificar el procedimiento almacenado para insertar n filas sin usar una tabla temporal o alguna otra solución porque MySQL no admite parámetros con valores de tabla para procedimientos almacenados.

Sin embargo, puede insertar varias filas a la vez si usa una declaración INSERT regular y .executemany . pymysql agrupará las inserciones en una o más inserciones de varias filas

mssql_crsr = mssql_cnxn.cursor()
mssql_stmt = """\
SELECT 1 AS id, N'Alfa' AS txt
UNION ALL
SELECT 2 AS id, N'Bravo' AS txt
UNION ALL
SELECT 3 AS id, N'Charlie' AS txt
"""
mssql_crsr.execute(mssql_stmt)
mssql_rows = []
while True:
    row = mssql_crsr.fetchone()
    if row:
        mssql_rows.append(tuple(row))
    else:
        break

mysql_cnxn = pymysql.connect(host='localhost', port=3307,
                             user='root', password='_whatever_',
                             db='mydb', autocommit=True)
mysql_crsr = mysql_cnxn.cursor()
mysql_stmt = "INSERT INTO stuff (id, txt) VALUES (%s, %s)"
mysql_crsr.executemany(mysql_stmt, mssql_rows)

El código anterior produce lo siguiente en MySQL general_log

190430 10:00:53     4 Connect   [email protected] on mydb
            4 Query INSERT INTO stuff (id, txt) VALUES (1, 'Alfa'),(2, 'Bravo'),(3, 'Charlie')
            4 Quit  

Tenga en cuenta que pymysql no puede agrupar llamadas a un procedimiento almacenado de la misma manera, por lo que si usara

mysql_stmt = "CALL stuff_one(%s, %s)"

en lugar de un INSERT regular, general_log contendría

190430  9:47:10     3 Connect   [email protected] on mydb
            3 Query CALL stuff_one(1, 'Alfa')
            3 Query CALL stuff_one(2, 'Bravo')
            3 Query CALL stuff_one(3, 'Charlie')
            3 Quit