Package org.postgresql.replication.fluent

Interface ChainedCreateReplicationSlotBuilder

  • All Known Implementing Classes:
    ReplicationCreateSlotBuilder
    public interface ChainedCreateReplicationSlotBuilder
    Fluent interface for specify common parameters for Logical and Physical replication.

    • Method Detail

      • logical

        ChainedLogicalCreateSlotBuilder logical()
        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
    }
        Returns:
        not null fluent api

      • physical

        ChainedPhysicalCreateSlotBuilder physical()

        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
    }
        Returns:
        not null fluent api