pyodbcを使ってdfをSQLデータベースにコミットする方法は？

Question

データベースに接続しています（pyodbcを使用しています）、新しいテーブルにdfをコミットする必要があります。私はこれをSQLでやったことがありますが、dfでそれをやる方法はわかりません。どのようにDFのために働くように、以下のコードを変更する上で任意のアイデア？ SQLのための

コード：

import pyodbc 
import pandas as pd  

conn= pyodbc.connect(r'DRIVER={Teradata};DBCNAME=foo; UID=name; PWD=password;QUIETMODE=YES;Trusted_Connection=yes') 

cursor = conn.cursor() 
cursor.execute(
""" 
CREATE TABLE SCHEMA.NEW_TABLE AS 
(
SELECT ... FROM .... 
) 
""" 
) 
conn.commit() 

私は、エラーをこのコードを試したが、データベース内に作成していない：

import pyodbc 
import pandas as pd  

conn= pyodbc.connect(r'DRIVER={Teradata};DBCNAME=foo; UID=name; PWD=password;QUIETMODE=YES;Trusted_Connection=yes') 

sheet1.to_sql(con=conn, name='new_table', schema='Schema', if_exists='replace', index=False) 

Answer 1

to_sql()のマニュアルに明記：

con：SQLAlchemyエンジンまたはDBAPI2接続（レガシーモード）

SQLAlchemyを使用すると、その ライブラリでサポートされているすべてのDBを使用できます。 DBAPI2オブジェクトの場合は、sqlite3のみがサポートされます。

したがって、to_sql()関数にSQLAlchemyエンジンを渡して、PandasからTeradataデータベースに直接書き込む必要があります。

別の方法として、データを別のデータ構造（たとえばto_dict()）にダンプし、pyODBCを使用してデータベースでDML文を実行することができます。