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

forループには余分なコンマが必要です。以下のコードを参照してください。xinforループの後に余分なコンマを指定しました。

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 に答える
0

少し異なる状況で同じ問題が発生しました。+27000行のテーブルをクエリする必要がありましたが、しばらくするとcx_OracleがDBへの接続を切断することがわかりました。

dbへの接続が開いているときに、cx_Oracle.Lobオブジェクトのread（）メソッドを使用して、dbを文字列に変換できます。ただし、クエリが大きすぎるテーブルをもたらす場合、接続はある時点で停止し、クエリの結果を読み取りたいときに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()

+27000行のテーブルを表示するのに長い時間（約4〜5分）かかりましたが、他のすべてが機能しなかった場合は機能しました。

誰かがもっと良い方法を知っているなら、それは私にも役立つでしょう。

于 2021-01-20T18:34:24.230 に答える