3

我有这个将 CSV 发送到 Oracle 的代码,但它比 1 月份的糖蜜慢。我想使用 odo 但对于这种确切类型的情况(从 CSV 到 Oracle 的数据),文档很少。我没有和 Pandas 结婚,所以最好不要使用它,这对我来说很好。

import pandas as pd
import pandas.io.sql as psql
from sqlalchemy import create_engine
import cx_Oracle as cx

engine = create_engine('oracle+cx_oracle://schema:'+pwd+'@server:port/service_name'
,encoding='latin1')

name='table'
path=r'path_to_folder'
filelist = os.listdir(path) 

for file in filelist:
    df = pd.read_csv(pathc+'\\'+file,encoding='latin1',index_col=0)
    df=df.astype('unicode')
    df['date'] = pd.to_datetime(df['date'])
    df['date'] = pd.to_datetime(df['Contract_EffDt'],format='%YYYY-%mm-%dd')
    df.to_sql(name, engine, if_exists = 'append')

提前致谢!

4

0 回答 0