Dependencies
- ant/ant/1.5.1 (available as org.apache.ant/ant/1.10.7)
- antlr/antlr/2.7.7
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- bsf/bsf/2.4.0 (available as org.apache.bsf/bsf-api/3.1)
- cglib/cglib-nodep/2.2 (available as cglib/cglib/3.3.0)
- ch.qos.logback/logback-classic/1.2.3
- ch.qos.logback/logback-core/1.2.3
- com.beust/jcommander/1.48
- com.conversantmedia/disruptor/1.2.8-JDK7
- com.fasterxml/classmate/1.3.4
- com.fasterxml.jackson.core/jackson-annotations/2.11.3
- com.fasterxml.jackson.core/jackson-core/2.11.3
- com.fasterxml.jackson.core/jackson-databind/2.11.3
- 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.ben-manes.caffeine/caffeine/2.8.0
- com.github.jnr/jffi/1.2.15
- com.github.jnr/jffi/1.2.15/native
- com.github.jnr/jnr-constants/0.9.8
- com.github.jnr/jnr-enxio/0.16
- com.github.jnr/jnr-ffi/2.1.4
- com.github.jnr/jnr-posix/3.0.35
- com.github.jnr/jnr-unixsocket/0.18
- com.github.jnr/jnr-x86asm/1.0.2
- com.github.jponge/lzma-java/1.3
- com.github.luben/zstd-jni/1.3.8-3
- com.google.code.findbugs/jsr305/3.0.2
- com.google.errorprone/error_prone_annotations/2.3.2
- com.google.guava/failureaccess/1.0.1
- com.google.guava/guava/28.1-jre
- com.google.guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava
- com.google.j2objc/j2objc-annotations/1.3
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.hazelcast/hazelcast/3.12.2
- com.jcraft/jsch/0.1.50
- com.jcraft/jsch.agentproxy.connector-factory/0.0.6
- com.jcraft/jsch.agentproxy.core/0.0.6
- com.jcraft/jsch.agentproxy.jsch/0.0.6
- com.jcraft/jsch.agentproxy.pageant/0.0.6
- com.jcraft/jsch.agentproxy.sshagent/0.0.6
- com.jcraft/jsch.agentproxy.usocket-jna/0.0.6
- com.jcraft/jsch.agentproxy.usocket-nc/0.0.6
- com.jcraft/jzlib/1.1.3
- com.lmax/disruptor/3.3.5
- com.mchange/c3p0/0.9.5.4
- com.mchange/mchange-commons-java/0.2.15
- commons-beanutils/commons-beanutils/1.8.3
- commons-codec/commons-codec/1.10
- commons-collections/commons-collections/3.2.1
- commons-configuration/commons-configuration/1.8
- commons-digester/commons-digester/1.8.1
- commons-httpclient/commons-httpclient/3.0
- commons-jxpath/commons-jxpath/1.3
- commons-lang/commons-lang/2.6
- commons-logging/commons-logging/1.2
- commons-net/commons-net/2.2
- commons-vfs/commons-vfs/1.0
- com.netflix.archaius/archaius-core/0.4.1
- com.netflix.hystrix/hystrix-core/1.5.12
- com.ning/compress-lzf/1.0.3
- com.squareup.okhttp3/okhttp/3.14.4
- com.squareup.okio/okio/1.17.2
- com.sun.istack/istack-commons-runtime/3.0.7
- com.sun.mail/javax.mail/1.5.5 (available as javax.mail/javax.mail-api/1.6.2)
- com.sun/tools/1.8
- com.sun.xml.fastinfoset/FastInfoset/1.2.15
- com.thoughtworks.qdox/qdox/1.12.1
- com.thoughtworks.xstream/xstream/1.4.7
- com.typesafe/config/1.3.0
- com.zaxxer/HikariCP/3.4.5
- dom4j/dom4j/1.6.1
- io.agroal/agroal-api/1.9
- io.agroal/agroal-pool/1.9
- io.dropwizard.metrics/metrics-core/4.0.6
- io.micrometer/micrometer-core/1.3.2
- io.netty/netty-buffer/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-haproxy/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-tcnative/2.0.30.Final
- io.netty/netty-transport/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.34.Final/linux-x86_64
- io.netty/netty-transport-native-epoll/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.49.Final (available as io.netty/netty-all/4.1.25.Final)
- io.projectreactor.netty/reactor-netty/0.8.6.RELEASE
- io.projectreactor/reactor-core/3.2.12.RELEASE
- io.projectreactor.tools/blockhound/1.0.3.RELEASE
- io.reactivex/rxjava/1.2.0 (available as io.reactivex.rxjava2/rxjava/2.2.11)
- io.vertx/vertx-codegen/4.0.0
- io.vertx/vertx-core/4.0.0
- io.vertx/vertx-docgen/0.9.2
- io.vertx/vertx-sql-client/4.0.0
- java/11
- javax.activation/activation/1.1
- javax.activation/javax.activation-api/1.2.0
- javax.cache/cache-api/1.1.1
- javax.mail/mail/1.4
- javax.persistence/javax.persistence-api/2.2
- javax.servlet/javax.servlet-api/3.1.0
- javax.servlet/servlet-api/2.5 (available as javax.servlet/javax.servlet-api/4.0.1)
- javax.xml.bind/jaxb-api/2.3.1
- jaxen/jaxen/1.1-beta-6
- jaxme/jaxme-api/0.3
- jdk/srczip/999
- jdom/jdom/1.0
- jline/jline/2.12
- joda-time/joda-time/1.6
- junit/junit/4.12
- log4j/log4j/1.2.14
- logkit/logkit/1.0.1
- msv/relaxngDatatype/20030807
- msv/xsdlib/20030807
- net.bytebuddy/byte-buddy/1.9.11 (available as net.bytebuddy/byte-buddy-dep/1.9.12)
- net.java.dev.jna/jna/4.5.2
- net.java.dev.jna/platform/3.4.0
- net.jpountz.lz4/lz4/1.3.0
- net.sf.ehcache/ehcache/2.10.6
- net.sf.kxml/kxml2/2.3.0
- net.sf.kxml/kxml2-min/2.3.0
- org.apache.ant/ant/1.9.4
- org.apache.ant/ant-antlr/1.9.4
- org.apache.ant/ant-junit/1.9.4
- org.apache.ant/ant-launcher/1.9.4
- org.apache.ant/ant-nodeps/1.7.1
- org.apache.ant/ant-trax/1.7.1
- org.apache.commons/commons-compress/1.12
- org.apache.commons/commons-csv/1.4
- org.apache.commons/commons-jexl/2.1.1
- org.apache.commons/commons-vfs2/2.0
- org.apache.felix/org.osgi.compendium/1.4.0
- org.apache.felix/org.osgi.core/1.4.0
- org.apache.httpcomponents/httpclient/4.5.6
- org.apache.httpcomponents/httpcore/4.4.10
- org.apache.ivy/ivy/2.4.0
- org.apache.jackrabbit/jackrabbit-jcr-commons/1.5.2
- org.apache.jackrabbit/jackrabbit-webdav/1.5.2
- org.apache.kafka/kafka-clients/0.10.0.1
- org.apache.logging.log4j/log4j-api/2.6.2
- org.apache.logging.log4j/log4j-core/2.7
- org.apache.maven.scm/maven-scm-api/1.4
- org.apache.maven.scm/maven-scm-provider-svn-commons/1.4
- org.apache.maven.scm/maven-scm-provider-svnexe/1.4
- org.apache.tomcat.embed/tomcat-embed-core/8.5.46
- org.apache.tomcat/tomcat-annotations-api/8.5.46
- org.aspectj/aspectjweaver/1.8.14
- org.bouncycastle/bcpg-jdk14/1.45
- org.bouncycastle/bcpkix-jdk15on/1.65
- org.bouncycastle/bcprov-jdk14/1.45
- org.bouncycastle/bcprov-jdk15on/1.65
- org.checkerframework/checker-qual/2.8.1
- org.codehaus.gpars/gpars/1.2.1
- org.codehaus.groovy/groovy-all/2.4.0
- org.codehaus.janino/commons-compiler/3.0.6
- org.codehaus.janino/janino/3.0.6
- org.codehaus.jcsp/jcsp/1.1-rc5
- org.codehaus.jettison/jettison/1.2
- org.codehaus.jsr166-mirror/jsr166y/1.7.0
- org.codehaus.mojo/animal-sniffer-annotations/1.18
- org.codehaus.plexus/plexus-utils/1.5.6
- org.codehaus.woodstox/stax2-api/3.1.4
- org.codehaus.woodstox/wstx-asl/3.2.7
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.dom4j/dom4j/2.1.1
- org.eclipse.jetty/jetty-http/9.2.28.v20190418
- org.eclipse.jetty/jetty-io/9.2.28.v20190418
- org.eclipse.jetty/jetty-jmx/9.2.28.v20190418
- org.eclipse.jetty/jetty-server/9.2.28.v20190418
- org.eclipse.jetty/jetty-util/9.2.28.v20190418
- org.eclipse.persistence/javax.persistence/2.1.0
- org.fusesource.jansi/jansi/1.13
- org.glassfish.jaxb/jaxb-runtime/2.3.1
- org.glassfish.jaxb/txw2/2.3.1
- org.hamcrest/hamcrest-core/1.3
- org.hdrhistogram/HdrHistogram/2.1.11
- org.hibernate.common/hibernate-commons-annotations/5.1.0.Final
- org.hibernate/hibernate-core/5.4.6.Final
- org.hibernate/hibernate-entitymanager/5.4.6.Final
- org.javassist/javassist/3.24.1-GA
- org.jboss/jandex/2.0.5.Final
- org.jboss.logging/jboss-logging/3.3.2.Final
- org.jboss.logging/jboss-logging-spi/2.1.2.GA
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.jboss.netty/netty/3.2.9.Final
- org.jboss.spec.javax.transaction/jboss-transaction-api_1.2_spec/1.1.1.Final
- org.jctools/jctools-core/1.2.1
- org.jdom/jdom/1.1.3
- org.jdom/jdom2/2.0.5
- org.jetbrains/annotations/13.0
- org.jetbrains.kotlin/kotlin-stdlib/1.2.51
- org.jetbrains.kotlin/kotlin-stdlib-common/1.2.51
- org.json/json/20080701
- org.jvnet.staxex/stax-ex/1.8
- org.latencyutils/LatencyUtils/2.0.3
- org.mongodb/bson/4.2.2
- org.mongodb/mongodb-crypt/1.0.0-beta4
- org.mongodb/mongo-java-driver/3.11.0
- org.multiverse/multiverse-core/0.7.0
- org.ow2.asm/asm/5.0.3
- org.ow2.asm/asm-analysis/5.0.3
- org.ow2.asm/asm-commons/5.0.3
- org.ow2.asm/asm-tree/5.0.3
- org.ow2.asm/asm-util/5.0.3
- org.reactivestreams/reactive-streams/1.0.2
- org.slf4j/slf4j-api/1.7.5
- org.testng/testng/6.8.13
- org.tukaani/xz/1.5
- org.xerial.snappy/snappy-java/1.1.4
- org.yaml/snakeyaml/1.15
- org.zeromq/jeromq/0.3.5
- oro/oro/2.0.8
- pull-parser/pull-parser/2
- regexp/regexp/1.3
- saxpath/saxpath/1.0-FCS
- stax/stax/1.2.0
- stax/stax-api/1.0.1
- xalan/serializer/2.7.1
- xalan/xalan/2.7.1
- xerces/xercesImpl/2.10.0
- xerces/xmlParserAPIs/2.6.2
- xml-apis/xml-apis/1.3.04
- xmlpull/xmlpull/1.1.3.1
- xml-resolver/xml-resolver/1.2
- xom/xom/1.1
- xpp3/xpp3/1.1.3.3
Declarations
-
examples
- JDBCExamples
- JDBCSqlClientExamples
-
SQLExamples
- example1(SQLConnection): void
- example2(SQLConnection): void
- example3(ResultSet): void
- example3__1(ResultSet): void
- example3_1(SQLConnection): void
- example4(SQLConnection): void
- example5(SQLConnection): void
- example6(SQLConnection): void
- example7(SQLConnection): void
- example8(SQLConnection): void
- example9(SQLConnection): void
- example10(SQLConnection): void
- example11(SQLConnection): void
- example12(SQLConnection): void
- example13(ResultSet): void
- example14(SQLConnection): void
- example15(SQLConnection): void
- example16(SQLClient): void
-
io
-
vertx
-
ext
-
jdbc
- JDBCClient
-
impl
-
DataSourceHolder
- creationQueue: TaskQueue
- provider: DataSourceProvider
- dataSource: DataSource
- exec: ExecutorService
- metrics: PoolMetrics
- refCount: int
- DataSourceHolder(DataSourceProvider): void
- DataSourceHolder(DataSource, ExecutorService, PoolMetrics): void
- DataSourceHolder(TaskQueue, DataSourceProvider, DataSource, ExecutorService, PoolMetrics, int): void
- created(DataSource, ExecutorService, PoolMetrics): DataSourceHolder
- increment(): DataSourceHolder
- decrement(): DataSourceHolder
-
JDBCClientImpl
- DS_LOCAL_MAP_NAME: String
- vertx: VertxInternal
- datasourceName: String
- config: JsonObject
- holders: Map<String, DataSourceHolder>
- helper: JDBCStatementHelper
- closed: boolean
- JDBCClientImpl(Vertx, DataSource): void
- JDBCClientImpl(Vertx, JsonObject, String): void
- JDBCClientImpl(Vertx, DataSourceProvider): void
- setupCloseHook(): void
- getHelper(): JDBCStatementHelper
- close(Promise<Void>): void
- close(): void
- close(Handler<AsyncResult<Void>>): void
- raiseCloseFlag(): boolean
- update(String, Handler<AsyncResult<UpdateResult>>): JDBCClient
- finalize(): void
- updateWithParams(String, JsonArray, Handler<AsyncResult<UpdateResult>>): JDBCClient
- query(String, Handler<AsyncResult<ResultSet>>): JDBCClient
- queryWithParams(String, JsonArray, Handler<AsyncResult<ResultSet>>): JDBCClient
- executeDirect(AbstractJDBCAction<Object>, Handler<AsyncResult<Object>>): void
- getConnection(): Future<SQLConnection>
- getConnection(ContextInternal): Future<SQLConnection>
- getDataSourceHolder(ContextInternal): Future<DataSourceHolder>
- createDataSource(Promise<DataSourceHolder>): void
- getConnection(Handler<AsyncResult<SQLConnection>>): SQLClient
- createProvider(): DataSourceProvider
- createMetrics(String, int): PoolMetrics
- createExecutor(): ExecutorService
- doClose(DataSourceHolder, Handler<AsyncResult<Void>>): void
-
JDBCConnectionImpl
- conn: Connection
- ctx: ContextInternal
- log: Logger
- metrics: PoolMetrics
- metric: Object
- helper: JDBCStatementHelper
- options: SQLOptions
- JDBCConnectionImpl(Context, JDBCStatementHelper, Connection, PoolMetrics, Object): void
- setOptions(SQLOptions): SQLConnection
- getOptions(): SQLOptions
- 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
- schedule(AbstractJDBCAction<Object>): Future<Object>
- applyConnectionOptions(Connection, SQLOptions): void
-
actions
- AbstractJDBCAction
- JDBCAutoCommit
-
JDBCBatch
- Type
- type: Type
- sql: List<String>
- in: List<JsonArray>
- out: List<JsonArray>
- JDBCBatch(JDBCStatementHelper, SQLOptions, List<String>): void
- JDBCBatch(JDBCStatementHelper, SQLOptions, String, List<JsonArray>): void
- JDBCBatch(JDBCStatementHelper, SQLOptions, String, List<JsonArray>, List<JsonArray>): void
- JDBCBatch(JDBCStatementHelper, SQLOptions, Type, List<String>, List<JsonArray>, List<JsonArray>): void
- execute(Connection): List<Integer>
- JDBCCallable
- JDBCClose
- JDBCCommit
- JDBCExecute
- JDBCQuery
- JDBCRollback
-
JDBCSQLRowStream
- st: Statement
- fetchSize: int
- ctx: ContextInternal
- log: Logger
- 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, 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
- log: Logger
- EMPTY: JsonArray
- DATETIME: Pattern
- DATE: Pattern
- TIME: Pattern
- UUID: Pattern
- castUUID: boolean
- castDate: boolean
- castTime: boolean
- castDatetime: boolean
- JDBCStatementHelper(): void
- JDBCStatementHelper(JsonObject): void
- fillStatement(PreparedStatement, JsonArray): void
- fillStatement(CallableStatement, JsonArray, JsonArray): void
- asList(ResultSet): ResultSet
- convertSqlValue(Object): Object
- optimisticCast(String): Object
- JDBCUpdate
- StreamQuery
-
DataSourceHolder
- spi
-
sql
- FetchDirection
- HandlerUtil
-
ResultSet
- columnNames: List<String>
- results: List<JsonArray>
- rows: List<JsonObject>
- output: JsonArray
- next: ResultSet
- ResultSet(): void
- ResultSet(ResultSet): void
- ResultSet(List<String>, List<JsonArray>, ResultSet): void
- ResultSet(JsonObject): void
- toJson(): JsonObject
- getResults(): List<JsonArray>
- setResults(List<JsonArray>): ResultSet
- getOutput(): JsonArray
- setOutput(JsonArray): ResultSet
- getColumnNames(): List<String>
- setColumnNames(List<String>): ResultSet
- getNext(): ResultSet
- setNext(ResultSet): ResultSet
- getRows(): List<JsonObject>
- getRows(boolean): List<JsonObject>
- getNumRows(): int
- getNumColumns(): int
- equals(Object): boolean
- hashCode(): int
- ResultSetConcurrency
- ResultSetConverter
- ResultSetType
- RuntimeSQLException
-
SQLClient
- getConnection(Handler<AsyncResult<SQLConnection>>): SQLClient
- close(Handler<AsyncResult<Void>>): void
- close(): void
- query(String, Handler<AsyncResult<ResultSet>>): SQLClient
- queryStream(String, Handler<AsyncResult<SQLRowStream>>): SQLClient
- queryStreamWithParams(String, JsonArray, Handler<AsyncResult<SQLRowStream>>): SQLClient
- queryWithParams(String, JsonArray, Handler<AsyncResult<ResultSet>>): SQLClient
- update(String, Handler<AsyncResult<UpdateResult>>): SQLClient
- updateWithParams(String, JsonArray, Handler<AsyncResult<UpdateResult>>): SQLClient
- call(String, Handler<AsyncResult<ResultSet>>): SQLClient
- callWithParams(String, JsonArray, JsonArray, Handler<AsyncResult<ResultSet>>): SQLClient
-
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
- 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
- setQueryTimeout(int): 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
- getTransactionIsolation(Handler<AsyncResult<TransactionIsolation>>): SQLConnection
- unwrap(): Object
-
SQLOperations
- query(String, Handler<AsyncResult<ResultSet>>): SQLOperations
- queryWithParams(String, JsonArray, Handler<AsyncResult<ResultSet>>): SQLOperations
- queryStream(String, Handler<AsyncResult<SQLRowStream>>): SQLOperations
- queryStreamWithParams(String, JsonArray, Handler<AsyncResult<SQLRowStream>>): SQLOperations
- querySingle(String, Handler<AsyncResult<JsonArray>>): SQLOperations
- querySingleWithParams(String, JsonArray, Handler<AsyncResult<JsonArray>>): SQLOperations
- update(String, Handler<AsyncResult<UpdateResult>>): SQLOperations
- updateWithParams(String, JsonArray, Handler<AsyncResult<UpdateResult>>): SQLOperations
- call(String, Handler<AsyncResult<ResultSet>>): SQLOperations
- callWithParams(String, JsonArray, JsonArray, Handler<AsyncResult<ResultSet>>): SQLOperations
-
SQLOptions
- setResultSetType(ResultSetType): SQLOptions
- readOnly: boolean
- catalog: String
- transactionIsolation: TransactionIsolation
- resultSetType: ResultSetType
- resultSetConcurrency: ResultSetConcurrency
- autoGeneratedKeys: boolean
- autoGeneratedKeysIndexes: JsonArray
- schema: String
- queryTimeout: int
- maxRows: int
- fetchDirection: FetchDirection
- fetchSize: int
- SQLOptions(): void
- SQLOptions(SQLOptions): void
- SQLOptions(JsonObject): void
- isReadOnly(): boolean
- setReadOnly(boolean): SQLOptions
- getCatalog(): String
- setCatalog(String): SQLOptions
- getTransactionIsolation(): TransactionIsolation
- setTransactionIsolation(TransactionIsolation): SQLOptions
- getResultSetType(): ResultSetType
- getResultSetConcurrency(): ResultSetConcurrency
- setResultSetConcurrency(ResultSetConcurrency): SQLOptions
- isAutoGeneratedKeys(): boolean
- setAutoGeneratedKeys(boolean): SQLOptions
- getSchema(): String
- setSchema(String): SQLOptions
- getQueryTimeout(): int
- setQueryTimeout(int): SQLOptions
- getFetchDirection(): FetchDirection
- setFetchDirection(FetchDirection): SQLOptions
- getFetchSize(): int
- setFetchSize(int): SQLOptions
- getAutoGeneratedKeysIndexes(): JsonArray
- setAutoGeneratedKeysIndexes(JsonArray): SQLOptions
- getMaxRows(): int
- setMaxRows(int): SQLOptions
- SQLOptionsConverter
-
SQLRowStream
- exceptionHandler(Handler<Throwable>): SQLRowStream
- handler(Handler<JsonArray>): SQLRowStream
- pause(): SQLRowStream
- resume(): SQLRowStream
- endHandler(Handler<Void>): SQLRowStream
- column(String): int
- columns(): List<String>
- resultSetClosedHandler(Handler<Void>): SQLRowStream
- moreResults(): void
- close(): void
- close(Handler<AsyncResult<Void>>): void
- TransactionIsolation
-
UpdateResult
- updated: int
- keys: JsonArray
- UpdateResult(): void
- UpdateResult(UpdateResult): void
- UpdateResult(JsonObject): void
- UpdateResult(int, JsonArray): void
- toJson(): JsonObject
- getUpdated(): int
- setUpdated(int): UpdateResult
- getKeys(): JsonArray
- setKeys(JsonArray): UpdateResult
- equals(Object): boolean
- hashCode(): int
- UpdateResultConverter
-
impl
-
RowStreamWrapper
- connection: SQLConnection
- rowStream: SQLRowStream
- RowStreamWrapper(SQLConnection, SQLRowStream): void
- closeConnection(Handler<AsyncResult<Void>>): void
- exceptionHandler(Handler<Throwable>): SQLRowStream
- handler(Handler<JsonArray>): SQLRowStream
- fetch(long): SQLRowStream
- pause(): SQLRowStream
- resume(): SQLRowStream
- endHandler(Handler<Void>): SQLRowStream
- column(String): int
- columns(): List<String>
- resultSetClosedHandler(Handler<Void>): SQLRowStream
- moreResults(): void
- close(): void
- close(Handler<AsyncResult<Void>>): void
-
RowStreamWrapper
-
jdbc
-
jdbcclient
-
JDBCConnectOptions
- dataSourceImplementation: String
- metricsEnabled: boolean
- jdbcUrl: String
- user: String
- password: String
- database: String
- connectTimeout: int
- idleTimeout: int
- tracingPolicy: TracingPolicy
- JDBCConnectOptions(): void
- JDBCConnectOptions(JsonObject): void
- getDataSourceImplementation(): String
- setDataSourceImplementation(String): JDBCConnectOptions
- isMetricsEnabled(): boolean
- setMetricsEnabled(boolean): JDBCConnectOptions
- getJdbcUrl(): String
- setJdbcUrl(String): JDBCConnectOptions
- getUser(): String
- setUser(String): JDBCConnectOptions
- getPassword(): String
- setPassword(String): JDBCConnectOptions
- getDatabase(): String
- setDatabase(String): JDBCConnectOptions
- getConnectTimeout(): int
- setConnectTimeout(int): JDBCConnectOptions
- getIdleTimeout(): int
- setIdleTimeout(int): JDBCConnectOptions
- getTracingPolicy(): TracingPolicy
- setTracingPolicy(TracingPolicy): JDBCConnectOptions
- toJson(): JsonObject
- JDBCConnectOptionsConverter
- JDBCPool
- SqlOutParam
-
impl
- AgroalCPDataSourceProvider
-
ConnectionImpl
- helper: JDBCStatementHelper
- context: ContextInternal
- conn: JDBCConnectionImpl
- sqlOptions: SQLOptions
- ConnectionImpl(JDBCStatementHelper, ContextInternal, SQLOptions, JDBCConnectionImpl): void
- isSsl(): boolean
- getDatabaseMetaData(): DatabaseMetadata
- init(Holder): void
- close(Holder, Promise<Void>): void
- getProcessId(): int
- getSecretKey(): int
- schedule(CommandBase<Object>, Promise<Object>): void
- handle(PrepareStatementCommand, Promise<PreparedStatement>): void
- handle(ExtendedQueryCommand<Object>, Promise<Boolean>): void
- handle(SimpleQueryCommand<Object>, Promise<Boolean>): void
- handle(TxCommand<Object>, Promise<Object>): void
- handle(JDBCQueryAction<Object, Object>, QueryResultHandler<Object>, Promise<Boolean>): void
-
JDBCPoolImpl
- vertx: VertxInternal
- client: JDBCClientImpl
- queryOptions: SQLOptions
- JDBCPoolImpl(Vertx, JDBCClientImpl, QueryTracer): void
- getConnection(Handler<AsyncResult<SqlConnection>>): void
- getConnection(): Future<SqlConnection>
- getConnectionInternal(ContextInternal): Future<SqlConnection>
- promise(): PromiseInternal<Object>
- promise(Handler<AsyncResult<Object>>): PromiseInternal<Object>
- close(Handler<AsyncResult<Void>>): void
- close(): Future<Void>
- schedule(CommandBase<Object>, Promise<Object>): void
-
JDBCRow
- desc: RowDesc
- JDBCRow(RowDesc): void
- JDBCRow(JDBCRow): void
- getColumnName(int): String
- getColumnIndex(String): int
- get(Class<Object>, int): Object
- getValues(Class<Object>, int): Object[]
- getNumeric(String): Numeric
- getArrayOfJsons(String): Object[]
- getArrayOfNumerics(String): Numeric[]
- getArrayOfChars(String): Character[]
- getChar(int): Character
- getNumeric(int): Numeric
- getJson(int): Object
- getArrayOfChars(int): Character[]
- getArrayOfJsons(int): Object[]
- getArrayOfNumerics(int): Numeric[]
- SqlOutParamImpl
-
actions
- JDBCPrepareStatementAction
-
JDBCPreparedBatch
- query: ExtendedQueryCommand<Object>
- listParams: List<Tuple>
- JDBCPreparedBatch(JDBCStatementHelper, SQLOptions, ExtendedQueryCommand<Object>, Collector<Row, Object, Object>, List<Tuple>): void
- execute(Connection): JDBCResponse<Object>
- prepare(Connection): PreparedStatement
- fillStatement(PreparedStatement, Connection, Tuple): void
- adaptType(Connection, Object): Object
-
JDBCPreparedQuery
- query: ExtendedQueryCommand<Object>
- params: Tuple
- outParams: List<Integer>
- countOut(Tuple): List<Integer>
- JDBCPreparedQuery(JDBCStatementHelper, SQLOptions, ExtendedQueryCommand<Object>, Collector<Row, Object, Object>, Tuple): void
- execute(Connection): JDBCResponse<Object>
- prepare(Connection): PreparedStatement
- fillStatement(PreparedStatement, Connection): void
- adaptType(Connection, Object): Object
- JDBCPreparedStatement
-
JDBCQueryAction
- collector: Collector<Row, Object, Object>
- JDBCQueryAction(JDBCStatementHelper, SQLOptions, Collector<Row, Object, Object>): void
- decode(Statement, boolean, boolean, List<Integer>): JDBCResponse<Object>
- decode(Statement, int[], boolean): JDBCResponse<Object>
- decodeResultSet(ResultSet, JDBCResponse<Object>): void
- decodeRawResultSet(ResultSet): Object
- decodeOutput(CallableStatement, List<Integer>, JDBCResponse<Object>): void
- decodeReturnedKeys(Statement, JDBCResponse<Object>): void
- convertSqlValue(Object): Object
- JDBCResponse
- JDBCSimpleQueryAction
- JDBCTxOp
-
JDBCConnectOptions
-
ext
-
vertx