class io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec<R, C extends io.vertx.sqlclient.impl.command.ExtendedQueryCommand<R>> extends io.vertx.pgclient.impl.codec.QueryCommandBaseCodec<R, C>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec
super_class: io.vertx.pgclient.impl.codec.QueryCommandBaseCodec
{
private io.vertx.pgclient.impl.codec.PgEncoder encoder;
descriptor: Lio/vertx/pgclient/impl/codec/PgEncoder;
flags: (0x0002) ACC_PRIVATE
private static final java.lang.String TABLE_SCHEMA_CHANGE_ERROR_MESSAGE_PATTERN;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "bind message has \\d result formats but query has \\d columns"
void <init>();
descriptor: (Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;)V
flags: (0x0000)
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.vertx.pgclient.impl.codec.QueryCommandBaseCodec.<init>:(Lio/vertx/sqlclient/impl/command/QueryCommandBase;)V
1: aload 0
new io.vertx.pgclient.impl.codec.RowResultDecoder
dup
aload 1
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.collector:()Ljava/util/stream/Collector;
aload 1
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.preparedStatement:()Lio/vertx/sqlclient/impl/PreparedStatement;
checkcast io.vertx.pgclient.impl.codec.PgPreparedStatement
invokevirtual io.vertx.pgclient.impl.codec.PgPreparedStatement.rowDesc:()Lio/vertx/pgclient/impl/codec/PgRowDesc;
invokespecial io.vertx.pgclient.impl.codec.RowResultDecoder.<init>:(Ljava/util/stream/Collector;Lio/vertx/pgclient/impl/codec/PgRowDesc;)V
putfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.decoder:Lio/vertx/pgclient/impl/codec/RowResultDecoder;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/pgclient/impl/codec/ExtendedQueryCommandCodec<TR;TC;>;
0 3 1 cmd TC;
Signature: (TC;)V
MethodParameters:
Name Flags
cmd
void encode(io.vertx.pgclient.impl.codec.PgEncoder);
descriptor: (Lio/vertx/pgclient/impl/codec/PgEncoder;)V
flags: (0x0000)
Code:
stack=4, locals=5, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.encoder:Lio/vertx/pgclient/impl/codec/PgEncoder;
1: aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.isSuspended:()Z
ifeq 5
2: aload 1
aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.cursorId:()Ljava/lang/String;
aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.fetch:()I
invokevirtual io.vertx.pgclient.impl.codec.PgEncoder.writeExecute:(Ljava/lang/String;I)V
3: aload 1
invokevirtual io.vertx.pgclient.impl.codec.PgEncoder.writeSync:()V
4: goto 20
5: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.preparedStatement:()Lio/vertx/sqlclient/impl/PreparedStatement;
checkcast io.vertx.pgclient.impl.codec.PgPreparedStatement
astore 2
start local 2 6: aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.isBatch:()Z
ifeq 17
7: aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.paramsList:()Ljava/util/List;
invokeinterface java.util.List.isEmpty:()Z
ifeq 11
8: aload 0
iconst_0
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
putfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.result:Ljava/lang/Object;
9: aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.completionHandler:Lio/vertx/core/Handler;
ldc "Can not execute batch query with 0 sets of batch parameters."
invokestatic io.vertx.sqlclient.impl.command.CommandResponse.failure:(Ljava/lang/String;)Lio/vertx/sqlclient/impl/command/CommandResponse;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
10: return
11: StackMap locals: io.vertx.pgclient.impl.codec.PgPreparedStatement
StackMap stack:
aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.paramsList:()Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 4
goto 15
StackMap locals: io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec io.vertx.pgclient.impl.codec.PgEncoder io.vertx.pgclient.impl.codec.PgPreparedStatement top java.util.Iterator
StackMap stack:
12: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.Tuple
astore 3
start local 3 13: aload 1
aload 2
getfield io.vertx.pgclient.impl.codec.PgPreparedStatement.bind:Lio/vertx/pgclient/impl/codec/Bind;
aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.cursorId:()Ljava/lang/String;
aload 3
invokevirtual io.vertx.pgclient.impl.codec.PgEncoder.writeBind:(Lio/vertx/pgclient/impl/codec/Bind;Ljava/lang/String;Lio/vertx/sqlclient/Tuple;)V
14: aload 1
aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.cursorId:()Ljava/lang/String;
aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.fetch:()I
invokevirtual io.vertx.pgclient.impl.codec.PgEncoder.writeExecute:(Ljava/lang/String;I)V
end local 3 15: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 12
16: goto 19
17: StackMap locals: io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec io.vertx.pgclient.impl.codec.PgEncoder io.vertx.pgclient.impl.codec.PgPreparedStatement
StackMap stack:
aload 1
aload 2
getfield io.vertx.pgclient.impl.codec.PgPreparedStatement.bind:Lio/vertx/pgclient/impl/codec/Bind;
aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.cursorId:()Ljava/lang/String;
aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.params:()Lio/vertx/sqlclient/Tuple;
invokevirtual io.vertx.pgclient.impl.codec.PgEncoder.writeBind:(Lio/vertx/pgclient/impl/codec/Bind;Ljava/lang/String;Lio/vertx/sqlclient/Tuple;)V
18: aload 1
aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.cursorId:()Ljava/lang/String;
aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.fetch:()I
invokevirtual io.vertx.pgclient.impl.codec.PgEncoder.writeExecute:(Ljava/lang/String;I)V
19: StackMap locals:
StackMap stack:
aload 1
invokevirtual io.vertx.pgclient.impl.codec.PgEncoder.writeSync:()V
end local 2 20: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lio/vertx/pgclient/impl/codec/ExtendedQueryCommandCodec<TR;TC;>;
0 21 1 encoder Lio/vertx/pgclient/impl/codec/PgEncoder;
6 20 2 ps Lio/vertx/pgclient/impl/codec/PgPreparedStatement;
13 15 3 param Lio/vertx/sqlclient/Tuple;
MethodParameters:
Name Flags
encoder
void handleParseComplete();
descriptor: ()V
flags: (0x0000)
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/pgclient/impl/codec/ExtendedQueryCommandCodec<TR;TC;>;
void handlePortalSuspended();
descriptor: ()V
flags: (0x0000)
Code:
stack=6, locals=5, args_size=1
start local 0 0: aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.decoder:Lio/vertx/pgclient/impl/codec/RowResultDecoder;
invokevirtual io.vertx.pgclient.impl.codec.RowResultDecoder.complete:()Ljava/lang/Throwable;
astore 1
start local 1 1: aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.decoder:Lio/vertx/pgclient/impl/codec/RowResultDecoder;
invokevirtual io.vertx.pgclient.impl.codec.RowResultDecoder.result:()Ljava/lang/Object;
astore 2
start local 2 2: aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.decoder:Lio/vertx/pgclient/impl/codec/RowResultDecoder;
getfield io.vertx.pgclient.impl.codec.RowResultDecoder.desc:Lio/vertx/pgclient/impl/codec/PgRowDesc;
astore 3
start local 3 3: aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.decoder:Lio/vertx/pgclient/impl/codec/RowResultDecoder;
invokevirtual io.vertx.pgclient.impl.codec.RowResultDecoder.size:()I
istore 4
start local 4 4: aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.decoder:Lio/vertx/pgclient/impl/codec/RowResultDecoder;
invokevirtual io.vertx.pgclient.impl.codec.RowResultDecoder.reset:()V
5: aload 0
iconst_1
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
putfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.result:Ljava/lang/Object;
6: aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.resultHandler:()Lio/vertx/sqlclient/impl/QueryResultHandler;
iconst_0
iload 4
aload 3
aload 2
aload 1
invokeinterface io.vertx.sqlclient.impl.QueryResultHandler.handleResult:(IILio/vertx/sqlclient/impl/RowDesc;Ljava/lang/Object;Ljava/lang/Throwable;)V
7: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/pgclient/impl/codec/ExtendedQueryCommandCodec<TR;TC;>;
1 8 1 failure Ljava/lang/Throwable;
2 8 2 result TR;
3 8 3 desc Lio/vertx/sqlclient/impl/RowDesc;
4 8 4 size I
void handleBindComplete();
descriptor: ()V
flags: (0x0000)
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/pgclient/impl/codec/ExtendedQueryCommandCodec<TR;TC;>;
public void handleErrorResponse(io.vertx.pgclient.impl.codec.ErrorResponse);
descriptor: (Lio/vertx/pgclient/impl/codec/ErrorResponse;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.preparedStatement:()Lio/vertx/sqlclient/impl/PreparedStatement;
checkcast io.vertx.pgclient.impl.codec.PgPreparedStatement
invokevirtual io.vertx.pgclient.impl.codec.PgPreparedStatement.isCached:()Z
ifeq 2
aload 0
aload 1
invokevirtual io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.isTableSchemaErrorMessage:(Lio/vertx/pgclient/impl/codec/ErrorResponse;)Z
ifeq 2
1: aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.encoder:Lio/vertx/pgclient/impl/codec/PgEncoder;
invokevirtual io.vertx.pgclient.impl.codec.PgEncoder.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
new io.vertx.sqlclient.impl.codec.InvalidCachedStatementEvent
dup
aload 0
getfield io.vertx.pgclient.impl.codec.ExtendedQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.ExtendedQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.preparedStatement:()Lio/vertx/sqlclient/impl/PreparedStatement;
invokeinterface io.vertx.sqlclient.impl.PreparedStatement.sql:()Ljava/lang/String;
invokespecial io.vertx.sqlclient.impl.codec.InvalidCachedStatementEvent.<init>:(Ljava/lang/String;)V
invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext;
pop
2: StackMap locals:
StackMap stack:
aload 0
aload 1
invokespecial io.vertx.pgclient.impl.codec.QueryCommandBaseCodec.handleErrorResponse:(Lio/vertx/pgclient/impl/codec/ErrorResponse;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/pgclient/impl/codec/ExtendedQueryCommandCodec<TR;TC;>;
0 4 1 errorResponse Lio/vertx/pgclient/impl/codec/ErrorResponse;
MethodParameters:
Name Flags
errorResponse
private boolean isTableSchemaErrorMessage(io.vertx.pgclient.impl.codec.ErrorResponse);
descriptor: (Lio/vertx/pgclient/impl/codec/ErrorResponse;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.vertx.pgclient.impl.codec.ErrorResponse.getMessage:()Ljava/lang/String;
ldc "bind message has \\d result formats but query has \\d columns"
invokevirtual java.lang.String.matches:(Ljava/lang/String;)Z
ifne 1
aload 1
invokevirtual io.vertx.pgclient.impl.codec.ErrorResponse.getMessage:()Ljava/lang/String;
ldc "cached plan must not change result type"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 1
iconst_0
ireturn
StackMap locals:
StackMap stack:
1: iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/pgclient/impl/codec/ExtendedQueryCommandCodec<TR;TC;>;
0 2 1 errorResponse Lio/vertx/pgclient/impl/codec/ErrorResponse;
MethodParameters:
Name Flags
errorResponse
}
Signature: <R:Ljava/lang/Object;C:Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand<TR;>;>Lio/vertx/pgclient/impl/codec/QueryCommandBaseCodec<TR;TC;>;
SourceFile: "ExtendedQueryCommandCodec.java"