使用 python 读取 oracle sql 文件并将结果提取到 CSV 文件中

Question

我是 python 的初学者，想从 python 读取一个 sql 文件并将这些结果提取到 CSV 文件中。我尝试使用 CX_oracle 连接到 oracle 数据库。当我直接在代码中给出 sql 查询时，它可以工作。但是，我不确定如何从 python 读取 sql 文件。

这是我直接在代码中进行 sql 查询时起作用的代码：

import csv 
import cx_Oracle
con = cx_Oracle.connect('XCM/XCM@home.com:1500/HOME')
cursor = con.cursor()
csv_file = open("exp.csv", "w")
writer = csv.writer(csv_file, delimiter='|', lineterminator="\n", quoting=csv.QUOTE_NONE)
r = cursor.execute("select * from home_parties where CREATION_DATE >= trunc(sysdate)")
for row in cursor:
    writer.writerow(row)
cursor.close()
con.close()
csv_file.close()

我尝试使用下面的代码从 sql 文件中获取，该文件具有与上面代码中提到的相同的 sql 查询 - sample.sql 但它不起作用

import csv
import cx_Oracle
con = cx_Oracle.connect('XCM/XCM@home.com:1500/HOME')
cursor = con.cursor()
csv_file = open("exp.csv", "w")
writer = csv.writer(csv_file, delimiter='|', lineterminator="\n", quoting=csv.QUOTE_NONE)
f = open('C:/Users/home1/sample.sql')
full_sql = f.read()
r = cursor.execute(full_sql)
for row in cursor:
    writer.writerow(row)
cursor.close()
con.close()
csv_file.close()

请帮帮我！！

Answer 1

sql文件的内容可能会在for循环line中被line读取，例如

import csv 
import cx_Oracle
con = cx_Oracle.connect('XCM/XCM@home.com:1500/HOME')
cursor = con.cursor()

sql=""
with open("C:/Users/home1/sample.sql") as f_in:
    for line in f_in:
        sql += line

f_out = open("exp.csv", "w")
writer = csv.writer(f_out, delimiter='|', lineterminator="\n", quoting=csv.QUOTE_NONE)
cursor.execute(sql)
for row in cursor:
    writer.writerow(row)
cursor.close()
con.close()
f_out.close()
f_in.close()

考虑将 SQL 语句分散到多行

Answer 2

假设您在同一目录中有一个 sample.sql 文件，其中第一行是查询。这将从该文件中读取 SQL 查询，然后执行查询并将结果保存到名为“exp.csv”的 CSV 文件中。

import cx_Oracle
con = cx_Oracle.connect('XCM/XCM@home.com:1500/HOME')
cursor = con.cursor()

import pandas as pd
with open('sample.sql') as f:
    sql_query_string = f.readline();
sql_query = pd.read_sql_query(sql_query_string, con)

sql_query.to_csv("exp.csv", sep='|')