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
-
AbstractJDBCAction
-
JDBCClientImpl
- spi
-
jdbc
-
ext
-
vertx