Chèn số lượng lớn pyodbc cơ bản

Question

Trong tập lệnh python, tôi cần chạy truy vấn trên một nguồn dữ liệu và chèn từng hàng từ truy vấn đó vào bảng trên nguồn dữ liệu khác. Tôi thường làm điều này với một tuyên bố chèn/chọn đơn với một máy chủ được liên kết với tsql nhưng tôi không có kết nối máy chủ được liên kết với nguồn dữ liệu cụ thể này.

Tôi đang gặp khó khăn khi tìm một ví dụ về pyodbc đơn giản về điều này. Đây là cách tôi sẽ làm điều đó nhưng tôi đoán thực hiện một tuyên bố chèn bên trong một vòng lặp là khá chậm.

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() 

Có cách nào tốt hơn để chèn bản ghi với pyodbc không? Hay đây là một cách tương đối hiệu quả để làm điều này. Tôi đang sử dụng SqlServer 2012, và các phiên bản pyodbc và python mới nhất.

Answer 1

Cách tốt nhất để xử lý việc này là sử dụng hàm pyodbc executemany.

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


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

Answer 2

Đây là chức năng có thể chèn số lượng lớn vào cơ sở dữ liệu 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() 

Điều này chắc chắn hoạt động. Do cập nhật, tốt hơn là sử dụng pypyodbc thay vì pyodbc.