class io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec<R> extends io.vertx.mysqlclient.impl.codec.ExtendedQueryCommandBaseCodec<R, io.vertx.sqlclient.impl.command.ExtendedQueryCommand<R>>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec
super_class: io.vertx.mysqlclient.impl.codec.ExtendedQueryCommandBaseCodec
{
private java.util.List<io.vertx.sqlclient.Tuple> params;
descriptor: Ljava/util/List;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/List<Lio/vertx/sqlclient/Tuple;>;
private int batchIdx;
descriptor: I
flags: (0x0002) ACC_PRIVATE
void <init>(io.vertx.sqlclient.impl.command.ExtendedQueryCommand<R>);
descriptor: (Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.vertx.mysqlclient.impl.codec.ExtendedQueryCommandBaseCodec.<init>:(Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;)V
1: aload 0
iconst_0
putfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.batchIdx:I
2: aload 0
aload 1
invokevirtual io.vertx.sqlclient.impl.command.ExtendedQueryCommand.paramsList:()Ljava/util/List;
putfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.params:Ljava/util/List;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/mysqlclient/impl/codec/ExtendedBatchQueryCommandCodec<TR;>;
0 4 1 cmd Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand<TR;>;
Signature: (Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand<TR;>;)V
MethodParameters:
Name Flags
cmd
void encode(io.vertx.mysqlclient.impl.codec.MySQLEncoder);
descriptor: (Lio/vertx/mysqlclient/impl/codec/MySQLEncoder;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.vertx.mysqlclient.impl.codec.ExtendedQueryCommandBaseCodec.encode:(Lio/vertx/mysqlclient/impl/codec/MySQLEncoder;)V
1: aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.params:Ljava/util/List;
invokeinterface java.util.List.isEmpty:()Z
ifeq 4
aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.statement:Lio/vertx/mysqlclient/impl/codec/MySQLPreparedStatement;
getfield io.vertx.mysqlclient.impl.codec.MySQLPreparedStatement.paramDesc:Lio/vertx/mysqlclient/impl/MySQLParamDesc;
invokevirtual io.vertx.mysqlclient.impl.MySQLParamDesc.paramDefinitions:()[Lio/vertx/mysqlclient/impl/protocol/ColumnDefinition;
arraylength
ifle 4
2: aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.completionHandler:Lio/vertx/core/Handler;
ldc "Statement parameter is not set because of the empty batch param list"
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
3: return
4: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.doExecuteBatch:()V
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/mysqlclient/impl/codec/ExtendedBatchQueryCommandCodec<TR;>;
0 6 1 encoder Lio/vertx/mysqlclient/impl/codec/MySQLEncoder;
MethodParameters:
Name Flags
encoder
protected void handleSingleResultsetDecodingCompleted(int, long, long);
descriptor: (IJJ)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 0
iload 1
lload 2
lload 4
invokespecial io.vertx.mysqlclient.impl.codec.ExtendedQueryCommandBaseCodec.handleSingleResultsetDecodingCompleted:(IJJ)V
1: aload 0
invokevirtual io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.doExecuteBatch:()V
2: return
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/mysqlclient/impl/codec/ExtendedBatchQueryCommandCodec<TR;>;
0 3 1 serverStatusFlags I
0 3 2 affectedRows J
0 3 4 lastInsertId J
MethodParameters:
Name Flags
serverStatusFlags
affectedRows
lastInsertId
protected boolean isDecodingCompleted(int);
descriptor: (I)Z
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
invokespecial io.vertx.mysqlclient.impl.codec.ExtendedQueryCommandBaseCodec.isDecodingCompleted:(I)Z
ifeq 1
aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.batchIdx:I
aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.params:Ljava/util/List;
invokeinterface java.util.List.size:()I
if_icmpne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/mysqlclient/impl/codec/ExtendedBatchQueryCommandCodec<TR;>;
0 2 1 serverStatusFlags I
MethodParameters:
Name Flags
serverStatusFlags
private void doExecuteBatch();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.batchIdx:I
aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.params:Ljava/util/List;
invokeinterface java.util.List.size:()I
if_icmpge 9
1: aload 0
iconst_0
putfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.sequenceId:I
2: aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.params:Ljava/util/List;
aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.batchIdx:I
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast io.vertx.sqlclient.Tuple
astore 1
start local 1 3: aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.statement:Lio/vertx/mysqlclient/impl/codec/MySQLPreparedStatement;
aload 1
invokevirtual io.vertx.mysqlclient.impl.codec.MySQLPreparedStatement.bindParameters:(Lio/vertx/sqlclient/Tuple;)Ljava/lang/String;
astore 2
start local 2 4: aload 2
ifnull 7
5: aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.completionHandler:Lio/vertx/core/Handler;
aload 2
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
6: return
7: StackMap locals: io.vertx.sqlclient.Tuple java.lang.String
StackMap stack:
aload 0
aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.statement:Lio/vertx/mysqlclient/impl/codec/MySQLPreparedStatement;
aload 1
invokevirtual io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.sendBatchStatementExecuteCommand:(Lio/vertx/mysqlclient/impl/codec/MySQLPreparedStatement;Lio/vertx/sqlclient/Tuple;)V
8: aload 0
dup
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.batchIdx:I
iconst_1
iadd
putfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.batchIdx:I
end local 2 end local 1 9: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/mysqlclient/impl/codec/ExtendedBatchQueryCommandCodec<TR;>;
3 9 1 param Lio/vertx/sqlclient/Tuple;
4 9 2 bindMsg Ljava/lang/String;
private void sendBatchStatementExecuteCommand(io.vertx.mysqlclient.impl.codec.MySQLPreparedStatement, io.vertx.sqlclient.Tuple);
descriptor: (Lio/vertx/mysqlclient/impl/codec/MySQLPreparedStatement;Lio/vertx/sqlclient/Tuple;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=12, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.allocateBuffer:()Lio/netty/buffer/ByteBuf;
astore 3
start local 3 1: aload 3
invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
istore 4
start local 4 2: aload 3
iconst_0
invokevirtual io.netty.buffer.ByteBuf.writeMediumLE:(I)Lio/netty/buffer/ByteBuf;
pop
3: aload 3
aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.sequenceId:I
invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
pop
4: aload 3
bipush 23
invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
pop
5: aload 3
aload 1
getfield io.vertx.mysqlclient.impl.codec.MySQLPreparedStatement.statementId:J
l2i
invokevirtual io.netty.buffer.ByteBuf.writeIntLE:(I)Lio/netty/buffer/ByteBuf;
pop
6: aload 3
iconst_0
invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
pop
7: aload 3
iconst_1
invokevirtual io.netty.buffer.ByteBuf.writeIntLE:(I)Lio/netty/buffer/ByteBuf;
pop
8: aload 1
invokevirtual io.vertx.mysqlclient.impl.codec.MySQLPreparedStatement.bindingTypes:()[Lio/vertx/mysqlclient/impl/datatype/DataType;
arraylength
istore 5
start local 5 9: iload 5
bipush 7
iadd
bipush 8
idiv
istore 6
start local 6 10: iload 6
newarray 8
astore 7
start local 7 11: aload 3
invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
istore 8
start local 8 12: iload 5
ifle 33
13: aload 3
aload 7
invokevirtual io.netty.buffer.ByteBuf.writeBytes:([B)Lio/netty/buffer/ByteBuf;
pop
14: aload 3
iconst_1
invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
pop
15: iconst_0
istore 9
start local 9 16: goto 22
17: StackMap locals: io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec io.vertx.mysqlclient.impl.codec.MySQLPreparedStatement io.vertx.sqlclient.Tuple io.netty.buffer.ByteBuf int int int byte[] int int
StackMap stack:
aload 2
iload 9
invokeinterface io.vertx.sqlclient.Tuple.getValue:(I)Ljava/lang/Object;
astore 10
start local 10 18: aload 10
invokestatic io.vertx.mysqlclient.impl.datatype.DataTypeCodec.inferDataTypeByEncodingValue:(Ljava/lang/Object;)Lio/vertx/mysqlclient/impl/datatype/DataType;
astore 11
start local 11 19: aload 3
aload 11
getfield io.vertx.mysqlclient.impl.datatype.DataType.id:I
invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
pop
20: aload 3
iconst_0
invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
pop
end local 11 end local 10 21: iinc 9 1
StackMap locals:
StackMap stack:
22: iload 9
aload 2
invokeinterface io.vertx.sqlclient.Tuple.size:()I
if_icmplt 17
end local 9 23: iconst_0
istore 9
start local 9 24: goto 31
25: StackMap locals:
StackMap stack:
aload 2
iload 9
invokeinterface io.vertx.sqlclient.Tuple.getValue:(I)Ljava/lang/Object;
astore 10
start local 10 26: aload 10
ifnull 29
27: aload 10
invokestatic io.vertx.mysqlclient.impl.datatype.DataTypeCodec.inferDataTypeByEncodingValue:(Ljava/lang/Object;)Lio/vertx/mysqlclient/impl/datatype/DataType;
aload 10
aload 0
getfield io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.encoder:Lio/vertx/mysqlclient/impl/codec/MySQLEncoder;
getfield io.vertx.mysqlclient.impl.codec.MySQLEncoder.encodingCharset:Ljava/nio/charset/Charset;
aload 3
invokestatic io.vertx.mysqlclient.impl.datatype.DataTypeCodec.encodeBinary:(Lio/vertx/mysqlclient/impl/datatype/DataType;Ljava/lang/Object;Ljava/nio/charset/Charset;Lio/netty/buffer/ByteBuf;)V
28: goto 30
29: StackMap locals: java.lang.Object
StackMap stack:
aload 7
iload 9
bipush 8
idiv
dup2
baload
iconst_1
iload 9
bipush 7
iand
ishl
ior
i2b
bastore
end local 10 30: StackMap locals:
StackMap stack:
iinc 9 1
StackMap locals:
StackMap stack:
31: iload 9
iload 5
if_icmplt 25
end local 9 32: aload 3
iload 8
aload 7
invokevirtual io.netty.buffer.ByteBuf.setBytes:(I[B)Lio/netty/buffer/ByteBuf;
pop
33: StackMap locals:
StackMap stack:
aload 3
invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
iload 4
isub
iconst_4
isub
istore 9
start local 9 34: aload 3
iload 4
iload 9
invokevirtual io.netty.buffer.ByteBuf.setMediumLE:(II)Lio/netty/buffer/ByteBuf;
pop
35: aload 0
aload 3
iload 9
invokevirtual io.vertx.mysqlclient.impl.codec.ExtendedBatchQueryCommandCodec.sendPacket:(Lio/netty/buffer/ByteBuf;I)V
36: return
end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 37 0 this Lio/vertx/mysqlclient/impl/codec/ExtendedBatchQueryCommandCodec<TR;>;
0 37 1 statement Lio/vertx/mysqlclient/impl/codec/MySQLPreparedStatement;
0 37 2 params Lio/vertx/sqlclient/Tuple;
1 37 3 packet Lio/netty/buffer/ByteBuf;
2 37 4 packetStartIdx I
9 37 5 numOfParams I
10 37 6 bitmapLength I
11 37 7 nullBitmap [B
12 37 8 pos I
16 23 9 i I
18 21 10 param Ljava/lang/Object;
19 21 11 dataType Lio/vertx/mysqlclient/impl/datatype/DataType;
24 32 9 i I
26 30 10 value Ljava/lang/Object;
34 37 9 payloadLength I
MethodParameters:
Name Flags
statement
params
}
Signature: <R:Ljava/lang/Object;>Lio/vertx/mysqlclient/impl/codec/ExtendedQueryCommandBaseCodec<TR;Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand<TR;>;>;
SourceFile: "ExtendedBatchQueryCommandCodec.java"