Database

private void SubscribeToTable(string tableName)
        {
            Log.Write("Add listener: " + tableName);

            OracleConnection con = DataBase.GetOpenConnection();
            OracleDependency dependency = new OracleDependency();
            dependency.QueryBasedNotification = false;
            OracleCommand cmd = con.CreateCommand();
            cmd.CommandText = "Select * from " + tableName;
            dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
            dependency.AddCommandDependency(cmd);
            cmd.Notification.IsNotifiedOnce = false;
            cmd.AddRowid = true;
            cmd.ExecuteNonQuery();
            con.Close();
            con.Dispose(); 
        }

42	4	net8://(ADDRESS=(PROTOCOL=tcp)(HOST=192.168.1.119)(PORT=1521))?PR=0	0	0	49999	WEB.EXPORTEDDOCUMENTS

static void dependency_OnChange(object sender, OracleNotificationEventArgs eventArgs) 
        {
            Log.Write("Table has been Changed");
            Log.Write(eventArgs.Source.ToString());
            Log.Write(eventArgs.Info.ToString());
            Log.Write(eventArgs.Source.ToString());
            Log.Write(eventArgs.Type.ToString()); 
        }