20

我有这个代码：

    dsn = cx_Oracle.makedsn(hostname, port, sid)
    orcl = cx_Oracle.connect(username + '/' + password + '@' + dsn)
    curs = orcl.cursor()
    sql = "select TEMPLATE from my_table where id ='6'"
    curs.execute(sql)
    rows = curs.fetchall()
    print rows
    template = rows[0][0]
    orcl.close()
    print template.read()

当我这样做时print rows，我得到了这个：

[(<cx_Oracle.LOB object at 0x0000000001D49990>,)]

但是，当我这样做时print template.read()，我收到此错误：

cx_Oracle.DatabaseError：句柄无效！

我如何获取和读取这些数据？谢谢。

4

5 回答 5

24

我发现如果在使用 cx_Oracle.LOB.read() 方法之前关闭与 Oracle 的连接，就会发生这种情况。

orcl = cx_Oracle.connect(usrpass+'@'+dbase)
c = orcl.cursor()
c.execute(sq)
dane =  c.fetchall()

orcl.close() # before reading LOB to str

wkt = dane[0][0].read()

我得到：DatabaseError：无效的句柄！
但以下代码有效：

orcl = cx_Oracle.connect(usrpass+'@'+dbase)
c = orcl.cursor()
c.execute(sq)
dane =  c.fetchall()

wkt = dane[0][0].read()

orcl.close() # after reading LOB to str
于 2012-09-25T21:00:16.753 回答
10

弄清楚了。我必须做这样的事情：

curs.execute(sql)        
for row in curs:
    print row[0].read()
于 2011-12-27T16:45:19.523 回答
1

您基本上必须遍历 fetchall 对象

dsn = cx_Oracle.makedsn(hostname, port, sid)
orcl = cx_Oracle.connect(username + '/' + password + '@' + dsn)
curs = orcl.cursor()
sql = "select TEMPLATE from my_table where id ='6'"
curs.execute(sql)
rows = curs.fetchall()
for x in rows:
   list_ = list(x)
   print(list_)
于 2019-03-18T12:42:53.643 回答
0

在略有不同的情况下，我遇到了同样的问题。我需要查询一个 +27000 行的表，结果发现 cx_Oracle 会在一段时间后切断与数据库的连接。

当与 db 的连接打开时，您可以使用 cx_Oracle.Lob 对象的 read() 方法将其转换为字符串。但是，如果查询带来的表太大，它将无法工作，因为连接将在某个时候停止，并且当您想从查询中读取结果时，您将在 cx_Oracle 对象上出现错误。

我尝试了很多事情，比如设置 connection.callTimeout = 0 （根据文档，这意味着它会无限期地等待），使用 fetchall() 然后将结果放在数据帧或 numpy 数组中，但我永远无法读取 cx_Oracle.Lob 对象.

如果我尝试使用 pandas.DataFrame.read_sql(query, connection) 运行查询，数据框将包含 cx_Oracle.Lob 对象，连接关闭，使它们无用。（同样，这只发生在桌子很大的情况下）

最后，我找到了一种通过查询并立即创建 csv 文件来解决此问题的方法，即使我知道这并不理想。

def csv_from_sql(sql: str, path: str="dataframe.csv") -> bool:
try: 
    with cx_Oracle.connect(config.username, config.password, config.database, encoding=config.encoding) as connection:
        connection.callTimeout = 0
        data = pd.read_sql(sql, con=connection)
        data.to_csv(path)
        print("FILE CREATED")
except cx_Oracle.Error as error: 
    print(error)
    return False
finally: 
    print("PROCESS ENDED\n")
    return True

def make_query(sql: str, path: str="dataframe.csv") -> pd.DataFrame:
if csv_from_sql(sql, path):
    dataframe = pd.read_csv("dataframe.csv")
    return dataframe
return pd.DataFrame()

这需要很长时间（大约 4 到 5 分钟）才能带来我的 +27000 行表，但是当其他一切都没有时，它就起作用了。

如果有人知道更好的方法，那对我也有帮助。

于 2021-01-20T18:34:24.230 回答
0

for 循环中应该有一个额外的逗号，请参见下面的代码，我在 for 循环中的 x 之后提供了一个额外的逗号。

dsn = cx_Oracle.makedsn(hostname, port, sid)
orcl = cx_Oracle.connect(username + '/' + password + '@' + dsn)
curs = orcl.cursor()
sql = "select TEMPLATE from my_table where id ='6'"
curs.execute(sql)
rows = curs.fetchall()
for x, in rows:
    print(x)
于 2019-10-10T14:09:25.867 回答