如何使用Java检查PostgreSQL逻辑复制插槽是否已经存在?

问题描述 投票:1回答:1

我正在使用PostgreSQL复制API用Java代码创建一个逻辑复制插槽,并且我想在创建过程之前添加一个测试,以检查该插槽是否已经存在。这是我的代码:

connection.getReplicationAPI()
.createReplicationSlot()
.logical()
.withSlotName(slotName)
.withOutputPlugin("test_decoding")
.make();
java postgresql database-replication
1个回答
0
投票
SELECT
  slot_name,
  plugin,
  slot_type,
  datoid,
  database,
  temporary,
  active,
  active_pid,
  xmin,
  catalog_xmin,
  restart_lsn,
  confirmed_flush_lsn
FROM pg_replication_slots
WHERE slot_name = ?
© www.soinside.com 2019 - 2024. All rights reserved.