HackBase/python-cx_Oracle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Adjust samples to handle the deregistration event without an exception.

Browse Source
This commit is contained in:
Anthony Tuininga 2017-08-30 11:56:55 -06:00
parent ec2f82ca95
commit 481371fb50
2 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
samples/DatabaseChangeNotification.py
View File

@ -24,8 +24,15 @@ import SampleEnv
import threading
import time
registered = True
def callback(message):
global registered
print("Message type:", message.type)
if message.type == cx_Oracle.EVENT_DEREG:
print("Deregistration has taken place...")
registered = False
return
print("Message database name:", message.dbname)
print("Message tables:")
for table in message.tables:
@ -52,7 +59,7 @@ print("--> Operations:", sub.operations)
print("--> Rowids?:", bool(sub.qos & cx_Oracle.SUBSCR_QOS_ROWIDS))
sub.registerquery("select * from TestTempTable")
while True:
while registered:
print("Waiting for notifications....")
time.sleep(5)

9
samples/QueryChangeNotification.py
View File

@ -24,8 +24,15 @@ import SampleEnv
import threading
import time
registered = True
def callback(message):
global registered
print("Message type:", message.type)
if message.type == cx_Oracle.EVENT_DEREG:
print("Deregistration has taken place...")
registered = False
return
print("Message database name:", message.dbname)
print("Message queries:")
for query in message.queries:
@ -56,7 +63,7 @@ print("--> Rowids?:", bool(sub.qos & cx_Oracle.SUBSCR_QOS_ROWIDS))
queryId = sub.registerquery("select * from TestTempTable")
print("Registered query:", queryId)
while True:
while registered:
print("Waiting for notifications....")
time.sleep(5)