iframe-proxy | Sunbelt Computer Software

History

67 lines (59 loc) · 2.46 KB

Raw

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

# 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.TestTempTable and you will see the notification of that change.

# This script requires cx_Oracle 5.3 and higher.

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

from __future__ import print_function

import cx_Oracle

import SampleEnv

import threading

import time

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 = cx_Oracle.connect(SampleEnv.GetMainConnectString(), events = True)

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

qos = cx_Oracle.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 & cx_Oracle.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

DatabaseChangeNotification.py

Latest commit

History

DatabaseChangeNotification.py

File metadata and controls