クラス ReplicationCreateSlotBuilder

java.lang.Object
org.postgresql.replication.fluent.ReplicationCreateSlotBuilder
すべての実装されたインタフェース:
ChainedCreateReplicationSlotBuilder

public class ReplicationCreateSlotBuilder extends Object implements ChainedCreateReplicationSlotBuilder
  • コンストラクタの詳細

    • ReplicationCreateSlotBuilder

      public ReplicationCreateSlotBuilder(BaseConnection baseConnection)
  • メソッドの詳細

    • logical

      インタフェースからコピーされた説明: 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
          }
      
         
       
      定義:
      logical インタフェース内 ChainedCreateReplicationSlotBuilder
      戻り値:
      not null fluent api
    • physical

      インタフェースからコピーされた説明: 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
          }
      
         
       
      定義:
      physical インタフェース内 ChainedCreateReplicationSlotBuilder
      戻り値:
      not null fluent api