public class org.postgresql.replication.PGReplicationConnectionImpl implements org.postgresql.replication.PGReplicationConnection
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.postgresql.replication.PGReplicationConnectionImpl
super_class: java.lang.Object
{
private org.postgresql.core.BaseConnection connection;
descriptor: Lorg/postgresql/core/BaseConnection;
flags: (0x0002) ACC_PRIVATE
public void <init>(org.postgresql.core.BaseConnection);
descriptor: (Lorg/postgresql/core/BaseConnection;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
start local 1 // org.postgresql.core.BaseConnection connection
0: .line 20
aload 0 /* this */
invokespecial java.lang.Object.<init>:()V
1: .line 21
aload 0 /* this */
aload 1 /* connection */
putfield org.postgresql.replication.PGReplicationConnectionImpl.connection:Lorg/postgresql/core/BaseConnection;
2: .line 22
return
end local 1 // org.postgresql.core.BaseConnection connection
end local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/postgresql/replication/PGReplicationConnectionImpl;
0 3 1 connection Lorg/postgresql/core/BaseConnection;
MethodParameters:
Name Flags
connection
public org.postgresql.replication.fluent.ChainedStreamBuilder replicationStream();
descriptor: ()Lorg/postgresql/replication/fluent/ChainedStreamBuilder;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
0: .line 26
new org.postgresql.replication.fluent.ReplicationStreamBuilder
dup
aload 0 /* this */
getfield org.postgresql.replication.PGReplicationConnectionImpl.connection:Lorg/postgresql/core/BaseConnection;
invokespecial org.postgresql.replication.fluent.ReplicationStreamBuilder.<init>:(Lorg/postgresql/core/BaseConnection;)V
areturn
end local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/postgresql/replication/PGReplicationConnectionImpl;
public org.postgresql.replication.fluent.ChainedCreateReplicationSlotBuilder createReplicationSlot();
descriptor: ()Lorg/postgresql/replication/fluent/ChainedCreateReplicationSlotBuilder;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
0: .line 31
new org.postgresql.replication.fluent.ReplicationCreateSlotBuilder
dup
aload 0 /* this */
getfield org.postgresql.replication.PGReplicationConnectionImpl.connection:Lorg/postgresql/core/BaseConnection;
invokespecial org.postgresql.replication.fluent.ReplicationCreateSlotBuilder.<init>:(Lorg/postgresql/core/BaseConnection;)V
areturn
end local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/postgresql/replication/PGReplicationConnectionImpl;
public void dropReplicationSlot(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=2
start local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
start local 1 // java.lang.String slotName
0: .line 36
aload 1 /* slotName */
ifnull 1
aload 1 /* slotName */
invokevirtual java.lang.String.isEmpty:()Z
ifeq 2
1: .line 37
StackMap locals:
StackMap stack:
new java.lang.IllegalArgumentException
dup
ldc "Replication slot name can't be null or empty"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: .line 40
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield org.postgresql.replication.PGReplicationConnectionImpl.connection:Lorg/postgresql/core/BaseConnection;
invokeinterface org.postgresql.core.BaseConnection.createStatement:()Ljava/sql/Statement;
astore 2 /* statement */
start local 2 // java.sql.Statement statement
3: .line 42
aload 2 /* statement */
new java.lang.StringBuilder
dup
ldc "DROP_REPLICATION_SLOT "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1 /* slotName */
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface java.sql.Statement.execute:(Ljava/lang/String;)Z
pop
4: .line 43
goto 8
StackMap locals: org.postgresql.replication.PGReplicationConnectionImpl java.lang.String java.sql.Statement
StackMap stack: java.lang.Throwable
5: astore 3
6: .line 44
aload 2 /* statement */
invokeinterface java.sql.Statement.close:()V
7: .line 45
aload 3
athrow
8: .line 44
StackMap locals:
StackMap stack:
aload 2 /* statement */
invokeinterface java.sql.Statement.close:()V
9: .line 46
return
end local 2 // java.sql.Statement statement
end local 1 // java.lang.String slotName
end local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/postgresql/replication/PGReplicationConnectionImpl;
0 10 1 slotName Ljava/lang/String;
3 10 2 statement Ljava/sql/Statement;
Exception table:
from to target type
3 5 5 any
Exceptions:
throws java.sql.SQLException
MethodParameters:
Name Flags
slotName
}
SourceFile: "PGReplicationConnectionImpl.java"