Package org.postgresql.core.v3.replication

Class V3ReplicationProtocol

java.lang.Object

org.postgresql.core.v3.replication.V3ReplicationProtocol

All Implemented Interfaces:

ReplicationProtocol

public class V3ReplicationProtocol
extends Object
implements ReplicationProtocol

Field Summary

Fields

Modifier and Type	Field	Description
private static final Logger	LOGGER
private final PGStream	pgStream
private final QueryExecutor	queryExecutor

Constructor Summary

Constructors

Constructor	Description
V3ReplicationProtocol(QueryExecutor queryExecutor, PGStream pgStream)

Method Summary

Modifier and Type	Method	Description
private void	configureSocketTimeout(CommonOptions options)
private String	createStartLogicalQuery(LogicalReplicationOptions options)	START_REPLICATION SLOT slot_name LOGICAL XXX/XXX [ ( option_name [option_value] [, ...
private String	createStartPhysicalQuery(PhysicalReplicationOptions options)	START_REPLICATION [SLOT slot_name] [PHYSICAL] XXX/XXX.
private PGReplicationStream	initializeReplication(String query, CommonOptions options, ReplicationType replicationType)
PGReplicationStream	startLogical(LogicalReplicationOptions options)
PGReplicationStream	startPhysical(PhysicalReplicationOptions options)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOGGER

private static final Logger LOGGER

queryExecutor

private final QueryExecutor queryExecutor

pgStream

private final PGStream pgStream

Constructor Details

V3ReplicationProtocol

public V3ReplicationProtocol(QueryExecutor queryExecutor,
 PGStream pgStream)

Method Details

startLogical

public PGReplicationStream startLogical(LogicalReplicationOptions options)
                                 throws SQLException

Specified by:

startLogical in interface ReplicationProtocol

Parameters:

options - not null options for logical replication stream

Returns:

not null stream instance from which available fetch wal logs that was decode by output plugin

Throws:

SQLException - on error

startPhysical

public PGReplicationStream startPhysical(PhysicalReplicationOptions options)
                                  throws SQLException

Specified by:

startPhysical in interface ReplicationProtocol

Parameters:

options - not null options for physical replication stream

Returns:

not null stream instance from which available fetch wal logs

Throws:

SQLException - on error

initializeReplication

private PGReplicationStream initializeReplication(String query,
 CommonOptions options,
 ReplicationType replicationType)
                                           throws SQLException

Throws:

SQLException

createStartPhysicalQuery

private String createStartPhysicalQuery(PhysicalReplicationOptions options)

START_REPLICATION [SLOT slot_name] [PHYSICAL] XXX/XXX.

createStartLogicalQuery

private String createStartLogicalQuery(LogicalReplicationOptions options)

START_REPLICATION SLOT slot_name LOGICAL XXX/XXX [ ( option_name [option_value] [, ... ] ) ]

configureSocketTimeout

private void configureSocketTimeout(CommonOptions options)
                             throws PSQLException

Throws:

PSQLException