PGProperty#REPLICATION and PGProperty#ASSUME_MIN_SERVER_VERSION. Without it property
building replication stream fail with exception.
| Modifier and Type | Method and Description |
|---|---|
| public ChainedCreateReplicationSlotBuilder | Returns: not null fluent api for build create replication slotCreate replication slot, that can be next use in Replication slots provide an automated way to ensure that the master does not remove WAL segments until they have been received by all standbys, and that the master does not remove rows which could cause a recovery conflict even when the standby is disconnected. |
| public void | dropReplicationSlot(String
not null replication slot name exists in database that should be drop slotName)
|
| public ChainedStreamBuilder | Returns: not null fluent api for build replication streamAfter start replication stream this connection not available to use for another queries until replication stream will not close. |
| createReplicationSlot | back to summary |
|---|---|
| public ChainedCreateReplicationSlotBuilder createReplicationSlot() Create replication slot, that can be next use in Replication slots provide an automated way to ensure that the master does not remove WAL segments until they have been received by all standbys, and that the master does not remove rows which could cause a recovery conflict even when the standby is disconnected.
| |
| dropReplicationSlot | back to summary |
|---|---|
public void dropReplicationSlot(String slotName) throws SQLException
| |
| replicationStream | back to summary |
|---|---|
| public ChainedStreamBuilder replicationStream() After start replication stream this connection not available to use for another queries until replication stream will not close.
| |