Top Fields Constructors Methods
org.postgresql.replication

public Class PGReplicationConnectionImpl

extends Object
implements PGReplicationConnection
Class Inheritance
All Implemented Interfaces
org.postgresql.replication.PGReplicationConnection
Imports
org.postgresql.core.BaseConnection, org.postgresql.replication.fluent.ChainedCreateReplicationSlotBuilder, .ChainedStreamBuilder, .ReplicationCreateSlotBuilder, .ReplicationStreamBuilder, java.sql.SQLException, .Statement

Field Summary

Modifier and TypeField and Description
private final BaseConnection
connection

Constructor Summary

AccessConstructor and Description
public
PGReplicationConnectionImpl(BaseConnection connection)

Method Summary

Modifier and TypeMethod and Description
public ChainedCreateReplicationSlotBuilder
createReplicationSlot()

Implements org.postgresql.replication.PGReplicationConnection.createReplicationSlot.

Create replication slot, that can be next use in PGReplicationConnection#replicationStream()

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)

Implements org.postgresql.replication.PGReplicationConnection.dropReplicationSlot.

public ChainedStreamBuilder
replicationStream()

Implements org.postgresql.replication.PGReplicationConnection.replicationStream.

After start replication stream this connection not available to use for another queries until replication stream will not close.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

connectionback to summary
private final BaseConnection connection

Constructor Detail

PGReplicationConnectionImplback to summary
public PGReplicationConnectionImpl(BaseConnection connection)

Method Detail

createReplicationSlotback to summary
public ChainedCreateReplicationSlotBuilder createReplicationSlot()

Implements org.postgresql.replication.PGReplicationConnection.createReplicationSlot.

Doc from org.postgresql.replication.PGReplicationConnection.createReplicationSlot.

Create replication slot, that can be next use in PGReplicationConnection#replicationStream()

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.

Returns:ChainedCreateReplicationSlotBuilder

not null fluent api for build create replication slot

Annotations
@Override
dropReplicationSlotback to summary
public void dropReplicationSlot(String slotName) throws SQLException

Implements org.postgresql.replication.PGReplicationConnection.dropReplicationSlot.

Parameters
slotName:String

Doc from org.postgresql.replication.PGReplicationConnection.dropReplicationSlot.

not null replication slot name exists in database that should be drop

Annotations
@Override
Exceptions
SQLException:

Doc from org.postgresql.replication.PGReplicationConnection.dropReplicationSlot.

if the replication slot cannot be dropped.

replicationStreamback to summary
public ChainedStreamBuilder replicationStream()

Implements org.postgresql.replication.PGReplicationConnection.replicationStream.

Doc from org.postgresql.replication.PGReplicationConnection.replicationStream.

After start replication stream this connection not available to use for another queries until replication stream will not close.

Returns:ChainedStreamBuilder

not null fluent api for build replication stream

Annotations
@Override