Dependencies
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- com.fasterxml.jackson.core/jackson-annotations/2.9.0
- com.fasterxml.jackson.core/jackson-core/2.9.9
- com.fasterxml.jackson.core/jackson-databind/2.9.9.1
- com.github.jponge/lzma-java/1.3
- com.github.mauricio/db-async-common_2.12/0.2.21
- com.github.mauricio/mysql-async_2.12/0.2.21
- com.github.mauricio/postgresql-async_2.12/0.2.21
- com.google.code.findbugs/jsr305/1.3.9
- com.google.guava/guava/18.0
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.jcraft/jzlib/1.1.3
- commons-logging/commons-logging/1.2
- com.ning/compress-lzf/1.0.3
- com.sun/tools/1.8
- io.netty/netty-buffer/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.vertx/vertx-codegen/3.8.0
- io.vertx/vertx-core/3.8.0
- io.vertx/vertx-docgen/0.9.2
- io.vertx/vertx-sql-common/3.8.0
- java/11
- jdk/srczip/999
- joda-time/joda-time/2.9.7
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- net.jpountz.lz4/lz4/1.3.0
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.logging.log4j/log4j-api/2.6.2
- org.bouncycastle/bcpkix-jdk15on/1.54
- org.bouncycastle/bcprov-jdk15on/1.54
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.javassist/javassist/3.21.0-GA
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.joda/joda-convert/1.8.1
- org.mvel/mvel2/2.3.1.Final
- org.scala-lang/scala-library/2.12.7
- org.slf4j/slf4j-api/1.7.21
Declarations
- examples
-
io
-
vertx
-
ext
-
asyncsql
-
AsyncSQLClient
-
MySQLClient
-
DEFAULT_PORT: int
-
DEFAULT_CHARSET: String
-
DEFAULT_DATABASE: String
-
DEFAULT_USER: String
-
DEFAULT_PASSWORD: String
-
DEFAULT_POOL_NAME: String
-
DEFAULT_HOST: String
-
DEFAULT_CONNECT_TIMEOUT: long
-
DEFAULT_TEST_TIMEOUT: long
-
createNonShared(Vertx, JsonObject): AsyncSQLClient
-
createShared(Vertx, JsonObject, String): AsyncSQLClient
-
createShared(Vertx, JsonObject): AsyncSQLClient
-
-
PostgreSQLClient
-
DEFAULT_DS_NAME: String
-
DEFAULT_HOST: String
-
DEFAULT_PORT: int
-
DEFAULT_DATABASE: String
-
DEFAULT_USER: String
-
DEFAULT_PASSWORD: String
-
DEFAULT_CHARSET: String
-
DEFAULT_CONNECT_TIMEOUT: long
-
DEFAULT_TEST_TIMEOUT: long
-
createNonShared(Vertx, JsonObject): AsyncSQLClient
-
createShared(Vertx, JsonObject, String): AsyncSQLClient
-
createShared(Vertx, JsonObject): AsyncSQLClient
-
-
impl
-
AsyncSQLClientImpl
-
AsyncSQLConnectionImpl
-
executionContext: ExecutionContext
-
inTransaction: boolean
-
inAutoCommit: boolean
-
connection: Connection
-
pool: AsyncConnectionPool
-
AsyncSQLConnectionImpl(Connection, AsyncConnectionPool, ExecutionContext): void
-
getStartTransactionStatement(): String
-
call(String, Handler<AsyncResult<ResultSet>>): SQLConnection
-
callWithParams(String, JsonArray, JsonArray, Handler<AsyncResult<ResultSet>>): SQLConnection
-
setOptions(SQLOptions): SQLConnection
-
setAutoCommit(boolean, Handler<AsyncResult<Void>>): SQLConnection
-
execute(String, Handler<AsyncResult<Void>>): SQLConnection
-
query(String, Handler<AsyncResult<ResultSet>>): SQLConnection
-
queryStream(String, Handler<AsyncResult<SQLRowStream>>): SQLConnection
-
queryWithParams(String, JsonArray, Handler<AsyncResult<ResultSet>>): SQLConnection
-
queryStreamWithParams(String, JsonArray, Handler<AsyncResult<SQLRowStream>>): SQLConnection
-
update(String, Handler<AsyncResult<UpdateResult>>): SQLConnection
-
updateWithParams(String, JsonArray, Handler<AsyncResult<UpdateResult>>): SQLConnection
-
close(Handler<AsyncResult<Void>>): void
-
close(): void
-
commit(Handler<AsyncResult<Void>>): SQLConnection
-
rollback(Handler<AsyncResult<Void>>): SQLConnection
-
setTransactionIsolation(TransactionIsolation, Handler<AsyncResult<Void>>): SQLConnection
-
getTransactionIsolation(Handler<AsyncResult<TransactionIsolation>>): SQLConnection
-
batch(List<String>, Handler<AsyncResult<List<Integer>>>): SQLConnection
-
batchWithParams(String, List<JsonArray>, Handler<AsyncResult<List<Integer>>>): SQLConnection
-
batchCallableWithParams(String, List<JsonArray>, List<JsonArray>, Handler<AsyncResult<List<Integer>>>): SQLConnection
-
unwrap(): Object
-
endAndStartTransaction(String, Handler<AsyncResult<Void>>): SQLConnection
-
beginTransactionIfNeeded(Handler<AsyncResult<Void>>): void
-
handleAsyncQueryResultToResultSet(Handler<AsyncResult<ResultSet>>): Handler<AsyncResult<QueryResult>>
-
handleAsyncQueryResultToRowStream(Handler<AsyncResult<SQLRowStream>>): Handler<AsyncResult<QueryResult>>
-
queryResultToResultSet(QueryResult): ResultSet
-
handleAsyncUpdateResultToResultSet(Handler<AsyncResult<UpdateResult>>): Handler<AsyncResult<QueryResult>>
-
queryResultToUpdateResult(QueryResult): UpdateResult
-
rowDataSeqToJsonArray(ResultSet): List<JsonArray>
-
-
AsyncSQLRowStream
-
rs: ResultSet
-
cursor: Iterator<RowData>
-
columns: List<String>
-
demand: long
-
ended: AtomicBoolean
-
handler: Handler<JsonArray>
-
endHandler: Handler<Void>
-
rsClosedHandler: Handler<Void>
-
AsyncSQLRowStream(QueryResult): void
-
column(String): int
-
columns(): List<String>
-
exceptionHandler(Handler<Throwable>): SQLRowStream
-
handler(Handler<JsonArray>): SQLRowStream
-
pause(): SQLRowStream
-
fetch(long): SQLRowStream
-
resume(): SQLRowStream
-
nextRow(): void
-
endHandler(Handler<Void>): SQLRowStream
-
resultSetClosedHandler(Handler<Void>): SQLRowStream
-
moreResults(): void
-
close(): void
-
close(Handler<AsyncResult<Void>>): void
-
-
BaseSQLClient
-
log: Logger
-
vertx: Vertx
-
globalConfig: JsonObject
-
BaseSQLClient(Vertx, JsonObject): void
-
pool(): AsyncConnectionPool
-
createFromPool(Connection, AsyncConnectionPool, ExecutionContext): SQLConnection
-
getConnection(Handler<AsyncResult<SQLConnection>>): void
-
close(Handler<AsyncResult<Void>>): void
-
close(): void
-
getConnectionConfiguration(String, int, String, String, String, String, long, long, JsonObject): Configuration
-
buildSslConfig(JsonObject): Map<String, String>
-
-
ClientHelper
-
ClientHolder
-
ClientWrapper
-
MYSQLClientImpl
-
MySQLConnectionImpl
-
PostgreSQLClientImpl
-
PostgreSQLConnectionImpl
-
ScalaUtils
-
ScalaUtils(): void
-
scalaToVertx(Future<Object>, ExecutionContext): Future<Object>
-
scalaToVertxVoid(Future<Object>, ExecutionContext): Future<Void>
-
toJavaList(List<Object>): List<Object>
-
toScalaList(List<Object>): List<Object>
-
toFunction1(Handler<AsyncResult<Object>>): Function1<Try<Object>, Void>
-
rowToJsonArray(RowData): JsonArray
-
convertValue(JsonArray, Object): void
-
durationToString(long): String
-
-
VertxEventLoopExecutionContext
-
pool
-
AsyncConnectionPool
-
DEFAULT_MAX_POOL_SIZE: int
-
DEFAULT_MAX_CONNECTION_RETRIES: int
-
DEFAULT_CONNECTION_RETRY_DELAY: int
-
logger: Logger
-
maxPoolSize: int
-
maxConnectionRetries: int
-
connectionRetryDelay: int
-
connectionConfig: Configuration
-
vertx: Vertx
-
poolSize: int
-
availableConnections: Deque<Connection>
-
waiters: Deque<Handler<AsyncResult<Connection>>>
-
AsyncConnectionPool(Vertx, JsonObject, Configuration): void
-
create(): Connection
-
createConnection(Handler<AsyncResult<Connection>>): void
-
createAndConnect(Handler<AsyncResult<Connection>>): void
-
waitForAvailableConnection(Handler<AsyncResult<Connection>>): void
-
createOrWaitForAvailableConnection(Handler<AsyncResult<Connection>>): void
-
take(Handler<AsyncResult<Connection>>): void
-
notifyWaitersAboutAvailableConnection(): void
-
giveBack(Connection): void
-
close(): void
-
close(Handler<AsyncResult<Void>>): void
-
-
MysqlAsyncConnectionPool
-
PostgresqlAsyncConnectionPool
-
-
-
-
asyncsql
-
ext
-
vertx