iframe-proxy | Sunbelt Computer Software

History

65 lines (58 loc) · 2.45 KB

Raw

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

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

# TestTempTable and you will see the notification of that change.

# This script requires cx_Oracle 5.3 and higher.

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

import time

import cx_Oracle as oracledb

import sample_env

registered = True

def callback(message):

global registered

print("Message type:", message.type)

if not message.registered:

print("Deregistration has taken place...")

registered = False

return

print("Message database name:", message.dbname)

print("Message tranasction id:", message.txid)

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 = oracledb.connect(sample_env.get_main_connect_string(),

events=True)

sub = connection.subscribe(callback=callback, timeout=1800,

qos=oracledb.SUBSCR_QOS_ROWIDS)

print("Subscription:", sub)

print("--> Connection:", sub.connection)

print("--> ID:", sub.id)

print("--> Callback:", sub.callback)

print("--> Namespace:", sub.namespace)

print("--> Protocol:", sub.protocol)

print("--> Timeout:", sub.timeout)

print("--> Operations:", sub.operations)

print("--> Rowids?:", bool(sub.qos & oracledb.SUBSCR_QOS_ROWIDS))

sub.registerquery("select * from TestTempTable")

while registered:

print("Waiting for notifications....")

time.sleep(5)

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Sunbelt Computer Software

PL/B Language Development and Support

FilesExpand file tree

database_change_notification.py

Latest commit

History

database_change_notification.py

File metadata and controls