#python操作Oracle依赖cx_Oracle
#pip install cx_Oracle
#pip install pandas
import os
from pandas.core.frame import DataFrame
import cx_Oracle
import pandas as pd
def query(ip,port,sid,username,password,sql):
dsn = cx_Oracle.makedsn(ip, port, sid)
conn = cx_Oracle.connect(username, password, dsn)
results = pd.read_sql(sql,conn)
conn.close
return results
def writeQueryToTxt(results:DataFrame,filedir):
results.to_csv(filedir,sep=‘\001‘,index=False,header=False)
if __name__ == "__main__":
sql = "select * from test"
df = query("127.0.0.1","1521","xe","ods","ods",sql)
df[‘BIRTH‘] = df[‘BIRTH‘].apply(lambda x:x.strftime(‘%Y-%m-%d‘))
writeQueryToTxt(df,"./test.txt")
