Cx_Oracle获取崩溃

Question

所以我使用cursor.execute（）从oracle数据库查询数据。一个相对简单的选择查询。有用。

但是当我尝试从中获取数据时，python崩溃了。

fetchall（），fetchmany（）和fetchone（）也是如此。

当查询首次在fetchmany（）中出现时，我决定循环通过fetchone（），它在前两行中工作，然后在第三行中断。

我猜这是因为第三排数据太多了。

那么，有没有办法绕过这个问题并提取数据？

（请忽略错误的缩进无法在我的手机中正确复制）

编辑：我删除了四个类型为“ROWID”的列。之后没有问题。我很容易一次获取100行。

因此，为了证实我的怀疑，我继续创建了另一个只有那些划线列的副本，它按预期崩溃了。

所以ROWID类型有什么问题吗？

测试表也一样。

插入TEST_FOR_CX_ORACLE（Z $ OEX0_LINES，Z $ OEX0_ORDER_INVOICES，Z $ OEX0_ORDERS，Z $ ITEM_ROWID）值（'ABoeqvAEyAAB0HOAAM'，'AAAL0DAEzAAClz7AAN'，'AAAVeuABHAAA4vdAAH'，'ABoeo + AIVAAE6dKAAQ'）;插入TEST_FOR_CX_ORACLE（Z $ OEX0_LINES，Z $ OEX0_ORDER_INVOICES，Z $ OEX0_ORDERS，Z $ ITEM_ROWID）值（'ABoeqvABQAABKo6AAI'，'AAAL0DAEzAAClz7AAO'，'AAAVeuABHAAA4vdAAH'，'ABoeo + AIVAAE6dKAAQ'）;插入TEST_FOR_CX_ORACLE（Z $ OEX0_LINES，Z $ OEX0_ORDER_INVOICES，Z $ OEX0_ORDERS，Z $ ITEM_ROWID）值（'ABoeqvABQAABKo6AAG'，'AAAL0DAEzAAClz7AAP'，'AAAVeuABHAAA4vdAAH'，'ABoeo + AHIAAN + OIAAM'）;插入TEST_FOR_CX_ORACLE（Z $ OEX0_LINES，Z $ OEX0_ORDER_INVOICES，Z $ OEX0_ORDERS，Z $ ITEM_ROWID）值（'ABoeqvAEyAAB0HOAAK'，'AAAL0DAEzAACl0EAAC'，'AAAVeuABHAAA4vdAAH'，'ABoeo + AHIAAN + OIAAM'）;

脚本：

from cx_Oracle import makedsn,connect,Cursor
from pandas import read_sql_table, DataFrame, Series

from time import time

def create_conn( host_link , port , service_name , user_name , password ):
    dsn=makedsn(host_link,port,service_name=service_name)
    return connect(user=user_name, password=password, dsn=dsn)

def initiate_connection(conn):
    try:
        dbconnection = create_conn(*conn)
        print('Connected to '+conn[2]+' !')
    except Exception as e:
        print(e)
        dbconnection = None
    return dbconnection        

def execute_query(query,conn):
    dbconnection=initiate_connection(conn)
    try:
        cursor = dbconnection.cursor()
        print ('Cursor Created!')
        return cursor.execute(query)
    except Exception as e:
        print(e)
        return None

start_time = time()

query='''SELECT * FROM test_for_cx_oracle'''

try:
    cx_read_query = execute_query(query,ecspat_c)
    time_after_execute_query = time()
    print('Query Executed')
    columns = [i[0] for i in cx_read_query.description]
    time_after_getting_columns = time()
except Exception as e:
    print(e)


print(time_after_execute_query-start_time,time_after_getting_columns-time_after_execute_query)

Answer 1

不幸的是，这是Oracle客户端库中的一个错误。如果您尝试在连续的行中多次获取相同的rowid值，您将看到它。如果你避免这种情况一切都很好。您还可以在运行查询之前将环境变量ORA_OCI_NO_OPTIMIZED_FETCH设置为值1以避免此问题。

这已在此前报道过：https://github.com/oracle/python-cx_Oracle/issues/120