class io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec<T> extends io.vertx.mysqlclient.impl.codec.QueryCommandBaseCodec<T, io.vertx.sqlclient.impl.command.SimpleQueryCommand<T>>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec
super_class: io.vertx.mysqlclient.impl.codec.QueryCommandBaseCodec
{
void <init>(io.vertx.sqlclient.impl.command.SimpleQueryCommand<T>);
descriptor: (Lio/vertx/sqlclient/impl/command/SimpleQueryCommand;)V
flags: (0x0000)
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
getstatic io.vertx.mysqlclient.impl.datatype.DataFormat.TEXT:Lio/vertx/mysqlclient/impl/datatype/DataFormat;
invokespecial io.vertx.mysqlclient.impl.codec.QueryCommandBaseCodec.<init>:(Lio/vertx/sqlclient/impl/command/QueryCommandBase;Lio/vertx/mysqlclient/impl/datatype/DataFormat;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec<TT;>;
0 2 1 cmd Lio/vertx/sqlclient/impl/command/SimpleQueryCommand<TT;>;
Signature: (Lio/vertx/sqlclient/impl/command/SimpleQueryCommand<TT;>;)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.QueryCommandBaseCodec.encode:(Lio/vertx/mysqlclient/impl/codec/MySQLEncoder;)V
1: aload 0
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.sendQueryCommand:()V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec<TT;>;
0 3 1 encoder Lio/vertx/mysqlclient/impl/codec/MySQLEncoder;
MethodParameters:
Name Flags
encoder
protected void handleInitPacket(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=4, args_size=2
start local 0 start local 1 0: aload 1
aload 1
invokevirtual io.netty.buffer.ByteBuf.readerIndex:()I
invokevirtual io.netty.buffer.ByteBuf.getUnsignedByte:(I)S
istore 2
start local 2 1: iload 2
ifne 5
2: aload 0
aload 1
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.decodeOkPacketPayload:(Lio/netty/buffer/ByteBuf;)Lio/vertx/mysqlclient/impl/protocol/Packets$OkPacket;
astore 3
start local 3 3: aload 0
aload 3
invokevirtual io.vertx.mysqlclient.impl.protocol.Packets$OkPacket.serverStatusFlags:()I
aload 3
invokevirtual io.vertx.mysqlclient.impl.protocol.Packets$OkPacket.affectedRows:()J
aload 3
invokevirtual io.vertx.mysqlclient.impl.protocol.Packets$OkPacket.lastInsertId:()J
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.handleSingleResultsetDecodingCompleted:(IJJ)V
end local 3 4: goto 12
StackMap locals: int
StackMap stack:
5: iload 2
sipush 255
if_icmpne 8
6: aload 0
aload 1
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.handleErrorPacketPayload:(Lio/netty/buffer/ByteBuf;)V
7: goto 12
StackMap locals:
StackMap stack:
8: iload 2
sipush 251
if_icmpne 11
9: aload 0
aload 1
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.handleLocalInfile:(Lio/netty/buffer/ByteBuf;)V
10: goto 12
11: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.handleResultsetColumnCountPacketBody:(Lio/netty/buffer/ByteBuf;)V
12: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec<TT;>;
0 13 1 payload Lio/netty/buffer/ByteBuf;
1 13 2 firstByte I
3 4 3 okPacket Lio/vertx/mysqlclient/impl/protocol/Packets$OkPacket;
MethodParameters:
Name Flags
payload
private void sendQueryCommand();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.allocateBuffer:()Lio/netty/buffer/ByteBuf;
astore 1
start local 1 1: aload 1
invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
istore 2
start local 2 2: aload 1
iconst_0
invokevirtual io.netty.buffer.ByteBuf.writeMediumLE:(I)Lio/netty/buffer/ByteBuf;
pop
3: aload 1
aload 0
getfield io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.sequenceId:I
invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
pop
4: aload 1
iconst_3
invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
pop
5: aload 1
aload 0
getfield io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.cmd:Lio/vertx/sqlclient/impl/command/CommandBase;
checkcast io.vertx.sqlclient.impl.command.SimpleQueryCommand
invokevirtual io.vertx.sqlclient.impl.command.SimpleQueryCommand.sql:()Ljava/lang/String;
aload 0
getfield io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.encoder:Lio/vertx/mysqlclient/impl/codec/MySQLEncoder;
getfield io.vertx.mysqlclient.impl.codec.MySQLEncoder.encodingCharset:Ljava/nio/charset/Charset;
invokevirtual io.netty.buffer.ByteBuf.writeCharSequence:(Ljava/lang/CharSequence;Ljava/nio/charset/Charset;)I
pop
6: aload 1
invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
iload 2
isub
iconst_4
isub
istore 3
start local 3 7: aload 1
iload 2
iload 3
invokevirtual io.netty.buffer.ByteBuf.setMediumLE:(II)Lio/netty/buffer/ByteBuf;
pop
8: aload 0
aload 1
iload 3
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.sendPacket:(Lio/netty/buffer/ByteBuf;I)V
9: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec<TT;>;
1 10 1 packet Lio/netty/buffer/ByteBuf;
2 10 2 packetStartIdx I
7 10 3 payloadLength I
private void handleLocalInfile(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=14, args_size=2
start local 0 start local 1 0: aload 1
iconst_1
invokevirtual io.netty.buffer.ByteBuf.skipBytes:(I)Lio/netty/buffer/ByteBuf;
pop
1: aload 0
aload 1
getstatic java.nio.charset.StandardCharsets.UTF_8:Ljava/nio/charset/Charset;
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.readRestOfPacketString:(Lio/netty/buffer/ByteBuf;Ljava/nio/charset/Charset;)Ljava/lang/String;
astore 2
start local 2 2: new java.io.File
dup
aload 2
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
astore 3
start local 3 3: aload 3
invokevirtual java.io.File.length:()J
lstore 4
start local 4 4: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 6
start local 6 5: iconst_0
istore 7
start local 7 6: lload 4
l2i
istore 8
start local 8 7: goto 12
8: StackMap locals: io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec io.netty.buffer.ByteBuf java.lang.String java.io.File long java.util.List int int
StackMap stack:
iload 7
istore 9
start local 9 9: aload 6
aload 0
aload 2
iload 9
invokedynamic get(Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec;Ljava/lang/String;I)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec.lambda$0(Ljava/lang/String;I)Lio/vertx/core/Future; (7)
()Lio/vertx/core/Future;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
10: iload 8
ldc 16777215
isub
istore 8
11: iload 7
ldc 16777215
iadd
istore 7
end local 9 12: StackMap locals:
StackMap stack:
iload 8
ldc 16777215
if_icmpge 8
13: iload 8
istore 9
start local 9 14: iload 7
istore 10
start local 10 15: invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
astore 11
start local 11 16: aload 6
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 13
goto 19
StackMap locals: io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec io.netty.buffer.ByteBuf java.lang.String java.io.File long java.util.List int int int int io.vertx.core.Future top java.util.Iterator
StackMap stack:
17: aload 13
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.function.Supplier
astore 12
start local 12 18: aload 11
aload 12
invokedynamic apply(Ljava/util/function/Supplier;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec.lambda$1(Ljava/util/function/Supplier;Ljava/lang/Void;)Lio/vertx/core/Future; (6)
(Ljava/lang/Void;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
astore 11
end local 12 19: StackMap locals:
StackMap stack:
aload 13
invokeinterface java.util.Iterator.hasNext:()Z
ifne 17
20: iload 9
ifle 22
21: aload 11
aload 0
aload 2
iload 10
iload 9
invokedynamic apply(Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec;Ljava/lang/String;II)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec.lambda$2(Ljava/lang/String;IILjava/lang/Void;)Lio/vertx/core/Future; (7)
(Ljava/lang/Void;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
astore 11
22: StackMap locals: io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec io.netty.buffer.ByteBuf java.lang.String java.io.File long java.util.List int int int int io.vertx.core.Future
StackMap stack:
aload 11
aload 0
invokedynamic handle(Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec.lambda$3(Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
23: return
end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec<TT;>;
0 24 1 payload Lio/netty/buffer/ByteBuf;
2 24 2 filename Ljava/lang/String;
3 24 3 file Ljava/io/File;
4 24 4 fileLength J
5 24 6 sendingFileInPacketContList Ljava/util/List<Ljava/util/function/Supplier<Lio/vertx/core/Future<Ljava/lang/Void;>;>;>;
6 24 7 offset I
7 24 8 remainingLen I
9 12 9 currentOffset I
14 24 9 tailLength I
15 24 10 tailOffset I
16 24 11 cont Lio/vertx/core/Future<Ljava/lang/Void;>;
18 19 12 futureSupplier Ljava/util/function/Supplier<Lio/vertx/core/Future<Ljava/lang/Void;>;>;
MethodParameters:
Name Flags
payload
private io.vertx.core.Future<java.lang.Void> sendFileInPacket(java.lang.String, int, int);
descriptor: (Ljava/lang/String;II)Lio/vertx/core/Future;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
iconst_4
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.allocateBuffer:(I)Lio/netty/buffer/ByteBuf;
astore 4
start local 4 1: aload 4
iload 3
invokevirtual io.netty.buffer.ByteBuf.writeMediumLE:(I)Lio/netty/buffer/ByteBuf;
pop
2: aload 4
aload 0
dup
getfield io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.sequenceId:I
dup_x1
iconst_1
iadd
putfield io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.sequenceId:I
invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
pop
3: aload 0
getfield io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.encoder:Lio/vertx/mysqlclient/impl/codec/MySQLEncoder;
getfield io.vertx.mysqlclient.impl.codec.MySQLEncoder.chctx:Lio/netty/channel/ChannelHandlerContext;
aload 4
invokeinterface io.netty.channel.ChannelHandlerContext.write:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
pop
4: aload 0
getfield io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.encoder:Lio/vertx/mysqlclient/impl/codec/MySQLEncoder;
getfield io.vertx.mysqlclient.impl.codec.MySQLEncoder.socketConnection:Lio/vertx/mysqlclient/impl/MySQLSocketConnection;
invokevirtual io.vertx.mysqlclient.impl.MySQLSocketConnection.socket:()Lio/vertx/core/net/impl/NetSocketInternal;
aload 1
iload 2
i2l
iload 3
i2l
invokeinterface io.vertx.core.net.impl.NetSocketInternal.sendFile:(Ljava/lang/String;JJ)Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec<TT;>;
0 5 1 filename Ljava/lang/String;
0 5 2 offset I
0 5 3 length I
1 5 4 packetHeader Lio/netty/buffer/ByteBuf;
Signature: (Ljava/lang/String;II)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
filename
offset
length
private void sendEmptyPacket();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
iconst_4
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.allocateBuffer:(I)Lio/netty/buffer/ByteBuf;
astore 1
start local 1 1: aload 1
iconst_0
invokevirtual io.netty.buffer.ByteBuf.writeMediumLE:(I)Lio/netty/buffer/ByteBuf;
pop
2: aload 1
aload 0
getfield io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.sequenceId:I
invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
pop
3: aload 0
aload 1
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.sendNonSplitPacket:(Lio/netty/buffer/ByteBuf;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec<TT;>;
1 5 1 packet Lio/netty/buffer/ByteBuf;
private io.vertx.core.Future lambda$0(java.lang.String, int);
descriptor: (Ljava/lang/String;I)Lio/vertx/core/Future;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=3
start local 0 0: aload 0
aload 1
iload 2
ldc 16777215
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.sendFileInPacket:(Ljava/lang/String;II)Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec<TT;>;
private static io.vertx.core.Future lambda$1(java.util.function.Supplier, java.lang.Void);
descriptor: (Ljava/util/function/Supplier;Ljava/lang/Void;)Lio/vertx/core/Future;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast io.vertx.core.Future
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 v Ljava/lang/Void;
private io.vertx.core.Future lambda$2(java.lang.String, int, int, java.lang.Void);
descriptor: (Ljava/lang/String;IILjava/lang/Void;)Lio/vertx/core/Future;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=5, args_size=5
start local 0 start local 4 0: aload 0
aload 1
iload 2
iload 3
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.sendFileInPacket:(Ljava/lang/String;II)Lio/vertx/core/Future;
areturn
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec<TT;>;
0 1 4 v Ljava/lang/Void;
private void lambda$3(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.mysqlclient.impl.codec.SimpleQueryCommandCodec.sendEmptyPacket:()V
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mysqlclient/impl/codec/SimpleQueryCommandCodec<TT;>;
0 1 1 v Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
}
Signature: <T:Ljava/lang/Object;>Lio/vertx/mysqlclient/impl/codec/QueryCommandBaseCodec<TT;Lio/vertx/sqlclient/impl/command/SimpleQueryCommand<TT;>;>;
SourceFile: "SimpleQueryCommandCodec.java"
InnerClasses:
public final OkPacket = io.vertx.mysqlclient.impl.protocol.Packets$OkPacket of io.vertx.mysqlclient.impl.protocol.Packets
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles