Dependencies
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- com.beust/jcommander/1.48
- com.conversantmedia/disruptor/1.2.8-JDK7
- 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.fasterxml.jackson.dataformat/jackson-dataformat-xml/2.8.3
- com.fasterxml.jackson.dataformat/jackson-dataformat-yaml/2.8.3
- com.fasterxml.jackson.module/jackson-module-jaxb-annotations/2.8.3
- com.fasterxml.woodstox/woodstox-core/5.0.2
- com.github.jponge/lzma-java/1.3
- com.google.code.findbugs/jsr305/1.3.9
- com.google.guava/guava/15.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
- com.jolbox/bonecp/0.8.0.RELEASE
- com.lmax/disruptor/3.3.5
- com.mchange/c3p0/0.9.5.4
- com.mchange/mchange-commons-java/0.2.15
- commons-logging/commons-logging/1.2
- com.ning/compress-lzf/1.0.3
- com.sun.mail/javax.mail/1.5.5 (available as javax.mail/javax.mail-api/1.6.2)
- com.sun/tools/1.8
- com.typesafe/config/1.3.0
- com.zaxxer/HikariCP/2.4.6
- io.agroal/agroal-api/1.1
- io.agroal/agroal-pool/1.1
- 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
- javax.activation/activation/1.1
- javax.inject/javax.inject/1
- jdk/srczip/999
- log4j/log4j/1.2.14
- logkit/logkit/1.0.1
- net.jpountz.lz4/lz4/1.3.0
- org.apache.commons/commons-compress/1.12
- org.apache.commons/commons-csv/1.4
- org.apache.kafka/kafka-clients/0.10.0.1
- org.apache.logging.log4j/log4j-api/2.7
- org.apache.logging.log4j/log4j-core/2.7
- org.bouncycastle/bcpkix-jdk15on/1.54
- org.bouncycastle/bcprov-jdk15on/1.54
- org.codehaus.woodstox/stax2-api/3.1.4
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.eclipse.persistence/javax.persistence/2.1.0
- org.fusesource.jansi/jansi/1.13
- org.javassist/javassist/3.20.0-GA
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.jctools/jctools-core/1.2.1
- org.mvel/mvel2/2.3.1.Final
- org.slf4j/slf4j-api/1.7.5
- org.tukaani/xz/1.5
- org.xerial.snappy/snappy-java/1.1.2.6
- org.yaml/snakeyaml/1.15
- org.zeromq/jeromq/0.3.5
Declarations
- examples
-
io
-
vertx
-
ext
-
jdbc
-
JDBCClient
-
impl
-
JDBCClientImpl
-
DS_LOCAL_MAP_NAME: String
-
vertx: Vertx
-
holder: DataSourceHolder
-
exec: ExecutorService
-
ds: DataSource
-
metrics: PoolMetrics
-
helper: JDBCStatementHelper
-
JDBCClientImpl(Vertx, DataSource): void
-
JDBCClientImpl(Vertx, JsonObject, String): void
-
setupCloseHook(): void
-
close(): void
-
close(Handler<AsyncResult<Void>>): void
-
update(String, Handler<AsyncResult<UpdateResult>>): JDBCClient
-
updateWithParams(String, JsonArray, Handler<AsyncResult<UpdateResult>>): JDBCClient
-
query(String, Handler<AsyncResult<ResultSet>>): JDBCClient
-
queryWithParams(String, JsonArray, Handler<AsyncResult<ResultSet>>): JDBCClient
-
executeDirect(Context, AbstractJDBCAction<Object>, Handler<AsyncResult<Object>>): void
-
getConnection(Context, Handler<AsyncResult<SQLConnection>>): void
-
getConnection(Handler<AsyncResult<SQLConnection>>): SQLClient
-
lookupHolder(String, JsonObject): DataSourceHolder
-
DataSourceHolder
-
exec(): ExecutorService
-
vertx: VertxInternal
-
map: LocalMap<String, DataSourceHolder>
-
provider: DataSourceProvider
-
config: JsonObject
-
ds: DataSource
-
metrics: PoolMetrics
-
exec: ExecutorService
-
refCount: int
-
name: String
-
DataSourceHolder(VertxInternal, DataSource): void
-
DataSourceHolder(VertxInternal, JsonObject, LocalMap<String, DataSourceHolder>, String): void
-
ds(): DataSource
-
incRefCount(): void
-
close(Handler<AsyncResult<Void>>): void
-
-
-
JDBCConnectionImpl
-
log: Logger
-
vertx: Vertx
-
conn: Connection
-
ctx: ContextInternal
-
metrics: PoolMetrics
-
metric: Object
-
statementsQueue: TaskQueue
-
helper: JDBCStatementHelper
-
options: SQLOptions
-
JDBCConnectionImpl(Context, JDBCStatementHelper, Connection, PoolMetrics, Object): void
-
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
-
queryStreamWithParams(String, JsonArray, Handler<AsyncResult<SQLRowStream>>): SQLConnection
-
queryWithParams(String, JsonArray, Handler<AsyncResult<ResultSet>>): SQLConnection
-
update(String, Handler<AsyncResult<UpdateResult>>): SQLConnection
-
updateWithParams(String, JsonArray, Handler<AsyncResult<UpdateResult>>): SQLConnection
-
call(String, Handler<AsyncResult<ResultSet>>): SQLConnection
-
callWithParams(String, JsonArray, JsonArray, Handler<AsyncResult<ResultSet>>): SQLConnection
-
close(Handler<AsyncResult<Void>>): void
-
close(): void
-
commit(Handler<AsyncResult<Void>>): SQLConnection
-
rollback(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
-
setTransactionIsolation(TransactionIsolation, Handler<AsyncResult<Void>>): SQLConnection
-
unwrap(): Object
-
-
actions
-
AbstractJDBCAction
-
vertx: Vertx
-
name(): String
-
options: SQLOptions
-
ctx: ContextInternal
-
helper: JDBCStatementHelper
-
AbstractJDBCAction(Vertx, SQLOptions, ContextInternal): void
-
AbstractJDBCAction(Vertx, JDBCStatementHelper, SQLOptions, ContextInternal): void
-
handle(Connection, Promise<Object>): void
-
execute(Connection, TaskQueue, Handler<AsyncResult<Object>>): void
-
execute(Connection): Object
-
applyStatementOptions(Statement): void
-
applyConnectionOptions(Connection): void
-
-
JDBCAutoCommit
-
JDBCBatch
-
Type
-
type: Type
-
sql: List<String>
-
in: List<JsonArray>
-
out: List<JsonArray>
-
JDBCBatch(Vertx, JDBCStatementHelper, SQLOptions, ContextInternal, List<String>): void
-
JDBCBatch(Vertx, JDBCStatementHelper, SQLOptions, ContextInternal, String, List<JsonArray>): void
-
JDBCBatch(Vertx, JDBCStatementHelper, SQLOptions, ContextInternal, String, List<JsonArray>, List<JsonArray>): void
-
JDBCBatch(Vertx, JDBCStatementHelper, SQLOptions, ContextInternal, Type, List<String>, List<JsonArray>, List<JsonArray>): void
-
execute(Connection): List<Integer>
-
name(): String
-
-
JDBCCallable
-
JDBCClose
-
JDBCCommit
-
JDBCExecute
-
JDBCQuery
-
JDBCRollback
-
JDBCSQLRowStream
-
log: Logger
-
ctx: ContextInternal
-
statementsQueue: TaskQueue
-
st: Statement
-
fetchSize: int
-
pending: InboundBuffer<JsonArray>
-
ended: AtomicBoolean
-
stClosed: AtomicBoolean
-
rsClosed: AtomicBoolean
-
more: AtomicBoolean
-
rs: ResultSet
-
metaData: ResultSetMetaData
-
columns: List<String>
-
cols: int
-
exceptionHandler: Handler<Throwable>
-
endHandler: Handler<Void>
-
rsClosedHandler: Handler<Void>
-
JDBCSQLRowStream(ContextInternal, TaskQueue, Statement, ResultSet, int): void
-
checkEndHandler(): void
-
column(String): int
-
columns(): List<String>
-
exceptionHandler(Handler<Throwable>): SQLRowStream
-
handler(Handler<JsonArray>): SQLRowStream
-
pause(): SQLRowStream
-
fetch(long): ReadStream<JsonArray>
-
resume(): SQLRowStream
-
readBatch(): void
-
empty(Throwable): void
-
endHandler(Handler<Void>): SQLRowStream
-
close0(Handler<AsyncResult<Void>>): void
-
close(): void
-
close(Handler<AsyncResult<Void>>): void
-
resultSetClosedHandler(Handler<Void>): SQLRowStream
-
moreResults(): void
-
getNextResultSet(Promise<Void>): void
-
close(AutoCloseable, AtomicBoolean, Handler<AsyncResult<Void>>): void
-
-
JDBCStatementHelper
-
convertSqlValue(Object): Object
-
log: Logger
-
EMPTY: JsonArray
-
DATETIME: Pattern
-
DATE: Pattern
-
TIME: Pattern
-
UUID: Pattern
-
castUUID: boolean
-
JDBCStatementHelper(): void
-
JDBCStatementHelper(JsonObject): void
-
fillStatement(PreparedStatement, JsonArray): void
-
fillStatement(CallableStatement, JsonArray, JsonArray): void
-
asList(ResultSet): ResultSet
-
optimisticCast(String): Object
-
-
JDBCUpdate
-
StreamQuery
-
-
- spi
-
-
jdbc
-
ext
-
vertx