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.11.3
- com.fasterxml.jackson.core/jackson-core/2.11.3
- com.fasterxml.jackson.core/jackson-databind/2.11.3
- com.github.jponge/lzma-java/1.3
- 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.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.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.tools/blockhound/1.0.3.RELEASE
- io.vertx/vertx-codegen/4.0.0
- io.vertx/vertx-core/4.0.0
- io.vertx/vertx-docgen/0.9.2
- java/11
- 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.65
- org.bouncycastle/bcprov-jdk15on/1.65
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.slf4j/slf4j-api/1.7.21
Declarations
-
examples
-
SqlClientExamples
- queries01(SqlClient): void
- queries02(SqlClient): void
- queries03(SqlClient): void
- queries04(SqlClient): void
- queries05(Row): void
- queries06(Row): void
- queries07(Row): void
- queries08(SqlClient): void
- queries09(SqlClient, SqlConnectOptions): void
- queries10(SqlConnection): void
- usingConnections01(Vertx, Pool): void
- usingConnections02(SqlConnection): void
- usingConnections03(Pool): void
- transaction01(Pool): void
- transaction02(Transaction): void
- transaction03(Pool): void
- usingCursors01(SqlConnection): void
- usingCursors02(Cursor): void
- usingCursors03(SqlConnection): void
- tracing01(SqlConnectOptions): void
-
SqlClientExamples
-
io
-
vertx
-
sqlclient
- Cursor
-
Pool
- pool(SqlConnectOptions): Pool
- pool(SqlConnectOptions, PoolOptions): Pool
- pool(Vertx, SqlConnectOptions, PoolOptions): Pool
- getConnection(Handler<AsyncResult<SqlConnection>>): void
- getConnection(): Future<SqlConnection>
- query(String): Query<RowSet<Row>>
- preparedQuery(String): PreparedQuery<RowSet<Row>>
- withTransaction(Function<SqlConnection, Future<Object>>, Handler<AsyncResult<Object>>): void
- withTransaction(Function<SqlConnection, Future<Object>>): Future<Object>
- withConnection(Function<SqlConnection, Future<Object>>, Handler<AsyncResult<Object>>): void
- withConnection(Function<SqlConnection, Future<Object>>): Future<Object>
- close(Handler<AsyncResult<Void>>): void
-
PoolOptions
- DEFAULT_MAX_SIZE: int
- DEFAULT_MAX_WAIT_QUEUE_SIZE: int
- maxSize: int
- maxWaitQueueSize: int
- PoolOptions(): void
- PoolOptions(JsonObject): void
- PoolOptions(PoolOptions): void
- getMaxSize(): int
- setMaxSize(int): PoolOptions
- getMaxWaitQueueSize(): int
- setMaxWaitQueueSize(int): PoolOptions
- toJson(): JsonObject
- equals(Object): boolean
- hashCode(): int
- PoolOptionsConverter
-
PreparedQuery
- execute(Tuple, Handler<AsyncResult<Object>>): void
- execute(Tuple): Future<Object>
- executeBatch(List<Tuple>, Handler<AsyncResult<Object>>): void
- executeBatch(List<Tuple>): Future<Object>
- collecting(Collector<Row, Object, Object>): PreparedQuery<SqlResult<Object>>
- mapping(Function<Row, Object>): PreparedQuery<RowSet<Object>>
- PreparedStatement
- PropertyKind
- Query
-
Row
- getColumnName(int): String
- getColumnIndex(String): int
- getValue(String): Object
- getBoolean(String): Boolean
- getShort(String): Short
- getInteger(String): Integer
- getLong(String): Long
- getFloat(String): Float
- getDouble(String): Double
- getNumeric(String): Numeric
- getString(String): String
- getJson(String): Object
- getJsonObject(String): JsonObject
- getJsonArray(String): JsonArray
- getTemporal(String): Temporal
- getLocalDate(String): LocalDate
- getLocalTime(String): LocalTime
- getLocalDateTime(String): LocalDateTime
- getOffsetTime(String): OffsetTime
- getOffsetDateTime(String): OffsetDateTime
- getBuffer(String): Buffer
- getUUID(String): UUID
- getBigDecimal(String): BigDecimal
- getArrayOfBooleans(String): Boolean[]
- getArrayOfShorts(String): Short[]
- getArrayOfIntegers(String): Integer[]
- getArrayOfLongs(String): Long[]
- getArrayOfFloats(String): Float[]
- getArrayOfDoubles(String): Double[]
- getArrayOfNumerics(String): Numeric[]
- getArrayOfStrings(String): String[]
- getArrayOfJsonObjects(String): JsonObject[]
- getArrayOfJsonArrays(String): JsonArray[]
- getArrayOfTemporals(String): Temporal[]
- getArrayOfLocalDates(String): LocalDate[]
- getArrayOfLocalTimes(String): LocalTime[]
- getArrayOfLocalDateTimes(String): LocalDateTime[]
- getArrayOfOffsetTimes(String): OffsetTime[]
- getArrayOfOffsetDateTimes(String): OffsetDateTime[]
- getArrayOfBuffers(String): Buffer[]
- getArrayOfUUIDs(String): UUID[]
- getArrayOfBigDecimals(String): BigDecimal[]
- getArrayOfJsons(String): Object[]
- get(Class<Object>, String): Object
- toJson(): JsonObject
- RowIterator
- RowSet
- RowStream
- SqlClient
-
SqlConnectOptions
- DEFAULT_CACHE_PREPARED_STATEMENTS: boolean
- DEFAULT_PREPARED_STATEMENT_CACHE_MAX_SIZE: int
- DEFAULT_PREPARED_STATEMENT_CACHE_SQL_LIMIT: int
- DEFAULT_PREPARED_STATEMENT_CACHE_FILTER: Predicate<String>
- host: String
- port: int
- user: String
- password: String
- database: String
- cachePreparedStatements: boolean
- preparedStatementCacheMaxSize: int
- preparedStatementCacheSqlFilter: Predicate<String>
- properties: Map<String, String>
- tracingPolicy: TracingPolicy
- SqlConnectOptions(): void
- SqlConnectOptions(JsonObject): void
- SqlConnectOptions(SqlConnectOptions): void
- getHost(): String
- setHost(String): SqlConnectOptions
- getPort(): int
- setPort(int): SqlConnectOptions
- getUser(): String
- setUser(String): SqlConnectOptions
- getPassword(): String
- setPassword(String): SqlConnectOptions
- getDatabase(): String
- setDatabase(String): SqlConnectOptions
- getCachePreparedStatements(): boolean
- setCachePreparedStatements(boolean): SqlConnectOptions
- getPreparedStatementCacheMaxSize(): int
- setPreparedStatementCacheMaxSize(int): SqlConnectOptions
- getPreparedStatementCacheSqlFilter(): Predicate<String>
- setPreparedStatementCacheSqlFilter(Predicate<String>): SqlConnectOptions
- setPreparedStatementCacheSqlLimit(int): SqlConnectOptions
- getProperties(): Map<String, String>
- setProperties(Map<String, String>): SqlConnectOptions
- addProperty(String, String): SqlConnectOptions
- getSocketAddress(): SocketAddress
- getTracingPolicy(): TracingPolicy
- setTracingPolicy(TracingPolicy): SqlConnectOptions
- toJson(): JsonObject
- init(): void
- SqlConnectOptionsConverter
-
SqlConnection
- prepare(String, Handler<AsyncResult<PreparedStatement>>): SqlConnection
- prepare(String): Future<PreparedStatement>
- exceptionHandler(Handler<Throwable>): SqlConnection
- closeHandler(Handler<Void>): SqlConnection
- begin(Handler<AsyncResult<Transaction>>): void
- begin(): Future<Transaction>
- isSSL(): boolean
- close(Handler<AsyncResult<Void>>): void
- databaseMetadata(): DatabaseMetadata
- SqlResult
- Transaction
- TransactionRollbackException
-
Tuple
- getString(int): String
- getNumeric(int): Numeric
- getBoolean(int): Boolean
- getShort(int): Short
- JSON_NULL: Object
- tuple(): Tuple
- from(List<Object>): Tuple
- from(Object[]): Tuple
- wrap(List<Object>): Tuple
- wrap(Object[]): Tuple
- of(Object): Tuple
- of(Object, Object): Tuple
- of(Object, Object, Object): Tuple
- of(Object, Object, Object, Object): Tuple
- of(Object, Object, Object, Object, Object): Tuple
- of(Object, Object, Object, Object, Object, Object): Tuple
- of(Object, Object[]): Tuple
- tuple(List<Object>): Tuple
- getValue(int): Object
- getInteger(int): Integer
- getLong(int): Long
- getFloat(int): Float
- getDouble(int): Double
- getJsonObject(int): JsonObject
- getJsonArray(int): JsonArray
- getJson(int): Object
- getTemporal(int): Temporal
- getLocalDate(int): LocalDate
- getLocalTime(int): LocalTime
- getLocalDateTime(int): LocalDateTime
- getOffsetTime(int): OffsetTime
- getOffsetDateTime(int): OffsetDateTime
- getBuffer(int): Buffer
- getUUID(int): UUID
- getBigDecimal(int): BigDecimal
- getArrayOfBooleans(int): Boolean[]
- getArrayOfShorts(int): Short[]
- getArrayOfIntegers(int): Integer[]
- getArrayOfLongs(int): Long[]
- getArrayOfFloats(int): Float[]
- getArrayOfDoubles(int): Double[]
- getArrayOfNumerics(int): Numeric[]
- getArrayOfStrings(int): String[]
- getArrayOfJsonObjects(int): JsonObject[]
- getArrayOfJsonArrays(int): JsonArray[]
- getArrayOfJsons(int): Object[]
- getArrayOfTemporals(int): Temporal[]
- getArrayOfLocalDates(int): LocalDate[]
- getArrayOfLocalTimes(int): LocalTime[]
- getArrayOfLocalDateTimes(int): LocalDateTime[]
- getArrayOfOffsetTimes(int): OffsetTime[]
- getArrayOfOffsetDateTimes(int): OffsetDateTime[]
- getArrayOfBuffers(int): Buffer[]
- getArrayOfUUIDs(int): UUID[]
- getArrayOfBigDecimals(int): BigDecimal[]
- addValue(Object): Tuple
- addBoolean(Boolean): Tuple
- addShort(Short): Tuple
- addInteger(Integer): Tuple
- addLong(Long): Tuple
- addFloat(Float): Tuple
- addDouble(Double): Tuple
- addString(String): Tuple
- addJsonObject(JsonObject): Tuple
- addJsonArray(JsonArray): Tuple
- addTemporal(Temporal): Tuple
- addLocalDate(LocalDate): Tuple
- addLocalTime(LocalTime): Tuple
- addLocalDateTime(LocalDateTime): Tuple
- addOffsetTime(OffsetTime): Tuple
- addOffsetDateTime(OffsetDateTime): Tuple
- addBuffer(Buffer): Tuple
- addUUID(UUID): Tuple
- addBigDecimal(BigDecimal): Tuple
- addArrayOfBoolean(Boolean[]): Tuple
- addArrayOfShort(Short[]): Tuple
- addArrayOfInteger(Integer[]): Tuple
- addArrayOfLong(Long[]): Tuple
- addArrayOfFloat(Float[]): Tuple
- addArrayOfDouble(Double[]): Tuple
- addArrayOfString(String[]): Tuple
- addArrayOfJsonObject(JsonObject[]): Tuple
- addArrayOfJsonArray(JsonArray[]): Tuple
- addArrayOfTemporal(Temporal[]): Tuple
- addArrayOfLocalDate(LocalDate[]): Tuple
- addArrayOfLocalTime(LocalTime[]): Tuple
- addArrayOfLocalDateTime(LocalDateTime[]): Tuple
- addArrayOfOffsetTime(OffsetTime[]): Tuple
- addArrayOfOffsetDateTime(OffsetDateTime[]): Tuple
- addArrayOfBuffer(Buffer[]): Tuple
- addArrayOfUUID(UUID[]): Tuple
- addArrayOfBigDecimal(BigDecimal[]): Tuple
- get(Class<Object>, int): Object
- size(): int
- clear(): void
- types(): List<Class<Object>>
- deepToString(): String
-
data
-
Numeric
- NaN: Numeric
- value: Number
- create(Number): Numeric
- parse(String): Numeric
- Numeric(Number): void
- shortValue(): short
- intValue(): int
- longValue(): long
- floatValue(): float
- doubleValue(): double
- isNaN(): boolean
- bigDecimalValue(): BigDecimal
- bigIntegerValue(): BigInteger
- equals(Object): boolean
- hashCode(): int
- toString(): String
-
Numeric
- desc
-
impl
- ArrayTuple
- Connection
- ConnectionFactory
-
CursorImpl
- conn: Connection
- tracer: QueryTracer
- metrics: ClientMetrics
- ps: PreparedStatementImpl
- context: ContextInternal
- autoCommit: boolean
- params: TupleInternal
- id: String
- closed: boolean
- result: QueryResultBuilder<RowSet<Row>, RowSetImpl<Row>, RowSet<Row>>
- CursorImpl(PreparedStatementImpl, Connection, QueryTracer, ClientMetrics, ContextInternal, boolean, TupleInternal): void
- hasMore(): boolean
- read(int, Handler<AsyncResult<RowSet<Row>>>): void
- read(int): Future<RowSet<Row>>
- isClosed(): boolean
- close(Handler<AsyncResult<Void>>): void
- close(): Future<Void>
- close(Promise<Void>): void
- ErrorMessageFactory
- ListTuple
- Notice
- Notification
- ParamDesc
-
PoolBase
- context: ContextInternal
- vertx: VertxInternal
- factory: ConnectionFactory
- pool: ConnectionPool
- closeFuture: CloseFuture
- PoolBase(ContextInternal, ConnectionFactory, QueryTracer, ClientMetrics, PoolOptions): void
- closeFuture(): CloseFuture
- promise(): PromiseInternal<Object>
- promise(Handler<AsyncResult<Object>>): PromiseInternal<Object>
- connect(Handler<AsyncResult<Connection>>): void
- getConnection(Handler<AsyncResult<SqlConnection>>): void
- getConnection(): Future<SqlConnection>
- schedule(CommandBase<Object>, Promise<Object>): void
- acquire(Handler<AsyncResult<Connection>>): void
- CommandWaiter
- wrap(ContextInternal, Connection): SqlConnectionImpl
- close(Promise<Void>): void
- close(): Future<Void>
- close(Handler<AsyncResult<Void>>): void
- doClose(): Future<Void>
- PreparedStatement
-
PreparedStatementImpl
- create(Connection, QueryTracer, ClientMetrics, ContextInternal, PreparedStatement, boolean): PreparedStatement
- create(Connection, QueryTracer, ClientMetrics, ContextInternal, String, boolean): PreparedStatement
- conn: Connection
- tracer: QueryTracer
- metrics: ClientMetrics
- context: ContextInternal
- sql: String
- promise: Promise<PreparedStatement>
- future: Future<PreparedStatement>
- autoCommit: boolean
- closed: AtomicBoolean
- PreparedStatementImpl(Connection, QueryTracer, ClientMetrics, ContextInternal, PreparedStatement, boolean): void
- PreparedStatementImpl(Connection, QueryTracer, ClientMetrics, ContextInternal, String, boolean): void
- query(): PreparedQuery<RowSet<Row>>
- withPreparedStatement(Tuple, Handler<AsyncResult<PreparedStatement>>): void
- execute(Tuple, int, String, boolean, QueryExecutor<Object, SqlResultBase, SqlResult>, PromiseInternal<SqlResult>): void
- executeBatch(List<Tuple>, QueryExecutor<Object, SqlResultBase, SqlResult>, PromiseInternal<SqlResult>): void
- cursor(Tuple): Cursor
- cursor(TupleInternal): Cursor
- close(): Future<Void>
- createStream(int, Tuple): RowStream<Row>
- close(Handler<AsyncResult<Void>>): void
- closeCursor(String, Promise<Void>): void
- PreparedStatementQuery
-
QueryBase
- builder: QueryExecutor<Object, SqlResultBase, SqlResult>
- QueryBase(QueryExecutor<Object, SqlResultBase, SqlResult>): void
- copy(QueryExecutor<Object, SqlResultBase, SqlResult>): QueryBase<Object, SqlResult>
- collecting(Collector<Row, Object, Object>): Query<SqlResult<Object>>
- mapping(Function<Row, Object>): Query<RowSet<Object>>
-
QueryExecutor
- metrics: ClientMetrics
- tracer: QueryTracer
- factory: Function<Object, SqlResultBase>
- collector: Collector<Row, Object, Object>
- QueryExecutor(QueryTracer, ClientMetrics, Function<Object, SqlResultBase>, Collector<Row, Object, Object>): void
- tracer(): QueryTracer
- metrics(): ClientMetrics
- createHandler(PromiseInternal<SqlResult>, Object): QueryResultBuilder<Object, SqlResultBase, SqlResult>
- createHandler(PromiseInternal<SqlResult>, Object, Object): QueryResultBuilder<Object, SqlResultBase, SqlResult>
- executeSimpleQuery(CommandScheduler, String, boolean, boolean, PromiseInternal<SqlResult>): void
- executeExtendedQuery(CommandScheduler, PreparedStatement, boolean, Tuple, int, String, boolean, PromiseInternal<SqlResult>): QueryResultBuilder<Object, SqlResultBase, SqlResult>
- executeExtendedQuery(CommandScheduler, String, boolean, Tuple, PromiseInternal<SqlResult>): void
- createExtendedQueryCommand(String, boolean, Tuple, QueryResultBuilder<Object, SqlResultBase, SqlResult>): ExtendedQueryCommand<Object>
- executeBatchQuery(CommandScheduler, PreparedStatement, boolean, List<Tuple>, PromiseInternal<SqlResult>): void
- executeBatchQuery(CommandScheduler, String, boolean, List<Tuple>, PromiseInternal<SqlResult>): void
- createBatchQueryCommand(String, boolean, List<Tuple>, QueryResultBuilder<Object, SqlResultBase, SqlResult>): ExtendedQueryCommand<Object>
-
QueryResultBuilder
- handler: Promise<SqlResult>
- factory: Function<Object, SqlResultBase>
- context: ContextInternal
- tracer: QueryTracer
- tracingPayload: Object
- metrics: ClientMetrics
- metric: Object
- first: SqlResultBase
- current: SqlResultBase
- failure: Throwable
- suspended: boolean
- QueryResultBuilder(Function<Object, SqlResultBase>, QueryTracer, Object, ClientMetrics, Object, PromiseInternal<SqlResult>): void
- handleResult(int, int, RowDesc, Object, Throwable): void
- handleResult(SqlResultBase): void
- addProperty(PropertyKind<Object>, Object): void
- tryComplete(Boolean): boolean
- tryFail(Throwable): boolean
- future(): Future<Boolean>
- isSuspended(): boolean
- QueryResultHandler
-
RowDecoder
- collector: Collector<Row, Object, Object>
- accumulator: BiConsumer<Object, Row>
- size: int
- container: Object
- failure: Throwable
- result: Object
- RowDecoder(Collector<Row, Object, Object>): void
- size(): int
- decodeRow(int, ByteBuf): Row
- handleRow(int, ByteBuf): void
- result(): Object
- complete(): Throwable
- reset(): void
- RowDesc
-
RowSetImpl
- COLLECTOR: Collector<Row, RowSetImpl<Row>, RowSet<Row>>
- collector(Function<Row, Object>): Collector<Row, RowSetImpl<Object>, RowSet<Object>>
- FACTORY: Function<RowSet<Row>, RowSetImpl<Row>>
- factory(): Function<RowSet<Object>, RowSetImpl<Object>>
- list: ArrayList<Object>
- value(): RowSet<Object>
- iterator(): RowIterator<Object>
- next(): RowSetImpl<Object>
-
RowStreamImpl
- fetch: int
- ps: PreparedStatementImpl
- context: ContextInternal
- params: Tuple
- endHandler: Handler<Void>
- rowHandler: Handler<Row>
- exceptionHandler: Handler<Throwable>
- demand: long
- emitting: boolean
- cursor: Cursor
- readInProgress: boolean
- result: Iterator<Row>
- RowStreamImpl(PreparedStatementImpl, ContextInternal, int, Tuple): void
- cursor(): Cursor
- exceptionHandler(Handler<Throwable>): RowStream<Row>
- handler(Handler<Row>): RowStream<Row>
- pause(): RowStream<Row>
- fetch(long): RowStream<Row>
- resume(): RowStream<Row>
- endHandler(Handler<Void>): RowStream<Row>
- handle(AsyncResult<RowSet<Row>>): void
- close(): Future<Void>
- close(Handler<AsyncResult<Void>>): void
- checkPending(): void
- RowStreamInternal
-
SocketConnectionBase
- logger: Logger
- Status
- PENDING_CMD_CONNECTION_CORRUPT_MSG: String
- psCache: PreparedStatementCache
- preparedStatementCacheSqlFilter: Predicate<String>
- context: ContextInternal
- holder: Holder
- pipeliningLimit: int
- pending: ArrayDeque<CommandBase<Object>>
- executing: boolean
- inflight: int
- paused: boolean
- socket: NetSocketInternal
- status: Status
- SocketConnectionBase(NetSocketInternal, boolean, int, Predicate<String>, int, ContextInternal): void
- context(): Context
- init(): void
- socket(): NetSocketInternal
- isSsl(): boolean
- init(Holder): void
- getProcessId(): int
- getSecretKey(): int
- close(Holder, Promise<Void>): void
- schedule(CommandBase<Object>, Promise<Object>): void
- doSchedule(CommandBase<Object>, Handler<AsyncResult<Object>>): void
- checkPending(): void
- prepareCommand(ExtendedQueryCommand<Object>, boolean, boolean): PrepareStatementCommand
- handleMessage(Object): void
- handleEvent(Object): void
- evictStatementIfNecessary(): CloseStatementCommand
- cacheStatement(PreparedStatement): void
- removeCachedStatement(String): void
- handleClosed(Void): void
- handleException(Throwable): void
- handleClose(Throwable): void
-
SqlClientBase
- tracer: QueryTracer
- metrics: ClientMetrics
- SqlClientBase(QueryTracer, ClientMetrics): void
- appendQueryPlaceholder(StringBuilder, int, int): int
- promise(): PromiseInternal<Object>
- promise(Handler<AsyncResult<Object>>): PromiseInternal<Object>
- query(String): Query<RowSet<Row>>
- preparedQuery(String): PreparedQuery<RowSet<Row>>
- autoCommit(): boolean
- QueryImpl
- PreparedQueryImpl
- SqlClientInternal
- SqlConnectionBase
-
SqlConnectionFactoryBase
- netClient: NetClient
- context: ContextInternal
- socketAddress: SocketAddress
- username: String
- password: String
- database: String
- properties: Map<String, String>
- cachePreparedStatements: boolean
- preparedStatementCacheSize: int
- preparedStatementCacheSqlFilter: Predicate<String>
- clientCloseFuture: CloseFuture
- reconnectAttempts: int
- reconnectInterval: long
- SqlConnectionFactoryBase(ContextInternal, SqlConnectOptions): void
- connect(): Future<Connection>
- close(Promise<Void>): void
- doConnectWithRetry(Promise<Connection>, int): void
- initializeConfiguration(SqlConnectOptions): void
- configureNetClientOptions(NetClientOptions): void
- doConnectInternal(Promise<Connection>): void
-
SqlConnectionImpl
- exceptionHandler: Handler<Throwable>
- closeHandler: Handler<Void>
- tx: TransactionImpl
- SqlConnectionImpl(ContextInternal, Connection, QueryTracer, ClientMetrics): void
- promise(): PromiseInternal<Object>
- promise(Handler<AsyncResult<Object>>): PromiseInternal<Object>
- handleClosed(): void
- schedule(CommandBase<Object>, Promise<Object>): void
- handleException(Throwable): void
- isSSL(): boolean
- databaseMetadata(): DatabaseMetadata
- closeHandler(Handler<Void>): SqlConnection
- exceptionHandler(Handler<Throwable>): SqlConnection
- begin(): Future<Transaction>
- autoCommit(): boolean
- begin(Handler<AsyncResult<Transaction>>): void
- handleEvent(Object): void
- close(): Future<Void>
- close(Handler<AsyncResult<Void>>): void
- close(Promise<Void>): void
-
SqlResultBase
- updated: int
- columnNames: List<String>
- columnDescriptors: List<ColumnDescriptor>
- size: int
- next: SqlResult<Object>
- properties: Map<PropertyKind<Object>, Object>
- columnsNames(): List<String>
- columnDescriptors(): List<ColumnDescriptor>
- rowCount(): int
- size(): int
- property(PropertyKind<Object>): Object
- next(): SqlResult<Object>
- SqlResultImpl
- StringLongSequence
-
TransactionImpl
- ST_BEGIN: int
- ST_PENDING: int
- ST_PROCESSING: int
- ST_COMPLETED: int
- context: ContextInternal
- connection: Connection
- pending: Deque<CommandBase<Object>>
- status: int
- completion: Promise<Void>
- TransactionImpl(ContextInternal, Connection): void
- begin(): Future<Transaction>
- execute(CommandBase<Object>): void
- wrap(Promise<Object>): Handler<AsyncResult<Object>>
- afterBegin(AsyncResult<Transaction>): void
- checkPending(): void
- schedule(CommandBase<Object>, Promise<Object>): void
- schedule(CommandBase<Object>): void
- commit(): Future<Void>
- commit(Handler<AsyncResult<Void>>): void
- rollback(): Future<Void>
- rollback(Handler<AsyncResult<Void>>): void
- txCommand(Kind, Promise<Void>): TxCommand<Void>
- tryComplete(Kind): void
- completion(Handler<AsyncResult<Void>>): void
- completion(): Future<Void>
- TupleInternal
- Utils
- cache
- codec
- command
- pool
- tracing
- spi
-
sqlclient
-
vertx