在使用Python cx_Oracle解析与PL / SQL和DML / DDL SQL文件(Par

2019-09-16 12:11发布

我有我想分析和使用的是Oracle执行SQL文件cx_Oracle Python库。 该SQL文件包含经典的DML / DDL和PL / SQL,例如。 它可以是这样的:

create.sql

-- This is some ; malicious comment
CREATE TABLE FOO(id numeric);

BEGIN
  INSERT INTO FOO VALUES(1);
  INSERT INTO FOO VALUES(2);
  INSERT INTO FOO VALUES(3);
END;
/
CREATE TABLE BAR(id numeric);

如果我使用的SQLDeveloper或SQL * Plus这个文件,它会被分成3个查询和执行。

然而,cx_Oracle.connect(...)。光标()。执行(...)可以在同一时间只有一个查询,而不是整个文件。 我不能简单地拆分使用字符串string.split(';')这里建议从cx_oracle执行SQL脚本文件? ),因为两者的评论将被分割(否则会导致错误)和PL / SQL块将不被作为单个命令执行,因而引起误差。

在Oracle论坛( https://forums.oracle.com/forums/thread.jspa?threadID=841025 )我发现,cx_Oracle本身不支持这样的东西作为解析整个文件。 我的问题是 - 有没有为我做到这一点的工具吗? 例如。 一个Python库我可以打电话给我的文件分割成疑问?

编辑:最好的解决方案似乎是使用SQL * Plus直接。 我用这个代码:

# open the file
f = open(file_path, 'r')
data = f.read()
f.close()

# add EXIT at the end so that SQL*Plus ends (there is no --no-interactive :(
data = "%s\n\nEXIT" % data

# write result to a temp file (required, SQL*Plus takes a file name argument)
f = open('tmp.file', 'w')
f.write(data)
f.close()

# execute SQL*Plus
output = subprocess.check_output(['sqlplus', '%s/%s@%s' % (db_user, db_password, db_address), '@', 'tmp.file'])

# if an error was found in the result, raise an Exception
if output.find('ERROR at line') != -1:
    raise Exception('%s\n\nStack:%s' % ('ERROR found in SQLPlus result', output))

Answer 1:

这有可能在同一时间执行多个语句,但它是半哈克。 你需要用你的陈述,并执行它们一次一个。

>>> import cx_Oracle
>>>
>>> a = cx_Oracle.connect('schema/pw@db')
>>> curs = a.cursor()
>>> SQL = (("""create table tmp_test ( a date )"""),
... ("""insert into tmp_test values ( sysdate )""")
... )
>>> for i in SQL:
...     print i
...
create table tmp_test ( a date )
insert into tmp_test values ( sysdate )
>>> for i in SQL:
...     curs.execute(i)
...
>>> a.commit()
>>>

如您所知,这并不解决分号问题,其中有没有简单的答案。 当我看到它,你有3种选择:

  1. 写一个过于复杂的解析器,我不认为这是一个不错的选择的。

  2. 不要在Python执行SQL脚本; 有两种不同的SQL脚本代码,以便解析容易,在一个单独的Python文件,嵌入在Python代码,在一个过程中的数据库...等等。这可能是我的首选方案。

  3. 使用subprocess和调用脚本的方式。 这是最简单,最快速的选项,但不使用cx_Oracle的。

     >>> import subprocess >>> cmdline = ['sqlplus','schema/pw@db','@','tmp_test.sql'] >>> subprocess.call(cmdline) SQL*Plus: Release 9.2.0.1.0 - Production on Fri Apr 13 09:40:41 2012 Copyright (c) 1982, 2002, Oracle Corporation. All rights reserved. Connected to: Oracle Database 11g Release 11.2.0.1.0 - 64bit Production SQL> SQL> CREATE TABLE FOO(id number); Table created. SQL> SQL> BEGIN 2 INSERT INTO FOO VALUES(1); 3 INSERT INTO FOO VALUES(2); 4 INSERT INTO FOO VALUES(3); 5 END; 6 / PL/SQL procedure successfully completed. SQL> CREATE TABLE BAR(id number); Table created. SQL> SQL> quit Disconnected from Oracle Database 11g Release 11.2.0.1.0 - 64bit Production 0 >>> 


文章来源: Parse SQL file with PL/SQL and DML/DDL using cx_Oracle in python