Java - Oracle 数据库更改通知

Question

我正在尝试实现一个可以识别数据库更改通知（Oracle）的事件侦听器。根据参考网站，它说当EXAMPLE表中发生变化时，事件将触发并打印ROW_ID。我希望这个项目运行，它应该给我一条消息“给我一些东西！” 如果我手动在数据库中插入/更新数据。但是，据我了解，该代码无论如何都会终止，因为没有可以被事件中断的无限循环。如果我错了，请纠正我。

附加问题]
通过将OracleConnection.DCN_NOTIFY_ROWIDS设置为 true，它将通知每个事件，包括插入、更新、删除。我对么？我对“数据库更改事件将包括行级详细信息，例如操作类型和 ROWID”的含义感到困惑

我的代码：

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
import oracle.jdbc.OracleConnection;
import oracle.jdbc.OracleDriver;
import oracle.jdbc.OracleStatement;
import oracle.jdbc.dcn.DatabaseChangeEvent;
import oracle.jdbc.dcn.DatabaseChangeListener;
import oracle.jdbc.dcn.DatabaseChangeRegistration;

public class DBTest {
    static final String USERNAME = "username";
    static final String PASSWORD = "password";
    static String URL = "jdbc:oracle:thin:@url:port/name";

    public static void main(String[] args) {
        DBTest oracleDCN = new DBTest();
        try {
            oracleDCN.run();
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    private void run() throws Exception {
        OracleConnection conn = connect();
        Properties prop = new Properties();
        prop.setProperty(OracleConnection.DCN_NOTIFY_ROWIDS, "true");
        DatabaseChangeRegistration dcr = conn.registerDatabaseChangeNotification(prop);

        try {
            dcr.addListener(new DatabaseChangeListener() {
                public void onDatabaseChangeNotification(DatabaseChangeEvent dce) {
                    System.out.println("GIVE ME SOMETHING!");
                }
            });
            //conn.unregisterDatabaseChangeNotification(dcr);
            Statement stmt = conn.createStatement();
            ((OracleStatement) stmt).setDatabaseChangeRegistration(dcr);
            ResultSet rs = stmt.executeQuery("select * from Schema.T_TEST");
            while (rs.next()) {
            }
            rs.close();
            stmt.close();
        } catch (SQLException ex) {
            if (conn != null) {
                conn.unregisterDatabaseChangeNotification(dcr);
                conn.close();
            }
            throw ex;
        }
    }

    OracleConnection connect() throws SQLException {
        OracleDriver dr = new OracleDriver();
        Properties prop = new Properties();
        prop.setProperty("user", DBTest.USERNAME);
        prop.setProperty("password", DBTest.PASSWORD);
        return (OracleConnection) dr.connect(DBTest.URL, prop);
    }
}

更多详细信息可以在参考网站中找到

Answer 1

正如您所猜测的，您需要保持主线程处于活动状态，否则您的程序将退出。你可以让它睡觉或者做一些更有用的事情。您也可以关闭 JDBC 连接，但不想立即关闭（取消注册）注册。数据库更改通知的工作方式是使用在驱动程序中运行的内部侦听线程。该监听线程将通过专用网络套接字接收服务器发送的带外事件，处理这些事件并通知监听者。如果您取消注册，该监听线程将被关闭。当您不再对接收这些事件感兴趣时，您可以创建另一个到数据库的连接来取消注册，这最终将关闭驱动程序的侦听线程。