sql >> データベース >  >> RDS >> Sqlserver

基本的なpyodbcバルクインサート

    これは、SQLServerデータベースへの一括挿入を実行できる関数です。

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

    これは間違いなく機能します。

    更新:コメントと定期的なコーディングで、pyodbcはpypyodbcよりもサポートされていることに気づきました。

    新しい更新:withステートメントが自動的に処理するため、conn.close()を削除します。



    1. ロックの総数がロックテーブルのサイズを超えています

    2. SQLServerの「時間」ストレージサイズを理解する

    3. SQLでは、OR付きの括弧の使用はどういう意味ですか?

    4. MariaDBで大文字に変換する方法