class io.vertx.sqlclient.impl.QueryExecutor<T, R extends io.vertx.sqlclient.impl.SqlResultBase<T>, L extends io.vertx.sqlclient.SqlResult<T>>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: io.vertx.sqlclient.impl.QueryExecutor
super_class: java.lang.Object
{
private final io.vertx.core.spi.metrics.ClientMetrics metrics;
descriptor: Lio/vertx/core/spi/metrics/ClientMetrics;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.sqlclient.impl.tracing.QueryTracer tracer;
descriptor: Lio/vertx/sqlclient/impl/tracing/QueryTracer;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.function.Function<T, R> factory;
descriptor: Ljava/util/function/Function;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/function/Function<TT;TR;>;
private final java.util.stream.Collector<io.vertx.sqlclient.Row, ?, T> collector;
descriptor: Ljava/util/stream/Collector;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/stream/Collector<Lio/vertx/sqlclient/Row;*TT;>;
public void <init>(io.vertx.sqlclient.impl.tracing.QueryTracer, io.vertx.core.spi.metrics.ClientMetrics, java.util.function.Function<T, R>, java.util.stream.Collector<io.vertx.sqlclient.Row, ?, T>);
descriptor: (Lio/vertx/sqlclient/impl/tracing/QueryTracer;Lio/vertx/core/spi/metrics/ClientMetrics;Ljava/util/function/Function;Ljava/util/stream/Collector;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
2: aload 0
aload 2
putfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
3: aload 0
aload 3
putfield io.vertx.sqlclient.impl.QueryExecutor.factory:Ljava/util/function/Function;
4: aload 0
aload 4
putfield io.vertx.sqlclient.impl.QueryExecutor.collector:Ljava/util/stream/Collector;
5: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/sqlclient/impl/QueryExecutor<TT;TR;TL;>;
0 6 1 tracer Lio/vertx/sqlclient/impl/tracing/QueryTracer;
0 6 2 metrics Lio/vertx/core/spi/metrics/ClientMetrics;
0 6 3 factory Ljava/util/function/Function<TT;TR;>;
0 6 4 collector Ljava/util/stream/Collector<Lio/vertx/sqlclient/Row;*TT;>;
Signature: (Lio/vertx/sqlclient/impl/tracing/QueryTracer;Lio/vertx/core/spi/metrics/ClientMetrics;Ljava/util/function/Function<TT;TR;>;Ljava/util/stream/Collector<Lio/vertx/sqlclient/Row;*TT;>;)V
MethodParameters:
Name Flags
tracer
metrics
factory
collector
io.vertx.sqlclient.impl.tracing.QueryTracer tracer();
descriptor: ()Lio/vertx/sqlclient/impl/tracing/QueryTracer;
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/QueryExecutor<TT;TR;TL;>;
io.vertx.core.spi.metrics.ClientMetrics metrics();
descriptor: ()Lio/vertx/core/spi/metrics/ClientMetrics;
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/QueryExecutor<TT;TR;TL;>;
private io.vertx.sqlclient.impl.QueryResultBuilder<T, R, L> createHandler(io.vertx.core.impl.future.PromiseInternal<L>, );
descriptor: (Lio/vertx/core/impl/future/PromiseInternal;Ljava/lang/Object;)Lio/vertx/sqlclient/impl/QueryResultBuilder;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.sqlclient.impl.QueryExecutor.createHandler:(Lio/vertx/core/impl/future/PromiseInternal;Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/sqlclient/impl/QueryResultBuilder;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/QueryExecutor<TT;TR;TL;>;
0 1 1 promise Lio/vertx/core/impl/future/PromiseInternal<TL;>;
0 1 2 payload Ljava/lang/Object;
Signature: (Lio/vertx/core/impl/future/PromiseInternal<TL;>;Ljava/lang/Object;)Lio/vertx/sqlclient/impl/QueryResultBuilder<TT;TR;TL;>;
MethodParameters:
Name Flags
promise
payload
private io.vertx.sqlclient.impl.QueryResultBuilder<T, R, L> createHandler(io.vertx.core.impl.future.PromiseInternal<L>, , );
descriptor: (Lio/vertx/core/impl/future/PromiseInternal;Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/sqlclient/impl/QueryResultBuilder;
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new io.vertx.sqlclient.impl.QueryResultBuilder
dup
aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.factory:Ljava/util/function/Function;
aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
aload 2
aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 3
aload 1
invokespecial io.vertx.sqlclient.impl.QueryResultBuilder.<init>:(Ljava/util/function/Function;Lio/vertx/sqlclient/impl/tracing/QueryTracer;Ljava/lang/Object;Lio/vertx/core/spi/metrics/ClientMetrics;Ljava/lang/Object;Lio/vertx/core/impl/future/PromiseInternal;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/QueryExecutor<TT;TR;TL;>;
0 1 1 promise Lio/vertx/core/impl/future/PromiseInternal<TL;>;
0 1 2 payload Ljava/lang/Object;
0 1 3 metric Ljava/lang/Object;
Signature: (Lio/vertx/core/impl/future/PromiseInternal<TL;>;Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/sqlclient/impl/QueryResultBuilder<TT;TR;TL;>;
MethodParameters:
Name Flags
promise
payload
metric
void executeSimpleQuery(io.vertx.sqlclient.impl.command.CommandScheduler, java.lang.String, boolean, boolean, io.vertx.core.impl.future.PromiseInternal<L>);
descriptor: (Lio/vertx/sqlclient/impl/command/CommandScheduler;Ljava/lang/String;ZZLio/vertx/core/impl/future/PromiseInternal;)V
flags: (0x0000)
Code:
stack=8, locals=10, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 5
invokeinterface io.vertx.core.impl.future.PromiseInternal.context:()Lio/vertx/core/impl/ContextInternal;
astore 6
start local 6 1: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
ifnull 4
2: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
aload 6
aload 2
invokevirtual io.vertx.sqlclient.impl.tracing.QueryTracer.sendRequest:(Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;)Ljava/lang/Object;
astore 7
start local 7 3: goto 5
end local 7 4: StackMap locals: io.vertx.core.impl.ContextInternal
StackMap stack:
aconst_null
astore 7
start local 7 5: StackMap locals: java.lang.Object
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
ifnull 9
6: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 2
aload 2
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestBegin:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
astore 8
start local 8 7: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 8
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestEnd:(Ljava/lang/Object;)V
8: goto 10
end local 8 9: StackMap locals:
StackMap stack:
aconst_null
astore 8
start local 8 10: StackMap locals: java.lang.Object
StackMap stack:
aload 0
aload 5
aload 7
aload 8
invokevirtual io.vertx.sqlclient.impl.QueryExecutor.createHandler:(Lio/vertx/core/impl/future/PromiseInternal;Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/sqlclient/impl/QueryResultBuilder;
astore 9
start local 9 11: aload 1
new io.vertx.sqlclient.impl.command.SimpleQueryCommand
dup
aload 2
iload 4
iload 3
aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.collector:Ljava/util/stream/Collector;
aload 9
invokespecial io.vertx.sqlclient.impl.command.SimpleQueryCommand.<init>:(Ljava/lang/String;ZZLjava/util/stream/Collector;Lio/vertx/sqlclient/impl/QueryResultHandler;)V
aload 9
invokeinterface io.vertx.sqlclient.impl.command.CommandScheduler.schedule:(Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;)V
12: 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 13 0 this Lio/vertx/sqlclient/impl/QueryExecutor<TT;TR;TL;>;
0 13 1 scheduler Lio/vertx/sqlclient/impl/command/CommandScheduler;
0 13 2 sql Ljava/lang/String;
0 13 3 autoCommit Z
0 13 4 singleton Z
0 13 5 promise Lio/vertx/core/impl/future/PromiseInternal<TL;>;
1 13 6 context Lio/vertx/core/impl/ContextInternal;
3 4 7 payload Ljava/lang/Object;
5 13 7 payload Ljava/lang/Object;
7 9 8 metric Ljava/lang/Object;
10 13 8 metric Ljava/lang/Object;
11 13 9 handler Lio/vertx/sqlclient/impl/QueryResultBuilder;
Signature: (Lio/vertx/sqlclient/impl/command/CommandScheduler;Ljava/lang/String;ZZLio/vertx/core/impl/future/PromiseInternal<TL;>;)V
MethodParameters:
Name Flags
scheduler
sql
autoCommit
singleton
promise
io.vertx.sqlclient.impl.QueryResultBuilder<T, R, L> executeExtendedQuery(io.vertx.sqlclient.impl.command.CommandScheduler, io.vertx.sqlclient.impl.PreparedStatement, boolean, io.vertx.sqlclient.Tuple, int, java.lang.String, boolean, io.vertx.core.impl.future.PromiseInternal<L>);
descriptor: (Lio/vertx/sqlclient/impl/command/CommandScheduler;Lio/vertx/sqlclient/impl/PreparedStatement;ZLio/vertx/sqlclient/Tuple;ILjava/lang/String;ZLio/vertx/core/impl/future/PromiseInternal;)Lio/vertx/sqlclient/impl/QueryResultBuilder;
flags: (0x0000)
Code:
stack=9, locals=15, args_size=9
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 0: aload 8
invokeinterface io.vertx.core.impl.future.PromiseInternal.context:()Lio/vertx/core/impl/ContextInternal;
astore 9
start local 9 1: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
ifnull 4
2: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
aload 9
aload 2
invokeinterface io.vertx.sqlclient.impl.PreparedStatement.sql:()Ljava/lang/String;
aload 4
invokevirtual io.vertx.sqlclient.impl.tracing.QueryTracer.sendRequest:(Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;Lio/vertx/sqlclient/Tuple;)Ljava/lang/Object;
astore 10
start local 10 3: goto 5
end local 10 4: StackMap locals: io.vertx.core.impl.ContextInternal
StackMap stack:
aconst_null
astore 10
start local 10 5: StackMap locals: java.lang.Object
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
ifnull 9
6: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 2
invokeinterface io.vertx.sqlclient.impl.PreparedStatement.sql:()Ljava/lang/String;
aload 2
invokeinterface io.vertx.sqlclient.impl.PreparedStatement.sql:()Ljava/lang/String;
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestBegin:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
astore 11
start local 11 7: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 11
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestEnd:(Ljava/lang/Object;)V
8: goto 10
end local 11 9: StackMap locals:
StackMap stack:
aconst_null
astore 11
start local 11 10: StackMap locals: java.lang.Object
StackMap stack:
aload 0
aload 8
aload 10
aload 11
invokevirtual io.vertx.sqlclient.impl.QueryExecutor.createHandler:(Lio/vertx/core/impl/future/PromiseInternal;Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/sqlclient/impl/QueryResultBuilder;
astore 12
start local 12 11: aload 2
aload 4
checkcast io.vertx.sqlclient.impl.TupleInternal
invokeinterface io.vertx.sqlclient.impl.PreparedStatement.prepare:(Lio/vertx/sqlclient/impl/TupleInternal;)Ljava/lang/String;
astore 13
start local 13 12: aload 13
ifnull 15
13: aload 12
aload 13
invokevirtual io.vertx.sqlclient.impl.QueryResultBuilder.fail:(Ljava/lang/String;)V
14: aconst_null
areturn
15: StackMap locals: io.vertx.sqlclient.impl.QueryResultBuilder java.lang.String
StackMap stack:
aload 2
invokeinterface io.vertx.sqlclient.impl.PreparedStatement.sql:()Ljava/lang/String;
16: aload 2
17: aload 4
18: iload 5
19: aload 6
20: iload 7
21: iload 3
22: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.collector:Ljava/util/stream/Collector;
23: aload 12
24: invokestatic io.vertx.sqlclient.impl.command.ExtendedQueryCommand.createQuery:(Ljava/lang/String;Lio/vertx/sqlclient/impl/PreparedStatement;Lio/vertx/sqlclient/Tuple;ILjava/lang/String;ZZLjava/util/stream/Collector;Lio/vertx/sqlclient/impl/QueryResultHandler;)Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;
astore 14
start local 14 25: aload 1
aload 14
aload 12
invokeinterface io.vertx.sqlclient.impl.command.CommandScheduler.schedule:(Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;)V
26: aload 12
areturn
end local 14 end local 13 end local 12 end local 11 end local 10 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 27 0 this Lio/vertx/sqlclient/impl/QueryExecutor<TT;TR;TL;>;
0 27 1 scheduler Lio/vertx/sqlclient/impl/command/CommandScheduler;
0 27 2 preparedStatement Lio/vertx/sqlclient/impl/PreparedStatement;
0 27 3 autoCommit Z
0 27 4 arguments Lio/vertx/sqlclient/Tuple;
0 27 5 fetch I
0 27 6 cursorId Ljava/lang/String;
0 27 7 suspended Z
0 27 8 promise Lio/vertx/core/impl/future/PromiseInternal<TL;>;
1 27 9 context Lio/vertx/core/impl/ContextInternal;
3 4 10 payload Ljava/lang/Object;
5 27 10 payload Ljava/lang/Object;
7 9 11 metric Ljava/lang/Object;
10 27 11 metric Ljava/lang/Object;
11 27 12 handler Lio/vertx/sqlclient/impl/QueryResultBuilder;
12 27 13 msg Ljava/lang/String;
25 27 14 cmd Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand<TT;>;
Signature: (Lio/vertx/sqlclient/impl/command/CommandScheduler;Lio/vertx/sqlclient/impl/PreparedStatement;ZLio/vertx/sqlclient/Tuple;ILjava/lang/String;ZLio/vertx/core/impl/future/PromiseInternal<TL;>;)Lio/vertx/sqlclient/impl/QueryResultBuilder<TT;TR;TL;>;
MethodParameters:
Name Flags
scheduler
preparedStatement
autoCommit
arguments
fetch
cursorId
suspended
promise
void executeExtendedQuery(io.vertx.sqlclient.impl.command.CommandScheduler, java.lang.String, boolean, io.vertx.sqlclient.Tuple, io.vertx.core.impl.future.PromiseInternal<L>);
descriptor: (Lio/vertx/sqlclient/impl/command/CommandScheduler;Ljava/lang/String;ZLio/vertx/sqlclient/Tuple;Lio/vertx/core/impl/future/PromiseInternal;)V
flags: (0x0000)
Code:
stack=5, locals=11, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 5
invokeinterface io.vertx.core.impl.future.PromiseInternal.context:()Lio/vertx/core/impl/ContextInternal;
astore 6
start local 6 1: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
ifnull 4
2: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
aload 6
aload 2
aload 4
invokevirtual io.vertx.sqlclient.impl.tracing.QueryTracer.sendRequest:(Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;Lio/vertx/sqlclient/Tuple;)Ljava/lang/Object;
astore 7
start local 7 3: goto 5
end local 7 4: StackMap locals: io.vertx.core.impl.ContextInternal
StackMap stack:
aconst_null
astore 7
start local 7 5: StackMap locals: java.lang.Object
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
ifnull 9
6: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 2
aload 2
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestBegin:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
astore 8
start local 8 7: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 8
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestEnd:(Ljava/lang/Object;)V
8: goto 10
end local 8 9: StackMap locals:
StackMap stack:
aconst_null
astore 8
start local 8 10: StackMap locals: java.lang.Object
StackMap stack:
aload 0
aload 5
aload 7
aload 8
invokevirtual io.vertx.sqlclient.impl.QueryExecutor.createHandler:(Lio/vertx/core/impl/future/PromiseInternal;Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/sqlclient/impl/QueryResultBuilder;
astore 9
start local 9 11: aload 0
aload 2
iload 3
aload 4
aload 9
invokevirtual io.vertx.sqlclient.impl.QueryExecutor.createExtendedQueryCommand:(Ljava/lang/String;ZLio/vertx/sqlclient/Tuple;Lio/vertx/sqlclient/impl/QueryResultBuilder;)Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;
astore 10
start local 10 12: aload 1
aload 10
aload 9
invokeinterface io.vertx.sqlclient.impl.command.CommandScheduler.schedule:(Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;)V
13: return
end local 10 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 14 0 this Lio/vertx/sqlclient/impl/QueryExecutor<TT;TR;TL;>;
0 14 1 scheduler Lio/vertx/sqlclient/impl/command/CommandScheduler;
0 14 2 sql Ljava/lang/String;
0 14 3 autoCommit Z
0 14 4 arguments Lio/vertx/sqlclient/Tuple;
0 14 5 promise Lio/vertx/core/impl/future/PromiseInternal<TL;>;
1 14 6 context Lio/vertx/core/impl/ContextInternal;
3 4 7 payload Ljava/lang/Object;
5 14 7 payload Ljava/lang/Object;
7 9 8 metric Ljava/lang/Object;
10 14 8 metric Ljava/lang/Object;
11 14 9 handler Lio/vertx/sqlclient/impl/QueryResultBuilder;
12 14 10 cmd Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;
Signature: (Lio/vertx/sqlclient/impl/command/CommandScheduler;Ljava/lang/String;ZLio/vertx/sqlclient/Tuple;Lio/vertx/core/impl/future/PromiseInternal<TL;>;)V
MethodParameters:
Name Flags
scheduler
sql
autoCommit
arguments
promise
private io.vertx.sqlclient.impl.command.ExtendedQueryCommand<T> createExtendedQueryCommand(java.lang.String, boolean, io.vertx.sqlclient.Tuple, io.vertx.sqlclient.impl.QueryResultBuilder<T, R, L>);
descriptor: (Ljava/lang/String;ZLio/vertx/sqlclient/Tuple;Lio/vertx/sqlclient/impl/QueryResultBuilder;)Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
1: aconst_null
2: aload 3
3: iload 2
4: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.collector:Ljava/util/stream/Collector;
5: aload 4
6: invokestatic io.vertx.sqlclient.impl.command.ExtendedQueryCommand.createQuery:(Ljava/lang/String;Lio/vertx/sqlclient/impl/PreparedStatement;Lio/vertx/sqlclient/Tuple;ZLjava/util/stream/Collector;Lio/vertx/sqlclient/impl/QueryResultHandler;)Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/sqlclient/impl/QueryExecutor<TT;TR;TL;>;
0 7 1 sql Ljava/lang/String;
0 7 2 autoCommit Z
0 7 3 tuple Lio/vertx/sqlclient/Tuple;
0 7 4 handler Lio/vertx/sqlclient/impl/QueryResultBuilder<TT;TR;TL;>;
Signature: (Ljava/lang/String;ZLio/vertx/sqlclient/Tuple;Lio/vertx/sqlclient/impl/QueryResultBuilder<TT;TR;TL;>;)Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand<TT;>;
MethodParameters:
Name Flags
sql
autoCommit
tuple
handler
void executeBatchQuery(io.vertx.sqlclient.impl.command.CommandScheduler, io.vertx.sqlclient.impl.PreparedStatement, boolean, java.util.List<io.vertx.sqlclient.Tuple>, io.vertx.core.impl.future.PromiseInternal<L>);
descriptor: (Lio/vertx/sqlclient/impl/command/CommandScheduler;Lio/vertx/sqlclient/impl/PreparedStatement;ZLjava/util/List;Lio/vertx/core/impl/future/PromiseInternal;)V
flags: (0x0000)
Code:
stack=6, locals=13, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 5
invokeinterface io.vertx.core.impl.future.PromiseInternal.context:()Lio/vertx/core/impl/ContextInternal;
astore 6
start local 6 1: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
ifnull 4
2: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
aload 6
aload 2
invokeinterface io.vertx.sqlclient.impl.PreparedStatement.sql:()Ljava/lang/String;
aload 4
invokevirtual io.vertx.sqlclient.impl.tracing.QueryTracer.sendRequest:(Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;Ljava/util/List;)Ljava/lang/Object;
astore 7
start local 7 3: goto 5
end local 7 4: StackMap locals: io.vertx.core.impl.ContextInternal
StackMap stack:
aconst_null
astore 7
start local 7 5: StackMap locals: java.lang.Object
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
ifnull 9
6: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 2
invokeinterface io.vertx.sqlclient.impl.PreparedStatement.sql:()Ljava/lang/String;
aload 2
invokeinterface io.vertx.sqlclient.impl.PreparedStatement.sql:()Ljava/lang/String;
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestBegin:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
astore 8
start local 8 7: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 8
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestEnd:(Ljava/lang/Object;)V
8: goto 10
end local 8 9: StackMap locals:
StackMap stack:
aconst_null
astore 8
start local 8 10: StackMap locals: java.lang.Object
StackMap stack:
aload 0
aload 5
aload 7
aload 8
invokevirtual io.vertx.sqlclient.impl.QueryExecutor.createHandler:(Lio/vertx/core/impl/future/PromiseInternal;Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/sqlclient/impl/QueryResultBuilder;
astore 9
start local 9 11: aload 4
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 11
goto 17
StackMap locals: io.vertx.sqlclient.impl.QueryExecutor io.vertx.sqlclient.impl.command.CommandScheduler io.vertx.sqlclient.impl.PreparedStatement int java.util.List io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.ContextInternal java.lang.Object java.lang.Object io.vertx.sqlclient.impl.QueryResultBuilder top java.util.Iterator
StackMap stack:
12: aload 11
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.Tuple
astore 10
start local 10 13: aload 2
aload 10
checkcast io.vertx.sqlclient.impl.TupleInternal
invokeinterface io.vertx.sqlclient.impl.PreparedStatement.prepare:(Lio/vertx/sqlclient/impl/TupleInternal;)Ljava/lang/String;
astore 12
start local 12 14: aload 12
ifnull 17
15: aload 9
aload 12
invokevirtual io.vertx.sqlclient.impl.QueryResultBuilder.fail:(Ljava/lang/String;)V
16: return
end local 12 end local 10 17: StackMap locals:
StackMap stack:
aload 11
invokeinterface java.util.Iterator.hasNext:()Z
ifne 12
18: aload 2
invokeinterface io.vertx.sqlclient.impl.PreparedStatement.sql:()Ljava/lang/String;
aload 2
aload 4
iload 3
aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.collector:Ljava/util/stream/Collector;
aload 9
invokestatic io.vertx.sqlclient.impl.command.ExtendedQueryCommand.createBatch:(Ljava/lang/String;Lio/vertx/sqlclient/impl/PreparedStatement;Ljava/util/List;ZLjava/util/stream/Collector;Lio/vertx/sqlclient/impl/QueryResultHandler;)Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;
astore 10
start local 10 19: aload 1
aload 10
aload 9
invokeinterface io.vertx.sqlclient.impl.command.CommandScheduler.schedule:(Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;)V
20: return
end local 10 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 21 0 this Lio/vertx/sqlclient/impl/QueryExecutor<TT;TR;TL;>;
0 21 1 scheduler Lio/vertx/sqlclient/impl/command/CommandScheduler;
0 21 2 preparedStatement Lio/vertx/sqlclient/impl/PreparedStatement;
0 21 3 autoCommit Z
0 21 4 batch Ljava/util/List<Lio/vertx/sqlclient/Tuple;>;
0 21 5 promise Lio/vertx/core/impl/future/PromiseInternal<TL;>;
1 21 6 context Lio/vertx/core/impl/ContextInternal;
3 4 7 payload Ljava/lang/Object;
5 21 7 payload Ljava/lang/Object;
7 9 8 metric Ljava/lang/Object;
10 21 8 metric Ljava/lang/Object;
11 21 9 handler Lio/vertx/sqlclient/impl/QueryResultBuilder;
13 17 10 args Lio/vertx/sqlclient/Tuple;
14 17 12 msg Ljava/lang/String;
19 21 10 cmd Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand<TT;>;
Signature: (Lio/vertx/sqlclient/impl/command/CommandScheduler;Lio/vertx/sqlclient/impl/PreparedStatement;ZLjava/util/List<Lio/vertx/sqlclient/Tuple;>;Lio/vertx/core/impl/future/PromiseInternal<TL;>;)V
MethodParameters:
Name Flags
scheduler
preparedStatement
autoCommit
batch
promise
void executeBatchQuery(io.vertx.sqlclient.impl.command.CommandScheduler, java.lang.String, boolean, java.util.List<io.vertx.sqlclient.Tuple>, io.vertx.core.impl.future.PromiseInternal<L>);
descriptor: (Lio/vertx/sqlclient/impl/command/CommandScheduler;Ljava/lang/String;ZLjava/util/List;Lio/vertx/core/impl/future/PromiseInternal;)V
flags: (0x0000)
Code:
stack=5, locals=11, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 5
invokeinterface io.vertx.core.impl.future.PromiseInternal.context:()Lio/vertx/core/impl/ContextInternal;
astore 6
start local 6 1: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
ifnull 4
2: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
aload 6
aload 2
aload 4
invokevirtual io.vertx.sqlclient.impl.tracing.QueryTracer.sendRequest:(Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;Ljava/util/List;)Ljava/lang/Object;
astore 7
start local 7 3: goto 5
end local 7 4: StackMap locals: io.vertx.core.impl.ContextInternal
StackMap stack:
aconst_null
astore 7
start local 7 5: StackMap locals: java.lang.Object
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
ifnull 9
6: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 2
aload 2
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestBegin:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
astore 8
start local 8 7: aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 8
invokeinterface io.vertx.core.spi.metrics.ClientMetrics.requestEnd:(Ljava/lang/Object;)V
8: goto 10
end local 8 9: StackMap locals:
StackMap stack:
aconst_null
astore 8
start local 8 10: StackMap locals: java.lang.Object
StackMap stack:
aload 0
aload 5
aload 7
aload 8
invokevirtual io.vertx.sqlclient.impl.QueryExecutor.createHandler:(Lio/vertx/core/impl/future/PromiseInternal;Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/sqlclient/impl/QueryResultBuilder;
astore 9
start local 9 11: aload 0
aload 2
iload 3
aload 4
aload 9
invokevirtual io.vertx.sqlclient.impl.QueryExecutor.createBatchQueryCommand:(Ljava/lang/String;ZLjava/util/List;Lio/vertx/sqlclient/impl/QueryResultBuilder;)Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;
astore 10
start local 10 12: aload 1
aload 10
aload 9
invokeinterface io.vertx.sqlclient.impl.command.CommandScheduler.schedule:(Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;)V
13: return
end local 10 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 14 0 this Lio/vertx/sqlclient/impl/QueryExecutor<TT;TR;TL;>;
0 14 1 scheduler Lio/vertx/sqlclient/impl/command/CommandScheduler;
0 14 2 sql Ljava/lang/String;
0 14 3 autoCommit Z
0 14 4 batch Ljava/util/List<Lio/vertx/sqlclient/Tuple;>;
0 14 5 promise Lio/vertx/core/impl/future/PromiseInternal<TL;>;
1 14 6 context Lio/vertx/core/impl/ContextInternal;
3 4 7 payload Ljava/lang/Object;
5 14 7 payload Ljava/lang/Object;
7 9 8 metric Ljava/lang/Object;
10 14 8 metric Ljava/lang/Object;
11 14 9 handler Lio/vertx/sqlclient/impl/QueryResultBuilder;
12 14 10 cmd Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand<TT;>;
Signature: (Lio/vertx/sqlclient/impl/command/CommandScheduler;Ljava/lang/String;ZLjava/util/List<Lio/vertx/sqlclient/Tuple;>;Lio/vertx/core/impl/future/PromiseInternal<TL;>;)V
MethodParameters:
Name Flags
scheduler
sql
autoCommit
batch
promise
private io.vertx.sqlclient.impl.command.ExtendedQueryCommand<T> createBatchQueryCommand(java.lang.String, boolean, java.util.List<io.vertx.sqlclient.Tuple>, io.vertx.sqlclient.impl.QueryResultBuilder<T, R, L>);
descriptor: (Ljava/lang/String;ZLjava/util/List;Lio/vertx/sqlclient/impl/QueryResultBuilder;)Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
aconst_null
aload 3
iload 2
aload 0
getfield io.vertx.sqlclient.impl.QueryExecutor.collector:Ljava/util/stream/Collector;
aload 4
invokestatic io.vertx.sqlclient.impl.command.ExtendedQueryCommand.createBatch:(Ljava/lang/String;Lio/vertx/sqlclient/impl/PreparedStatement;Ljava/util/List;ZLjava/util/stream/Collector;Lio/vertx/sqlclient/impl/QueryResultHandler;)Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/QueryExecutor<TT;TR;TL;>;
0 1 1 sql Ljava/lang/String;
0 1 2 autoCommit Z
0 1 3 argsList Ljava/util/List<Lio/vertx/sqlclient/Tuple;>;
0 1 4 handler Lio/vertx/sqlclient/impl/QueryResultBuilder<TT;TR;TL;>;
Signature: (Ljava/lang/String;ZLjava/util/List<Lio/vertx/sqlclient/Tuple;>;Lio/vertx/sqlclient/impl/QueryResultBuilder<TT;TR;TL;>;)Lio/vertx/sqlclient/impl/command/ExtendedQueryCommand<TT;>;
MethodParameters:
Name Flags
sql
autoCommit
argsList
handler
}
Signature: <T:Ljava/lang/Object;R:Lio/vertx/sqlclient/impl/SqlResultBase<TT;>;L::Lio/vertx/sqlclient/SqlResult<TT;>;>Ljava/lang/Object;
SourceFile: "QueryExecutor.java"