Package org.postgresql.replication.fluent

Class ReplicationCreateSlotBuilder

java.lang.Object
org.postgresql.replication.fluent.ReplicationCreateSlotBuilder
All Implemented Interfaces:
ChainedCreateReplicationSlotBuilder
public class ReplicationCreateSlotBuilder extends Object implements ChainedCreateReplicationSlotBuilder

  • Constructor Details

    • ReplicationCreateSlotBuilder

      public ReplicationCreateSlotBuilder(BaseConnection baseConnection)

  • Method Details

    • logical

      public ChainedLogicalCreateSlotBuilder logical()
      Description copied from interface: ChainedCreateReplicationSlotBuilder
      Get the logical slot builder. Example usage: 
         

    pgConnection
        .getReplicationAPI()
        .createReplicationSlot()
        .logical()
        .withSlotName("mySlot")
        .withOutputPlugin("test_decoding")
        .make();

    PGReplicationStream stream =
        pgConnection
            .getReplicationAPI()
            .replicationStream()
            .logical()
            .withSlotName("mySlot")
            .withSlotOption("include-xids", false)
            .withSlotOption("skip-empty-xacts", true)
            .start();

    while (true) {
      ByteBuffer buffer = stream.read();
      //process logical changes
    }
      Specified by:
      logical in interface ChainedCreateReplicationSlotBuilder
      Returns:
      not null fluent api

    • physical

      public ChainedPhysicalCreateSlotBuilder physical()
      Description copied from interface: ChainedCreateReplicationSlotBuilder

      Create physical replication stream for process wal logs in binary form.

      Example usage:

         

    pgConnection
        .getReplicationAPI()
        .createReplicationSlot()
        .physical()
        .withSlotName("mySlot")
        .make();

    PGReplicationStream stream =
        pgConnection
            .getReplicationAPI()
            .replicationStream()
            .physical()
            .withSlotName("mySlot")
            .start();

    while (true) {
      ByteBuffer buffer = stream.read();
      //process binary WAL logs
    }
      Specified by:
      physical in interface ChainedCreateReplicationSlotBuilder
      Returns:
      not null fluent api