Updated on 2024-05-07 GMT+08:00

PGReplicationConnection

PGReplicationConnection is an API class provided by the JDBC driver in GaussDB. It is used to implement functions related to logical replication.

Inheritance Relationship of PGReplicationConnection

PGReplicationConnection is a logical replication interface. Its implementation class is PGReplicationConnectionImpl, which is in the org.postgresql.replication package. The declaration of the class is as follows:

public class PGReplicationConnection implements PGReplicationConnection

Construction Method

public PGReplicationConnection(BaseConnection connection)

Common Methods

Table 1 Common methods of PGReplicationConnection

Return Value

Method

Description

Throws

ChainedCreateReplicationSlotBuilder

createReplicationSlot()

Creates a logical replication slot. Only LSN-based logical replication slots can be created. For details about how to create CSN-based logical replication slots, see the SQL function pg_create_logical_replication_slot for logical replication.

-

void

dropReplicationSlot(String slotName)

Deletes a logical replication slot.

SQLException,IOException

ChainedStreamBuilder

replicationStream()

Enables logical replication.

-