class io.vertx.sqlclient.impl.PreparedStatementImpl implements io.vertx.sqlclient.PreparedStatement
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: io.vertx.sqlclient.impl.PreparedStatementImpl
super_class: java.lang.Object
{
private final io.vertx.sqlclient.impl.Connection conn;
descriptor: Lio/vertx/sqlclient/impl/Connection;
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 io.vertx.core.spi.metrics.ClientMetrics metrics;
descriptor: Lio/vertx/core/spi/metrics/ClientMetrics;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.impl.ContextInternal context;
descriptor: Lio/vertx/core/impl/ContextInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.String sql;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.vertx.core.Promise<io.vertx.sqlclient.impl.PreparedStatement> promise;
descriptor: Lio/vertx/core/Promise;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Promise<Lio/vertx/sqlclient/impl/PreparedStatement;>;
private io.vertx.core.Future<io.vertx.sqlclient.impl.PreparedStatement> future;
descriptor: Lio/vertx/core/Future;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Future<Lio/vertx/sqlclient/impl/PreparedStatement;>;
private final boolean autoCommit;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicBoolean closed;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
static io.vertx.sqlclient.PreparedStatement create(io.vertx.sqlclient.impl.Connection, io.vertx.sqlclient.impl.tracing.QueryTracer, io.vertx.core.spi.metrics.ClientMetrics, io.vertx.core.impl.ContextInternal, io.vertx.sqlclient.impl.PreparedStatement, boolean);
descriptor: (Lio/vertx/sqlclient/impl/Connection;Lio/vertx/sqlclient/impl/tracing/QueryTracer;Lio/vertx/core/spi/metrics/ClientMetrics;Lio/vertx/core/impl/ContextInternal;Lio/vertx/sqlclient/impl/PreparedStatement;Z)Lio/vertx/sqlclient/PreparedStatement;
flags: (0x0008) ACC_STATIC
Code:
stack=8, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: new io.vertx.sqlclient.impl.PreparedStatementImpl
dup
aload 0
aload 1
aload 2
aload 3
aload 4
iload 5
invokespecial io.vertx.sqlclient.impl.PreparedStatementImpl.<init>:(Lio/vertx/sqlclient/impl/Connection;Lio/vertx/sqlclient/impl/tracing/QueryTracer;Lio/vertx/core/spi/metrics/ClientMetrics;Lio/vertx/core/impl/ContextInternal;Lio/vertx/sqlclient/impl/PreparedStatement;Z)V
areturn
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 1 0 conn Lio/vertx/sqlclient/impl/Connection;
0 1 1 tracer Lio/vertx/sqlclient/impl/tracing/QueryTracer;
0 1 2 metrics Lio/vertx/core/spi/metrics/ClientMetrics;
0 1 3 context Lio/vertx/core/impl/ContextInternal;
0 1 4 ps Lio/vertx/sqlclient/impl/PreparedStatement;
0 1 5 autoCommit Z
MethodParameters:
Name Flags
conn
tracer
metrics
context
ps
autoCommit
static io.vertx.sqlclient.PreparedStatement create(io.vertx.sqlclient.impl.Connection, io.vertx.sqlclient.impl.tracing.QueryTracer, io.vertx.core.spi.metrics.ClientMetrics, io.vertx.core.impl.ContextInternal, java.lang.String, boolean);
descriptor: (Lio/vertx/sqlclient/impl/Connection;Lio/vertx/sqlclient/impl/tracing/QueryTracer;Lio/vertx/core/spi/metrics/ClientMetrics;Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;Z)Lio/vertx/sqlclient/PreparedStatement;
flags: (0x0008) ACC_STATIC
Code:
stack=8, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: new io.vertx.sqlclient.impl.PreparedStatementImpl
dup
aload 0
aload 1
aload 2
aload 3
aload 4
iload 5
invokespecial io.vertx.sqlclient.impl.PreparedStatementImpl.<init>:(Lio/vertx/sqlclient/impl/Connection;Lio/vertx/sqlclient/impl/tracing/QueryTracer;Lio/vertx/core/spi/metrics/ClientMetrics;Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;Z)V
areturn
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 1 0 conn Lio/vertx/sqlclient/impl/Connection;
0 1 1 tracer Lio/vertx/sqlclient/impl/tracing/QueryTracer;
0 1 2 metrics Lio/vertx/core/spi/metrics/ClientMetrics;
0 1 3 context Lio/vertx/core/impl/ContextInternal;
0 1 4 sql Ljava/lang/String;
0 1 5 autoCommit Z
MethodParameters:
Name Flags
conn
tracer
metrics
context
sql
autoCommit
private void <init>(io.vertx.sqlclient.impl.Connection, io.vertx.sqlclient.impl.tracing.QueryTracer, io.vertx.core.spi.metrics.ClientMetrics, io.vertx.core.impl.ContextInternal, io.vertx.sqlclient.impl.PreparedStatement, boolean);
descriptor: (Lio/vertx/sqlclient/impl/Connection;Lio/vertx/sqlclient/impl/tracing/QueryTracer;Lio/vertx/core/spi/metrics/ClientMetrics;Lio/vertx/core/impl/ContextInternal;Lio/vertx/sqlclient/impl/PreparedStatement;Z)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
2: aload 0
aload 1
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.conn:Lio/vertx/sqlclient/impl/Connection;
3: aload 0
aload 2
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
4: aload 0
aload 3
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
5: aload 0
aload 4
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.context:Lio/vertx/core/impl/ContextInternal;
6: aload 0
aconst_null
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.sql:Ljava/lang/String;
7: aload 0
aconst_null
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.promise:Lio/vertx/core/Promise;
8: aload 0
aload 5
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.future:Lio/vertx/core/Future;
9: aload 0
iload 6
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.autoCommit:Z
10: return
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 11 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 11 1 conn Lio/vertx/sqlclient/impl/Connection;
0 11 2 tracer Lio/vertx/sqlclient/impl/tracing/QueryTracer;
0 11 3 metrics Lio/vertx/core/spi/metrics/ClientMetrics;
0 11 4 context Lio/vertx/core/impl/ContextInternal;
0 11 5 ps Lio/vertx/sqlclient/impl/PreparedStatement;
0 11 6 autoCommit Z
MethodParameters:
Name Flags
conn
tracer
metrics
context
ps
autoCommit
private void <init>(io.vertx.sqlclient.impl.Connection, io.vertx.sqlclient.impl.tracing.QueryTracer, io.vertx.core.spi.metrics.ClientMetrics, io.vertx.core.impl.ContextInternal, java.lang.String, boolean);
descriptor: (Lio/vertx/sqlclient/impl/Connection;Lio/vertx/sqlclient/impl/tracing/QueryTracer;Lio/vertx/core/spi/metrics/ClientMetrics;Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;Z)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
2: aload 0
aload 1
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.conn:Lio/vertx/sqlclient/impl/Connection;
3: aload 0
aload 2
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
4: aload 0
aload 3
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
5: aload 0
aload 4
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.context:Lio/vertx/core/impl/ContextInternal;
6: aload 0
aload 5
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.sql:Ljava/lang/String;
7: aload 0
invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.promise:Lio/vertx/core/Promise;
8: aload 0
iload 6
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.autoCommit:Z
9: return
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 10 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 10 1 conn Lio/vertx/sqlclient/impl/Connection;
0 10 2 tracer Lio/vertx/sqlclient/impl/tracing/QueryTracer;
0 10 3 metrics Lio/vertx/core/spi/metrics/ClientMetrics;
0 10 4 context Lio/vertx/core/impl/ContextInternal;
0 10 5 sql Ljava/lang/String;
0 10 6 autoCommit Z
MethodParameters:
Name Flags
conn
tracer
metrics
context
sql
autoCommit
public io.vertx.sqlclient.PreparedQuery<io.vertx.sqlclient.RowSet<io.vertx.sqlclient.Row>> query();
descriptor: ()Lio/vertx/sqlclient/PreparedQuery;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=2, args_size=1
start local 0 0: new io.vertx.sqlclient.impl.QueryExecutor
dup
1: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
2: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
3: getstatic io.vertx.sqlclient.impl.RowSetImpl.FACTORY:Ljava/util/function/Function;
4: getstatic io.vertx.sqlclient.impl.RowSetImpl.COLLECTOR:Ljava/util/stream/Collector;
5: invokespecial io.vertx.sqlclient.impl.QueryExecutor.<init>:(Lio/vertx/sqlclient/impl/tracing/QueryTracer;Lio/vertx/core/spi/metrics/ClientMetrics;Ljava/util/function/Function;Ljava/util/stream/Collector;)V
astore 1
start local 1 6: new io.vertx.sqlclient.impl.PreparedStatementImpl$PreparedStatementQuery
dup
aload 0
aload 1
invokespecial io.vertx.sqlclient.impl.PreparedStatementImpl$PreparedStatementQuery.<init>:(Lio/vertx/sqlclient/impl/PreparedStatementImpl;Lio/vertx/sqlclient/impl/QueryExecutor;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
6 7 1 builder Lio/vertx/sqlclient/impl/QueryExecutor<Lio/vertx/sqlclient/RowSet<Lio/vertx/sqlclient/Row;>;Lio/vertx/sqlclient/impl/RowSetImpl<Lio/vertx/sqlclient/Row;>;Lio/vertx/sqlclient/RowSet<Lio/vertx/sqlclient/Row;>;>;
Signature: ()Lio/vertx/sqlclient/PreparedQuery<Lio/vertx/sqlclient/RowSet<Lio/vertx/sqlclient/Row;>;>;
void withPreparedStatement(io.vertx.sqlclient.Tuple, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.sqlclient.impl.PreparedStatement>>);
descriptor: (Lio/vertx/sqlclient/Tuple;Lio/vertx/core/Handler;)V
flags: (0x0000)
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.context:Lio/vertx/core/impl/ContextInternal;
invokestatic io.vertx.core.Vertx.currentContext:()Lio/vertx/core/Context;
if_acmpne 7
1: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.future:Lio/vertx/core/Future;
ifnonnull 5
2: new io.vertx.sqlclient.impl.command.PrepareStatementCommand
dup
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.sql:Ljava/lang/String;
iconst_1
aload 1
invokeinterface io.vertx.sqlclient.Tuple.types:()Ljava/util/List;
invokespecial io.vertx.sqlclient.impl.command.PrepareStatementCommand.<init>:(Ljava/lang/String;ZLjava/util/List;)V
astore 3
start local 3 3: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.conn:Lio/vertx/sqlclient/impl/Connection;
aload 3
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.promise:Lio/vertx/core/Promise;
invokeinterface io.vertx.sqlclient.impl.Connection.schedule:(Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;)V
4: aload 0
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.promise:Lio/vertx/core/Promise;
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.future:Lio/vertx/core/Future;
end local 3 5: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.future:Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
6: goto 8
7: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.context:Lio/vertx/core/impl/ContextInternal;
aload 0
aload 1
aload 2
invokedynamic handle(Lio/vertx/sqlclient/impl/PreparedStatementImpl;Lio/vertx/sqlclient/Tuple;Lio/vertx/core/Handler;)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/sqlclient/impl/PreparedStatementImpl.lambda$0(Lio/vertx/sqlclient/Tuple;Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.runOnContext:(Lio/vertx/core/Handler;)V
8: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 9 1 args Lio/vertx/sqlclient/Tuple;
0 9 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/PreparedStatement;>;>;
3 5 3 prepare Lio/vertx/sqlclient/impl/command/PrepareStatementCommand;
Signature: (Lio/vertx/sqlclient/Tuple;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/PreparedStatement;>;>;)V
MethodParameters:
Name Flags
args
handler
<R, F extends io.vertx.sqlclient.SqlResult<R>> void execute(io.vertx.sqlclient.Tuple, int, java.lang.String, boolean, io.vertx.sqlclient.impl.QueryExecutor<R, ?, F>, io.vertx.core.impl.future.PromiseInternal<F>);
descriptor: (Lio/vertx/sqlclient/Tuple;ILjava/lang/String;ZLio/vertx/sqlclient/impl/QueryExecutor;Lio/vertx/core/impl/future/PromiseInternal;)V
flags: (0x0000)
Code:
stack=9, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
aload 1
aload 0
aload 5
aload 1
iload 2
aload 3
iload 4
aload 6
invokedynamic handle(Lio/vertx/sqlclient/impl/PreparedStatementImpl;Lio/vertx/sqlclient/impl/QueryExecutor;Lio/vertx/sqlclient/Tuple;ILjava/lang/String;ZLio/vertx/core/impl/future/PromiseInternal;)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/sqlclient/impl/PreparedStatementImpl.lambda$1(Lio/vertx/sqlclient/impl/QueryExecutor;Lio/vertx/sqlclient/Tuple;ILjava/lang/String;ZLio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.sqlclient.impl.PreparedStatementImpl.withPreparedStatement:(Lio/vertx/sqlclient/Tuple;Lio/vertx/core/Handler;)V
1: return
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 2 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 2 1 args Lio/vertx/sqlclient/Tuple;
0 2 2 fetch I
0 2 3 cursorId Ljava/lang/String;
0 2 4 suspended Z
0 2 5 builder Lio/vertx/sqlclient/impl/QueryExecutor<TR;*TF;>;
0 2 6 p Lio/vertx/core/impl/future/PromiseInternal<TF;>;
Signature: <R:Ljava/lang/Object;F::Lio/vertx/sqlclient/SqlResult<TR;>;>(Lio/vertx/sqlclient/Tuple;ILjava/lang/String;ZLio/vertx/sqlclient/impl/QueryExecutor<TR;*TF;>;Lio/vertx/core/impl/future/PromiseInternal<TF;>;)V
MethodParameters:
Name Flags
args
fetch
cursorId
suspended
builder
p
<R, F extends io.vertx.sqlclient.SqlResult<R>> void executeBatch(java.util.List<io.vertx.sqlclient.Tuple>, io.vertx.sqlclient.impl.QueryExecutor<R, ?, F>, io.vertx.core.impl.future.PromiseInternal<F>);
descriptor: (Ljava/util/List;Lio/vertx/sqlclient/impl/QueryExecutor;Lio/vertx/core/impl/future/PromiseInternal;)V
flags: (0x0000)
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast io.vertx.sqlclient.Tuple
aload 0
aload 2
aload 1
aload 3
invokedynamic handle(Lio/vertx/sqlclient/impl/PreparedStatementImpl;Lio/vertx/sqlclient/impl/QueryExecutor;Ljava/util/List;Lio/vertx/core/impl/future/PromiseInternal;)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/sqlclient/impl/PreparedStatementImpl.lambda$2(Lio/vertx/sqlclient/impl/QueryExecutor;Ljava/util/List;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.sqlclient.impl.PreparedStatementImpl.withPreparedStatement:(Lio/vertx/sqlclient/Tuple;Lio/vertx/core/Handler;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 2 1 argsList Ljava/util/List<Lio/vertx/sqlclient/Tuple;>;
0 2 2 builder Lio/vertx/sqlclient/impl/QueryExecutor<TR;*TF;>;
0 2 3 p Lio/vertx/core/impl/future/PromiseInternal<TF;>;
Signature: <R:Ljava/lang/Object;F::Lio/vertx/sqlclient/SqlResult<TR;>;>(Ljava/util/List<Lio/vertx/sqlclient/Tuple;>;Lio/vertx/sqlclient/impl/QueryExecutor<TR;*TF;>;Lio/vertx/core/impl/future/PromiseInternal<TF;>;)V
MethodParameters:
Name Flags
argsList
builder
p
public io.vertx.sqlclient.Cursor cursor(io.vertx.sqlclient.Tuple);
descriptor: (Lio/vertx/sqlclient/Tuple;)Lio/vertx/sqlclient/Cursor;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
checkcast io.vertx.sqlclient.impl.TupleInternal
invokevirtual io.vertx.sqlclient.impl.PreparedStatementImpl.cursor:(Lio/vertx/sqlclient/impl/TupleInternal;)Lio/vertx/sqlclient/Cursor;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 1 1 args Lio/vertx/sqlclient/Tuple;
MethodParameters:
Name Flags
args
private io.vertx.sqlclient.Cursor cursor(io.vertx.sqlclient.impl.TupleInternal);
descriptor: (Lio/vertx/sqlclient/impl/TupleInternal;)Lio/vertx/sqlclient/Cursor;
flags: (0x0002) ACC_PRIVATE
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: new io.vertx.sqlclient.impl.CursorImpl
dup
aload 0
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.conn:Lio/vertx/sqlclient/impl/Connection;
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.tracer:Lio/vertx/sqlclient/impl/tracing/QueryTracer;
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.metrics:Lio/vertx/core/spi/metrics/ClientMetrics;
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.context:Lio/vertx/core/impl/ContextInternal;
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.autoCommit:Z
aload 1
invokespecial io.vertx.sqlclient.impl.CursorImpl.<init>:(Lio/vertx/sqlclient/impl/PreparedStatementImpl;Lio/vertx/sqlclient/impl/Connection;Lio/vertx/sqlclient/impl/tracing/QueryTracer;Lio/vertx/core/spi/metrics/ClientMetrics;Lio/vertx/core/impl/ContextInternal;ZLio/vertx/sqlclient/impl/TupleInternal;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 1 1 args Lio/vertx/sqlclient/impl/TupleInternal;
MethodParameters:
Name Flags
args
public io.vertx.core.Future<java.lang.Void> close();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifeq 11
1: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 1
start local 1 2: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.promise:Lio/vertx/core/Promise;
ifnonnull 6
3: new io.vertx.sqlclient.impl.command.CloseStatementCommand
dup
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.future:Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.result:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.impl.PreparedStatement
invokespecial io.vertx.sqlclient.impl.command.CloseStatementCommand.<init>:(Lio/vertx/sqlclient/impl/PreparedStatement;)V
astore 2
start local 2 4: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.conn:Lio/vertx/sqlclient/impl/Connection;
aload 2
aload 1
invokeinterface io.vertx.sqlclient.impl.Connection.schedule:(Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;)V
end local 2 5: goto 10
6: StackMap locals: io.vertx.core.Promise
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.future:Lio/vertx/core/Future;
ifnonnull 9
7: aload 0
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.promise:Lio/vertx/core/Promise;
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
putfield io.vertx.sqlclient.impl.PreparedStatementImpl.future:Lio/vertx/core/Future;
8: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.promise:Lio/vertx/core/Promise;
ldc "Closed"
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/String;)V
9: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.future:Lio/vertx/core/Future;
aload 0
aload 1
invokedynamic handle(Lio/vertx/sqlclient/impl/PreparedStatementImpl;Lio/vertx/core/Promise;)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/sqlclient/impl/PreparedStatementImpl.lambda$3(Lio/vertx/core/Promise;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
10: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 1 11: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.context:Lio/vertx/core/impl/ContextInternal;
ldc "Already closed"
invokeinterface io.vertx.core.impl.ContextInternal.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
2 11 1 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
4 5 2 cmd Lio/vertx/sqlclient/impl/command/CloseStatementCommand;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public io.vertx.sqlclient.RowStream<io.vertx.sqlclient.Row> createStream(int, io.vertx.sqlclient.Tuple);
descriptor: (ILio/vertx/sqlclient/Tuple;)Lio/vertx/sqlclient/RowStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new io.vertx.sqlclient.impl.RowStreamImpl
dup
aload 0
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.context:Lio/vertx/core/impl/ContextInternal;
iload 1
aload 2
invokespecial io.vertx.sqlclient.impl.RowStreamImpl.<init>:(Lio/vertx/sqlclient/impl/PreparedStatementImpl;Lio/vertx/core/impl/ContextInternal;ILio/vertx/sqlclient/Tuple;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 1 1 fetch I
0 1 2 args Lio/vertx/sqlclient/Tuple;
Signature: (ILio/vertx/sqlclient/Tuple;)Lio/vertx/sqlclient/RowStream<Lio/vertx/sqlclient/Row;>;
MethodParameters:
Name Flags
fetch
args
public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.sqlclient.impl.PreparedStatementImpl.close:()Lio/vertx/core/Future;
astore 2
start local 2 1: aload 1
ifnull 3
2: aload 2
aload 1
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: StackMap locals: io.vertx.core.Future
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 4 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 4 2 fut Lio/vertx/core/Future<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
completionHandler
void closeCursor(java.lang.String, io.vertx.core.Promise<java.lang.Void>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x0000)
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.future:Lio/vertx/core/Future;
aload 0
aload 1
aload 2
invokedynamic handle(Lio/vertx/sqlclient/impl/PreparedStatementImpl;Ljava/lang/String;Lio/vertx/core/Promise;)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/sqlclient/impl/PreparedStatementImpl.lambda$4(Ljava/lang/String;Lio/vertx/core/Promise;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
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 2 1 cursorId Ljava/lang/String;
0 2 2 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
cursorId
promise
private void lambda$0(io.vertx.sqlclient.Tuple, io.vertx.core.Handler, java.lang.Void);
descriptor: (Lio/vertx/sqlclient/Tuple;Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.sqlclient.impl.PreparedStatementImpl.withPreparedStatement:(Lio/vertx/sqlclient/Tuple;Lio/vertx/core/Handler;)V
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 1 3 v Ljava/lang/Void;
private void lambda$1(io.vertx.sqlclient.impl.QueryExecutor, io.vertx.sqlclient.Tuple, int, java.lang.String, boolean, io.vertx.core.impl.future.PromiseInternal, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/sqlclient/impl/QueryExecutor;Lio/vertx/sqlclient/Tuple;ILjava/lang/String;ZLio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=9, locals=8, args_size=8
start local 0 start local 7 0: aload 7
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 12
1: aload 1
2: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.conn:Lio/vertx/sqlclient/impl/Connection;
3: aload 7
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.impl.PreparedStatement
4: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.autoCommit:Z
5: aload 2
6: iload 3
7: aload 4
8: iload 5
9: aload 6
10: invokevirtual io.vertx.sqlclient.impl.QueryExecutor.executeExtendedQuery:(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;
pop
11: goto 13
12: StackMap locals:
StackMap stack:
aload 6
aload 7
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.impl.future.PromiseInternal.fail:(Ljava/lang/Throwable;)V
13: StackMap locals:
StackMap stack:
return
end local 7 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 14 7 ar Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/PreparedStatement;>;
private void lambda$2(io.vertx.sqlclient.impl.QueryExecutor, java.util.List, io.vertx.core.impl.future.PromiseInternal, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/sqlclient/impl/QueryExecutor;Ljava/util/List;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 4 0: aload 4
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: aload 1
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.conn:Lio/vertx/sqlclient/impl/Connection;
aload 4
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.impl.PreparedStatement
aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.autoCommit:Z
aload 2
aload 3
invokevirtual io.vertx.sqlclient.impl.QueryExecutor.executeBatchQuery:(Lio/vertx/sqlclient/impl/command/CommandScheduler;Lio/vertx/sqlclient/impl/PreparedStatement;ZLjava/util/List;Lio/vertx/core/impl/future/PromiseInternal;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 3
aload 4
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.impl.future.PromiseInternal.fail:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 5 4 ar Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/PreparedStatement;>;
private void lambda$3(io.vertx.core.Promise, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: new io.vertx.sqlclient.impl.command.CloseStatementCommand
dup
aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.impl.PreparedStatement
invokespecial io.vertx.sqlclient.impl.command.CloseStatementCommand.<init>:(Lio/vertx/sqlclient/impl/PreparedStatement;)V
astore 3
start local 3 2: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.conn:Lio/vertx/sqlclient/impl/Connection;
aload 3
aload 1
invokeinterface io.vertx.sqlclient.impl.Connection.schedule:(Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;)V
end local 3 3: goto 5
4: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.vertx.core.Promise.complete:()V
5: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 6 2 ar Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/PreparedStatement;>;
2 3 3 cmd Lio/vertx/sqlclient/impl/command/CloseStatementCommand;
private void lambda$4(java.lang.String, io.vertx.core.Promise, io.vertx.core.AsyncResult);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: new io.vertx.sqlclient.impl.command.CloseCursorCommand
dup
aload 1
aload 3
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.sqlclient.impl.PreparedStatement
invokespecial io.vertx.sqlclient.impl.command.CloseCursorCommand.<init>:(Ljava/lang/String;Lio/vertx/sqlclient/impl/PreparedStatement;)V
astore 4
start local 4 2: aload 0
getfield io.vertx.sqlclient.impl.PreparedStatementImpl.conn:Lio/vertx/sqlclient/impl/Connection;
aload 4
aload 2
invokeinterface io.vertx.sqlclient.impl.Connection.schedule:(Lio/vertx/sqlclient/impl/command/CommandBase;Lio/vertx/core/Promise;)V
end local 4 3: goto 5
4: StackMap locals:
StackMap stack:
aload 2
aload 3
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
5: StackMap locals:
StackMap stack:
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/sqlclient/impl/PreparedStatementImpl;
0 6 3 ar Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/impl/PreparedStatement;>;
2 3 4 cmd Lio/vertx/sqlclient/impl/command/CloseCursorCommand;
}
SourceFile: "PreparedStatementImpl.java"
NestMembers:
io.vertx.sqlclient.impl.PreparedStatementImpl$PreparedStatementQuery
InnerClasses:
private PreparedStatementQuery = io.vertx.sqlclient.impl.PreparedStatementImpl$PreparedStatementQuery of io.vertx.sqlclient.impl.PreparedStatementImpl
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles