iframe-proxy | Sunbelt Computer Software

History

72 lines (59 loc) · 2.28 KB

Raw

#------------------------------------------------------------------------------

# 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.

#------------------------------------------------------------------------------

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""")

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!")

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Sunbelt Computer Software

PL/B Language Development and Support

FilesExpand file tree

Threads.py

Latest commit

History

Threads.py

File metadata and controls