952580a565
- administrative user is ADMIN on the Oracle Cloud databases and SYSTEM on local databases (SYSDBA is not available on the Oracle Cloud database) - use dbms_session.sleep() instead of dbms_lock.sleep() where possible - environment variables CX_ORACLE_SAMPLES_SYSDBA_USER and CX_ORACLE_SAMPLES_SYSDBA_PASSWORD are replaced with CX_ORACLE_SAMPLES_ADMIN_USER and CX_ORACLE_SAMPLES_ADMIN_PASSWORD - new environment variable CX_ORACLE_SAMPLES_DRCP_CONNECT_STRING used for specifying the connect string to use for DRCP usage
75 lines
2.3 KiB
Python
75 lines
2.3 KiB
Python
#------------------------------------------------------------------------------
|
|
# Copyright (c) 2017, 2019, Oracle and/or its affiliates. All rights reserved.
|
|
#------------------------------------------------------------------------------
|
|
|
|
#------------------------------------------------------------------------------
|
|
# Threads.py
|
|
# This script demonstrates the use of threads with cx_Oracle. A session pool
|
|
# is used so that multiple connections are available to perform work on the
|
|
# database. Only one operation (such as an execute or fetch) can take place at
|
|
# a time on a connection. In the below example, one of the threads performs
|
|
# dbms_lock.sleep while the other performs a query.
|
|
#
|
|
# This script requires cx_Oracle 2.5 and higher.
|
|
#------------------------------------------------------------------------------
|
|
|
|
from __future__ import print_function
|
|
|
|
import cx_Oracle
|
|
import SampleEnv
|
|
import threading
|
|
|
|
pool = cx_Oracle.SessionPool(SampleEnv.GetMainUser(),
|
|
SampleEnv.GetMainPassword(), SampleEnv.GetConnectString(), min=2,
|
|
max=5, increment=1, threaded=True)
|
|
|
|
# dbms_session.sleep() replaces dbms_lock.sleep() from Oracle Database 18c
|
|
conn = pool.acquire()
|
|
sleepProcName = "dbms_session.sleep" \
|
|
if int(conn.version.split(".")[0]) >= 18 \
|
|
else "dbms_lock.sleep"
|
|
conn.close()
|
|
|
|
def TheLongQuery():
|
|
conn = pool.acquire()
|
|
cursor = conn.cursor()
|
|
cursor.arraysize = 25000
|
|
print("TheLongQuery(): beginning execute...")
|
|
cursor.execute("""
|
|
select *
|
|
from
|
|
TestNumbers
|
|
cross join TestNumbers
|
|
cross join TestNumbers
|
|
cross join TestNumbers
|
|
cross join TestNumbers
|
|
cross join TestNumbers""")
|
|
print("TheLongQuery(): done execute...")
|
|
while True:
|
|
rows = cursor.fetchmany()
|
|
if not rows:
|
|
break
|
|
print("TheLongQuery(): fetched", len(rows), "rows...")
|
|
print("TheLongQuery(): all done!")
|
|
|
|
|
|
def DoALock():
|
|
conn = pool.acquire()
|
|
cursor = conn.cursor()
|
|
print("DoALock(): beginning execute...")
|
|
cursor.callproc(sleepProcName, (5,))
|
|
print("DoALock(): done execute...")
|
|
|
|
|
|
thread1 = threading.Thread(None, TheLongQuery)
|
|
thread1.start()
|
|
|
|
thread2 = threading.Thread(None, DoALock)
|
|
thread2.start()
|
|
|
|
thread1.join()
|
|
thread2.join()
|
|
|
|
print("All done!")
|
|
|