Class V3ReplicationProtocol

    • Field Detail

      • LOGGER

        private static final java.util.logging.Logger LOGGER
      • pgStream

        private final PGStream pgStream
    • Constructor Detail

      • V3ReplicationProtocol

        public V3ReplicationProtocol​(QueryExecutor queryExecutor,
                                     PGStream pgStream)
    • Method Detail

      • startLogical

        public PGReplicationStream startLogical​(LogicalReplicationOptions options)
                                         throws java.sql.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:
        java.sql.SQLException - on error
      • createStartPhysicalQuery

        private java.lang.String createStartPhysicalQuery​(PhysicalReplicationOptions options)
        START_REPLICATION [SLOT slot_name] [PHYSICAL] XXX/XXX.
      • createStartLogicalQuery

        private java.lang.String createStartLogicalQuery​(LogicalReplicationOptions options)
        START_REPLICATION SLOT slot_name LOGICAL XXX/XXX [ ( option_name [option_value] [, ... ] ) ]