在PYPYODBC中使用executemany()

Question

我的项目目前正在使用pypyodbc Python库连接到DB2数据库，我的源是MS，我需要从中读取数据并将数据加载到DB2表中。数据量为百万行，我试图使用executemany()方法在一次执行中加载50条记录，但我始终得到错误：

数据必须在列表、元组或行中。

我确实使用了list函数来键入游标结果，但它仍然不起作用。结果集中的数据采用[(record1),(record2)]格式。代码片段如下所示：

也尝试过键入sql结果集元组。

# use pypyodbc to establish a connection - db2_conn. 
cur = db2_conn.cursor()
cur.execute('...a query with 10 columns...')
result = cur.fetchmany(50)

insert_query = 'insert into db2_table (col1,col2,col3,...) values (?,?,?,..)'
cur.executemany(insert_query, list(result))
cur.commit()

Answer 1

代码看起来没问题我以Db2作为源和目标测试了以下内容：

1. 创建的源表和目标表

db2 "create table odbc_test(c1 int, c2 varchar(10))"
db2 "create table odbc_test_sorurce(c1 int, c2 varchar(10))"

1. 用数据填充

db2 "insert into odbc_test_sorurce 
    with
       cte(c1)
    as
       (select
            1
        from
           sysibm.sysdummy1
        union all
        select
           c1 + 1
        from
           cte
        where c1 < 1000) select  c1, 'row' || c1 from cte"

1. 连接到数据库并获取行。

import pyodbc
cnx = pyodbc.connect("DRIVER={DB2};HOSTNAME=localhost;DATABASE=sample;UID=xxxx;PWD=xxxxx;PROTOCOL=TCPIP;PORT=60115")
cnx.autocommit = False
cur = cnx.cursor()
cur.execute('select c1, c2 from odbc_test_sorurce')
result = cur.fetchmany(50)

1. 这给了我一个结果清单：

In [16]: result
Out[16]: 
[(1, 'row1'),
 (2, 'row2'),
 (3, 'row3'),
 (4, 'row4'),
 (5, 'row5'),
 (6, 'row6'),
 (7, 'row7'),
...


In [17]: type(result)
Out[17]: list

1. 插入的效果很好：

cur.executemany("insert into odbc_test(c1, c2) values (?,?)", result)
cnx.commit()