PostgreSQL 在 Oracle 和 MySQL 中的 XMIN

Question

我正在尝试在 Oracle 和 MySQL 上获取此代码的等效项

if(vardbtype.equals("POSTGRESQL")){
            Long previousTxId = 0L;
            Long nextTxId = 0L;

            Class.forName("org.postgresql.Driver");
            System.out.println("----------------------------");

            try(Connection c = DriverManager.getConnection("jdbc:postgresql://localhost:5432/"+ vardbserver, vardbuser, vardbpassword);
                 PreparedStatement stmts = c.prepareStatement("SELECT * FROM "+ vardbname +" where xmin::varchar::bigint > ? and xmin::varchar::bigint < ? ");
                 PreparedStatement max = c.prepareStatement("select max(xmin::varchar::bigint) as txid from "+ vardbname)
                ) {
                c.setAutoCommit(false);

                while(true) {
                    stmts.clearParameters();

                    try(ResultSet rss = max.executeQuery()) {
                        if(rss.next()) {
                            nextTxId = rss.getLong(1);
                        }
                    }
                    stmts.setLong(1, previousTxId);
                    stmts.setLong(2, nextTxId + 1);
                    try(ResultSet rss = stmts.executeQuery()) {
                        while(rss.next()) {
                            String message = rss.getString("MESSAGE");
                            System.out.println("Message = " + message);
                            TextMessage mssg = session.createTextMessage(message);
                            System.out.println("Sent: " + mssg.getText());
                            producer.send(mssg);
                        }
                        previousTxId = nextTxId;
                    }
                    Thread.sleep(batchperiod2);
                }
            }
        }

基本上，代码用于获取数据库表中的内容并将其发送到 ActiveMQ。并且当表格更新时，它将发送刚刚更新的内容（而不是发送过去发送的内容）。但此代码仅适用于 PostgreSQL

然后我打算创建一个“if”函数。所以我可以使用另一个数据库来获取数据（Oracle 和 MySQL）。

我想我必须更改此代码吧？

 try(Connection c = DriverManager.getConnection("jdbc:postgresql://localhost:5432/"+ vardbserver, vardbuser, vardbpassword);
             PreparedStatement stmts = c.prepareStatement("SELECT * FROM "+ vardbname +" where xmin::varchar::bigint > ? and xmin::varchar::bigint < ? ");
             PreparedStatement max = c.prepareStatement("select max(xmin::varchar::bigint) as txid from "+ vardbname)
            ) {

Answer 1

此脚本在表格中查找间隔，并输出自上次循环以来插入的所有消息。

PostgreSQL 存储了插入记录的事务编号，因此可以用来查找新插入的记录（尽管我不确定是否可以保证新事务的编号比以前的所有事务都高）假设）。

其他 DBMS 没有此伪列。所以你必须在你的表中有一个时间戳列并使用它来代替。您必须更改两个查询以及代码以匹配数据类型（我想 java.sql.Timestamp 而不是 Long，但我不是 Java 人）。

Answer 2

Thorsten 回答的一些补充想法。

首先，xmin 是一个系统列，即 iirc，存储在磁盘的行标题中。它由写入更新。我还没有遇到交易ID不增加的情况。但是，必须有一些环绕点。我认为您最好使用一个触发器，该触发器将事务 id 存储在另一个表中以便出于这个原因进行处理（并使用它来处理事情）。

对于 Oracle 和 MySQL，底层存储有很大的不同，我不知道如何直接做到这一点。

如果您想要一个通用解决方案，您需要一个队列表，您可以在其中使用触发器插入等待的副本，然后在您的工作人员中从中选择/删除。这在 MySQL 上可能比在 PostgreSQL 上工作得更好，而对于 Oracle，您希望寻找面向索引的表。如果 autovacuum 无法跟上，请提出更多问题或聘请顾问。

经过进一步研究

InnoDB 提供了一个类似的DB_TRX_ID 列。请注意，如果您正在运行 MySQL，您不能假设您有此列，因为 MySQL 具有不同的表存储引擎，而且并非所有引擎都支持事务。所以这是一个重要的限制。

我无法在 Oracle 上找到类似的专栏。