有没有办法在 python 中使用 cx_oracle 执行 sql 脚本文件。
我需要在 sql 文件中执行我的创建表脚本。
另一种选择是使用 SQL*Plus(Oracle 的命令行工具)来运行脚本。您可以使用该subprocess
模块从 Python 调用它 - 这里有一个很好的演练:http: //moizmuhammad.wordpress.com/2012/01/31/run-oracle-commands-from-python-via-sql-plus/。
对于像这样的脚本tables.sql
(注意故意的错误):
CREATE TABLE foo ( x INT );
CREATE TABLER bar ( y INT );
您可以使用如下函数:
from subprocess import Popen, PIPE
def run_sql_script(connstr, filename):
sqlplus = Popen(['sqlplus','-S', connstr], stdin=PIPE, stdout=PIPE, stderr=PIPE)
sqlplus.stdin.write('@'+filename)
return sqlplus.communicate()
connstr
是用于 的相同连接字符串cx_Oracle
。filename
是脚本的完整路径(例如'C:\temp\tables.sql'
)。该函数打开一个 SQL Plus 会话(使用 '-S' 使其欢迎消息静音),然后将“@filename”排队发送给它 - 这将告诉 SQL Plus 运行脚本。
sqlplus.communicate
将命令发送到标准输入,等待 SQL*Plus 会话终止,然后作为元组返回 (stdout, stderr)。使用上述调用此函数tables.sql
将给出以下输出:
>>> output, error = run_sql_script(connstr, r'C:\temp\tables.sql')
>>> print output
Table created.
CREATE TABLER bar (
*
ERROR at line 1:
ORA-00901: invalid CREATE command
>>> print error
这将需要一些解析,具体取决于您想要返回程序的其余部分 - 如果它是交互式的,您可以向用户显示整个输出,或者如果您只想检查它是否扫描单词“ERROR”跑好了。
cx_oracle 试图遵守的PEP-249并没有这样的方法。
但是,该过程应该非常简单。将文件内容拉成字符串,在“;”上分割 字符,然后在结果数组的每个成员上调用 .execute。我假设“;” 字符仅用于分隔文件中的 oracle SQL 语句。
f = open('tabledefinition.sql')
full_sql = f.read()
sql_commands = full_sql.split(';')
for sql_command in sql_commands:
curs.execute(sql_command)