43 lines
1.6 KiB
Python
43 lines
1.6 KiB
Python
#------------------------------------------------------------------------------
|
|
# DatabaseChangeNotification.py
|
|
# This script demonstrates using database change notification in Python, a
|
|
# feature that is available in Oracle 10g Release 2. Once this script is
|
|
# running, use another session to insert, update or delete rows from the table
|
|
# cx_Oracle.TestExecuteMany and you will see the notification of that change.
|
|
#------------------------------------------------------------------------------
|
|
|
|
import cx_Oracle
|
|
import time
|
|
|
|
def callback(message):
|
|
print "Message type:", message.type
|
|
print "Message database name:", message.dbname
|
|
print "Message tables:"
|
|
for table in message.tables:
|
|
print "--> Table Name:", table.name
|
|
print "--> Table Operation:", table.operation
|
|
if table.rows is not None:
|
|
print "--> Table Rows:"
|
|
for row in table.rows:
|
|
print "--> --> Row RowId:", row.rowid
|
|
print "--> --> Row Operation:", row.operation
|
|
print "-" * 60
|
|
print "=" * 60
|
|
|
|
connection = cx_Oracle.Connection("cx_Oracle/password", events = True)
|
|
sub = connection.subscribe(callback = callback, timeout = 1800, rowids = True)
|
|
print "Subscription:", sub
|
|
print "--> Connection:", sub.connection
|
|
print "--> Callback:", sub.callback
|
|
print "--> Namespace:", sub.namespace
|
|
print "--> Protocol:", sub.protocol
|
|
print "--> Timeout:", sub.timeout
|
|
print "--> Operations:", sub.operations
|
|
print "--> Rowids?:", sub.rowids
|
|
sub.registerquery("select * from TestExecuteMany")
|
|
|
|
while True:
|
|
print "Waiting for notifications...."
|
|
time.sleep(5)
|
|
|