Below is a simple example of a cutdown example of using DCN in Oracle with JDBC.<\/p>\n
I plan on presenting this to our developers as an alternative to the ATG InventoryCache manager module.<\/p>\n
\r\nimport java.sql.*;\r\nimport java.util.*;\r\nimport oracle.jdbc.*;\r\nimport oracle.jdbc.dcn.*;\r\nimport oracle.jdbc.dcn.RowChangeDescription.*;\r\n\r\npublic class ATGInventoryChangeNotify {\r\n String URL = \"jdbc:oracle:thin:test\/test@192.168.1.50:1521\/express.home\";\r\n Properties prop;\r\n\r\n public static void main(String[] argv) {\r\n\r\n ATGInventoryChangeNotify dcn = new ATGInventoryChangeNotify();\r\n try {\r\n dcn.prop = new Properties();\r\n dcn.run();\r\n }\r\n catch(Exception e) {\r\n e.printStackTrace();\r\n }\r\n }\r\n\r\n void run() throws SQLException {\r\n OracleConnection conn = (OracleConnection)DriverManager.getConnection(URL,prop);\r\n\r\n Properties prop = new Properties();\r\n prop.setProperty(OracleConnection.DCN_NOTIFY_ROWIDS,\"true\");\r\n DatabaseChangeRegistration dcr = conn.registerDatabaseChangeNotification(prop);\r\n\r\n try {\r\n dcnListener list = new dcnListener(this);\r\n dcr.addListener(list);\r\n\r\n Statement stmt = conn.createStatement();\r\n ((OracleStatement)stmt).setDatabaseChangeRegistration(dcr);\r\n ResultSet rs = stmt.executeQuery(\"select * from dept where 1 = 2\");\r\n rs.close();\r\n stmt.close();\r\n }\r\n catch(Exception e) {\r\n \/\/clean up our registration\r\n if(conn != null)\r\n conn.unregisterDatabaseChangeNotification(dcr);\r\n e.printStackTrace();\r\n }\r\n finally {\r\n try {\r\n conn.close();\r\n }\r\n catch(Exception e){\r\n e.printStackTrace();\r\n }\r\n }\r\n\r\n try {\r\n Thread.currentThread().join();\r\n }\r\n catch (Exception e) {\r\n e.printStackTrace();\r\n }\r\n\r\n finally {\r\n OracleConnection conn3 = (OracleConnection)DriverManager.getConnection(URL,prop);\r\n conn3.unregisterDatabaseChangeNotification(dcr);\r\n conn3.close();\r\n }\r\n }\r\n}\r\n\r\nclass dcnListener implements DatabaseChangeListener {\r\n ATGInventoryChangeNotify dcn;\r\n dcnListener(ATGInventoryChangeNotify dem) {\r\n dcn = dem;\r\n }\r\n\r\n public void onDatabaseChangeNotification(DatabaseChangeEvent e) {\r\n TableChangeDescription[] tc = e.getTableChangeDescription();\r\n\r\n for (int i = 0; i < tc.length; i++) {\r\n RowChangeDescription[] rcds = tc[i].getRowChangeDescription();\r\n for (int j = 0; j < rcds.length; j++) {\r\n \tSystem.out.println(rcds[j].getRowOperation() + \" \" + rcds[j].getRowid().stringValue());\r\n\t }\r\n\t}\r\n synchronized( dcn ){\r\n dcn.notify();\r\n }\r\n }\r\n}\r\n<\/pre>\n","protected":false},"excerpt":{"rendered":"Below is a simple example of a cutdown example of using DCN in Oracle with JDBC. I plan on presenting this to our developers as an alternative to the ATG InventoryCache manager module. import java.sql.*; import java.util.*; import oracle.jdbc.*; import…<\/p>\n