public abstract class io.vertx.ext.asyncsql.impl.BaseSQLClient
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: io.vertx.ext.asyncsql.impl.BaseSQLClient
super_class: java.lang.Object
{
protected final io.vertx.core.logging.Logger log;
descriptor: Lio/vertx/core/logging/Logger;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
protected final io.vertx.core.Vertx vertx;
descriptor: Lio/vertx/core/Vertx;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
protected final io.vertx.core.json.JsonObject globalConfig;
descriptor: Lio/vertx/core/json/JsonObject;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
public void <init>(io.vertx.core.Vertx, io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/core/json/JsonObject;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 0
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putfield io.vertx.ext.asyncsql.impl.BaseSQLClient.log:Lio/vertx/core/logging/Logger;
2: aload 0
aload 1
putfield io.vertx.ext.asyncsql.impl.BaseSQLClient.vertx:Lio/vertx/core/Vertx;
3: aload 0
aload 2
putfield io.vertx.ext.asyncsql.impl.BaseSQLClient.globalConfig:Lio/vertx/core/json/JsonObject;
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/ext/asyncsql/impl/BaseSQLClient;
0 5 1 vertx Lio/vertx/core/Vertx;
0 5 2 globalConfig Lio/vertx/core/json/JsonObject;
MethodParameters:
Name Flags
vertx
globalConfig
protected abstract io.vertx.ext.asyncsql.impl.pool.AsyncConnectionPool pool();
descriptor: ()Lio/vertx/ext/asyncsql/impl/pool/AsyncConnectionPool;
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
protected abstract io.vertx.ext.sql.SQLConnection createFromPool(com.github.mauricio.async.db.Connection, io.vertx.ext.asyncsql.impl.pool.AsyncConnectionPool, scala.concurrent.ExecutionContext);
descriptor: (Lcom/github/mauricio/async/db/Connection;Lio/vertx/ext/asyncsql/impl/pool/AsyncConnectionPool;Lscala/concurrent/ExecutionContext;)Lio/vertx/ext/sql/SQLConnection;
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
MethodParameters:
Name Flags
conn
pool
ec
public void getConnection(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.sql.SQLConnection>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.ext.asyncsql.impl.BaseSQLClient.pool:()Lio/vertx/ext/asyncsql/impl/pool/AsyncConnectionPool;
aload 0
aload 1
invokedynamic handle(Lio/vertx/ext/asyncsql/impl/BaseSQLClient;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/ext/asyncsql/impl/BaseSQLClient.lambda$0(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.ext.asyncsql.impl.pool.AsyncConnectionPool.take:(Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/asyncsql/impl/BaseSQLClient;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/sql/SQLConnection;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/sql/SQLConnection;>;>;)V
MethodParameters:
Name Flags
handler
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=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.asyncsql.impl.BaseSQLClient.log:Lio/vertx/core/logging/Logger;
new java.lang.StringBuilder
dup
ldc "Stopping async SQL client "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual io.vertx.core.logging.Logger.info:(Ljava/lang/Object;)V
1: aload 0
invokevirtual io.vertx.ext.asyncsql.impl.BaseSQLClient.pool:()Lio/vertx/ext/asyncsql/impl/pool/AsyncConnectionPool;
aload 1
invokedynamic handle(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/ext/asyncsql/impl/BaseSQLClient.lambda$1(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.ext.asyncsql.impl.pool.AsyncConnectionPool.close:(Lio/vertx/core/Handler;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/asyncsql/impl/BaseSQLClient;
0 3 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
handler
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aconst_null
invokevirtual io.vertx.ext.asyncsql.impl.BaseSQLClient.close:(Lio/vertx/core/Handler;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/asyncsql/impl/BaseSQLClient;
protected com.github.mauricio.async.db.Configuration getConnectionConfiguration(java.lang.String, int, java.lang.String, java.lang.String, java.lang.String, java.lang.String, long, long, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;JJLio/vertx/core/json/JsonObject;)Lcom/github/mauricio/async/db/Configuration;
flags: (0x0004) ACC_PROTECTED
Code:
stack=15, locals=25, args_size=10
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 9 start local 11 0: aload 11
ldc "host"
aload 1
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
astore 12
start local 12 1: aload 11
ldc "port"
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual io.vertx.core.json.JsonObject.getInteger:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;
invokevirtual java.lang.Integer.intValue:()I
istore 13
start local 13 2: aload 11
ldc "username"
aload 4
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
astore 14
start local 14 3: aload 11
ldc "password"
aload 5
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
astore 15
start local 15 4: aload 11
ldc "database"
aload 3
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
astore 16
start local 16 5: aload 11
ldc "charset"
aload 6
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
invokestatic java.nio.charset.Charset.forName:(Ljava/lang/String;)Ljava/nio/charset/Charset;
astore 17
start local 17 6: aload 11
ldc "connectTimeout"
lload 7
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokevirtual io.vertx.core.json.JsonObject.getLong:(Ljava/lang/String;Ljava/lang/Long;)Ljava/lang/Long;
invokevirtual java.lang.Long.longValue:()J
lstore 18
start local 18 7: aload 11
ldc "testTimeout"
lload 9
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokevirtual io.vertx.core.json.JsonObject.getLong:(Ljava/lang/String;Ljava/lang/Long;)Ljava/lang/Long;
invokevirtual java.lang.Long.longValue:()J
lstore 20
start local 20 8: aload 11
ldc "queryTimeout"
invokevirtual io.vertx.core.json.JsonObject.getLong:(Ljava/lang/String;)Ljava/lang/Long;
astore 22
start local 22 9: aload 22
ifnonnull 11
10: invokestatic scala.Option.empty:()Lscala/Option;
goto 12
StackMap locals: io.vertx.ext.asyncsql.impl.BaseSQLClient java.lang.String int java.lang.String java.lang.String java.lang.String java.lang.String long long io.vertx.core.json.JsonObject java.lang.String int java.lang.String java.lang.String java.lang.String java.nio.charset.Charset long long java.lang.Long
StackMap stack:
11: aload 22
invokevirtual java.lang.Long.longValue:()J
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic scala.concurrent.duration.Duration.apply:(JLjava/util/concurrent/TimeUnit;)Lscala/concurrent/duration/FiniteDuration;
invokestatic scala.Option.apply:(Ljava/lang/Object;)Lscala/Option;
12: StackMap locals:
StackMap stack: scala.Option
astore 23
start local 23 13: aload 0
aload 11
invokevirtual io.vertx.ext.asyncsql.impl.BaseSQLClient.buildSslConfig:(Lio/vertx/core/json/JsonObject;)Lscala/collection/immutable/Map;
astore 24
start local 24 14: aload 0
getfield io.vertx.ext.asyncsql.impl.BaseSQLClient.log:Lio/vertx/core/logging/Logger;
new java.lang.StringBuilder
dup
ldc "Creating configuration for "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 12
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ":"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
iload 13
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual io.vertx.core.logging.Logger.info:(Ljava/lang/Object;)V
15: new com.github.mauricio.async.db.Configuration
dup
16: aload 14
17: aload 12
18: iload 13
19: aload 15
invokestatic scala.Option.apply:(Ljava/lang/Object;)Lscala/Option;
20: aload 16
invokestatic scala.Option.apply:(Ljava/lang/Object;)Lscala/Option;
21: aload 24
invokestatic com.github.mauricio.async.db.SSLConfiguration.apply:(Lscala/collection/immutable/Map;)Lcom/github/mauricio/async/db/SSLConfiguration;
22: aload 17
23: ldc 16777216
24: getstatic io.netty.buffer.PooledByteBufAllocator.DEFAULT:Lio/netty/buffer/PooledByteBufAllocator;
25: lload 18
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic scala.concurrent.duration.Duration.apply:(JLjava/util/concurrent/TimeUnit;)Lscala/concurrent/duration/FiniteDuration;
26: lload 20
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic scala.concurrent.duration.Duration.apply:(JLjava/util/concurrent/TimeUnit;)Lscala/concurrent/duration/FiniteDuration;
27: aload 23
28: invokespecial com.github.mauricio.async.db.Configuration.<init>:(Ljava/lang/String;Ljava/lang/String;ILscala/Option;Lscala/Option;Lcom/github/mauricio/async/db/SSLConfiguration;Ljava/nio/charset/Charset;ILio/netty/buffer/ByteBufAllocator;Lscala/concurrent/duration/Duration;Lscala/concurrent/duration/Duration;Lscala/Option;)V
areturn
end local 24 end local 23 end local 22 end local 20 end local 18 end local 17 end local 16 end local 15 end local 14 end local 13 end local 12 end local 11 end local 9 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 29 0 this Lio/vertx/ext/asyncsql/impl/BaseSQLClient;
0 29 1 defaultHost Ljava/lang/String;
0 29 2 defaultPort I
0 29 3 defaultDatabase Ljava/lang/String;
0 29 4 defaultUser Ljava/lang/String;
0 29 5 defaultPassword Ljava/lang/String;
0 29 6 defaultCharset Ljava/lang/String;
0 29 7 defaultConnectTimeout J
0 29 9 defaultTestTimeout J
0 29 11 config Lio/vertx/core/json/JsonObject;
1 29 12 host Ljava/lang/String;
2 29 13 port I
3 29 14 username Ljava/lang/String;
4 29 15 password Ljava/lang/String;
5 29 16 database Ljava/lang/String;
6 29 17 charset Ljava/nio/charset/Charset;
7 29 18 connectTimeout J
8 29 20 testTimeout J
9 29 22 queryTimeout Ljava/lang/Long;
13 29 23 queryTimeoutOption Lscala/Option<Lscala/concurrent/duration/Duration;>;
14 29 24 sslConfig Lscala/collection/immutable/Map<Ljava/lang/String;Ljava/lang/String;>;
MethodParameters:
Name Flags
defaultHost
defaultPort
defaultDatabase
defaultUser
defaultPassword
defaultCharset
defaultConnectTimeout
defaultTestTimeout
config
private scala.collection.immutable.Map<java.lang.String, java.lang.String> buildSslConfig(io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/json/JsonObject;)Lscala/collection/immutable/Map;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: getstatic scala.collection.Map$.MODULE$:Lscala/collection/Map$;
invokevirtual scala.collection.Map$.empty:()Lscala/collection/immutable/Map;
astore 2
start local 2 1: aload 1
ldc "sslMode"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
ifnull 3
2: aload 2
ldc "sslmode"
aload 1
ldc "sslMode"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic scala.Tuple2.apply:(Ljava/lang/Object;Ljava/lang/Object;)Lscala/Tuple2;
invokeinterface scala.collection.immutable.Map.$plus:(Lscala/Tuple2;)Lscala/collection/immutable/Map;
astore 2
3: StackMap locals: scala.collection.immutable.Map
StackMap stack:
aload 1
ldc "sslRootCert"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
ifnull 5
4: aload 2
ldc "sslrootcert"
aload 1
ldc "sslRootCert"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic scala.Tuple2.apply:(Ljava/lang/Object;Ljava/lang/Object;)Lscala/Tuple2;
invokeinterface scala.collection.immutable.Map.$plus:(Lscala/Tuple2;)Lscala/collection/immutable/Map;
astore 2
5: StackMap locals:
StackMap stack:
aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/ext/asyncsql/impl/BaseSQLClient;
0 6 1 config Lio/vertx/core/json/JsonObject;
1 6 2 sslConfig Lscala/collection/immutable/Map<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/core/json/JsonObject;)Lscala/collection/immutable/Map<Ljava/lang/String;Ljava/lang/String;>;
MethodParameters:
Name Flags
config
private void lambda$0(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=5, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 5
1: aload 0
invokevirtual io.vertx.ext.asyncsql.impl.BaseSQLClient.pool:()Lio/vertx/ext/asyncsql/impl/pool/AsyncConnectionPool;
astore 3
start local 3 2: aload 0
getfield io.vertx.ext.asyncsql.impl.BaseSQLClient.vertx:Lio/vertx/core/Vertx;
invokestatic io.vertx.ext.asyncsql.impl.VertxEventLoopExecutionContext.create:(Lio/vertx/core/Vertx;)Lscala/concurrent/ExecutionContext;
astore 4
start local 4 3: aload 1
aload 0
aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast com.github.mauricio.async.db.Connection
aload 3
aload 4
invokevirtual io.vertx.ext.asyncsql.impl.BaseSQLClient.createFromPool:(Lcom/github/mauricio/async/db/Connection;Lio/vertx/ext/asyncsql/impl/pool/AsyncConnectionPool;Lscala/concurrent/ExecutionContext;)Lio/vertx/ext/sql/SQLConnection;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 4 end local 3 4: goto 6
5: StackMap locals:
StackMap stack:
aload 1
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/ext/asyncsql/impl/BaseSQLClient;
0 7 2 ar Lio/vertx/core/AsyncResult<Lcom/github/mauricio/async/db/Connection;>;
2 4 3 pool Lio/vertx/ext/asyncsql/impl/pool/AsyncConnectionPool;
3 4 4 ec Lscala/concurrent/ExecutionContext;
private static void lambda$1(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 0
ifnull 6
2: aload 0
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: goto 6
4: StackMap locals:
StackMap stack:
aload 0
ifnull 6
5: aload 0
aload 1
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: StackMap locals:
StackMap stack:
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 7 1 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
}
SourceFile: "BaseSQLClient.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles