基本pyodbc一括挿入

Question

pythonスクリプトでは、あるデータソースに対してクエリを実行し、そのクエリの各行を別のデータソースのテーブルに挿入する必要があります。私は通常、単一の挿入/選択ステートメントをtsqlリンクサーバーの結合でこれを行うだろうが、私はこの特定のデータソースへのリンクサーバー接続がありません。

これの簡単なpyodbcの例を見つけるのに問題があります。ここで私はそれを行う方法ですが、ループ内でのinsert文の実行はかなり遅いと推測しています。

result = ds1Cursor.execute(selectSql) 

for row in result: 
    insertSql = "insert into TableName (Col1, Col2, Col3) values (?, ?, ?)" 
    ds2Cursor.execute(insertSql, row[0], row[1], row[2]) 
    ds2Cursor.commit() 

pyodbcでレコードを挿入する方法はありますか？とにかくこれを行うには、これは比較的効率的な方法です。私はSqlServer 2012と最新のpyodbcとpythonのバージョンを使用しています。

Answer 1

これを処理する最善の方法は、pyodbc関数executemanyを使用することです。

ds1Cursor.execute(selectSql) 
result = ds1Cursor.fetchall() 


ds2Cursor.executemany('INSERT INTO [TableName] (Col1, Col2, Col3) VALUES (?, ?, ?)', result) 
ds2Cursor.commit() 

Answer 2

SQL Serverデータベースに一括挿入できる機能は次のとおりです。

import pypyodbc 
import contextlib 

def bulk_insert(table_name, file_path): 
    string = "BULK INSERT {} FROM '{}' (WITH FORMAT = 'CSV');" 
    with contextlib.closing(pypyodbc.connect("MYCONN")) as conn: 
     with contextlib.closing(conn.cursor()) as cursor: 
      cursor.execute(string.format(table_name, file_path)) 
     conn.commit() 
     conn.close() 

これは間違いなく機能します。更新のために、pyodbcの代わりにpypyodbcを使用する方が良いです。