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.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
- 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.54
- org.bouncycastle/bcprov-jdk15on/1.54
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.mvel/mvel2/2.3.1.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(Vertx, SqlConnectOptions, PoolOptions): void
- queries10(SqlClient): void
- usingConnections01(Vertx, Pool): void
- usingConnections02(SqlConnection): void
- usingConnections03(SqlConnection): void
- transaction01(Pool): void
- transaction02(Transaction): void
- transaction03(Pool): void
- usingCursors01(SqlConnection): void
- usingCursors02(Cursor): void
- usingCursors03(SqlConnection): void
-
SqlClientExamples
-
io
-
vertx
-
sqlclient
- Cursor
-
Pool
- close(): void
- preparedQuery(String, Handler<AsyncResult<RowSet>>): Pool
- preparedQuery(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): Pool
- query(String, Handler<AsyncResult<RowSet>>): Pool
- query(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): Pool
- preparedQuery(String, Tuple, Handler<AsyncResult<RowSet>>): Pool
- preparedQuery(String, Tuple, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): Pool
- preparedBatch(String, List<Tuple>, Handler<AsyncResult<RowSet>>): Pool
- preparedBatch(String, List<Tuple>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): Pool
- getConnection(Handler<AsyncResult<SqlConnection>>): void
- begin(Handler<AsyncResult<Transaction>>): 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(Handler<AsyncResult<RowSet>>): PreparedQuery
- execute(Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PreparedQuery
- execute(Tuple, Handler<AsyncResult<RowSet>>): PreparedQuery
- execute(Tuple, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PreparedQuery
- cursor(): Cursor
- cursor(Tuple): Cursor
- createStream(int, Tuple): RowStream<Row>
- batch(List<Tuple>, Handler<AsyncResult<RowSet>>): PreparedQuery
- batch(List<Tuple>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PreparedQuery
- close(): void
- close(Handler<AsyncResult<Void>>): void
-
Row
- getColumnName(int): String
- getColumnIndex(String): int
- getBoolean(String): Boolean
- getValue(String): Object
- getShort(String): Short
- getInteger(String): Integer
- getLong(String): Long
- getFloat(String): Float
- getDouble(String): Double
- getString(String): String
- getBuffer(String): Buffer
- getTemporal(String): Temporal
- getLocalDate(String): LocalDate
- getLocalTime(String): LocalTime
- getLocalDateTime(String): LocalDateTime
- getOffsetTime(String): OffsetTime
- getOffsetDateTime(String): OffsetDateTime
- getUUID(String): UUID
- getBigDecimal(String): BigDecimal
- getIntegerArray(String): Integer[]
- getBooleanArray(String): Boolean[]
- getShortArray(String): Short[]
- getLongArray(String): Long[]
- getFloatArray(String): Float[]
- getDoubleArray(String): Double[]
- getStringArray(String): String[]
- getLocalDateArray(String): LocalDate[]
- getLocalTimeArray(String): LocalTime[]
- getOffsetTimeArray(String): OffsetTime[]
- getLocalDateTimeArray(String): LocalDateTime[]
- getOffsetDateTimeArray(String): OffsetDateTime[]
- getBufferArray(String): Buffer[]
- getUUIDArray(String): UUID[]
- getValues(Class<Object>, int): Object[]
- RowIterator
- RowSet
- RowStream
-
SqlClient
- query(String, Handler<AsyncResult<RowSet>>): SqlClient
- query(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): SqlClient
- preparedQuery(String, Handler<AsyncResult<RowSet>>): SqlClient
- preparedQuery(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): SqlClient
- preparedQuery(String, Tuple, Handler<AsyncResult<RowSet>>): SqlClient
- preparedQuery(String, Tuple, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): SqlClient
- preparedBatch(String, List<Tuple>, Handler<AsyncResult<RowSet>>): SqlClient
- preparedBatch(String, List<Tuple>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): SqlClient
- close(): void
-
SqlConnectOptions
- DEFAULT_CACHE_PREPARED_STATEMENTS: boolean
- DEFAULT_PREPARED_STATEMENT_CACHE_MAX_SIZE: int
- DEFAULT_PREPARED_STATEMENT_CACHE_SQL_LIMIT: int
- host: String
- port: int
- user: String
- password: String
- database: String
- cachePreparedStatements: boolean
- preparedStatementCacheMaxSize: int
- preparedStatementCacheSqlLimit: int
- properties: Map<String, String>
- 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
- getPreparedStatementCacheSqlLimit(): int
- setPreparedStatementCacheSqlLimit(int): SqlConnectOptions
- getProperties(): Map<String, String>
- setProperties(Map<String, String>): SqlConnectOptions
- addProperty(String, String): SqlConnectOptions
- toJson(): JsonObject
- init(): void
- checkParameterNonNull(Object, String): void
- SqlConnectOptionsConverter
-
SqlConnection
- prepare(String, Handler<AsyncResult<PreparedQuery>>): SqlConnection
- exceptionHandler(Handler<Throwable>): SqlConnection
- closeHandler(Handler<Void>): SqlConnection
- begin(): Transaction
- isSSL(): boolean
- close(): void
- preparedQuery(String, Handler<AsyncResult<RowSet>>): SqlConnection
- preparedQuery(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): SqlConnection
- query(String, Handler<AsyncResult<RowSet>>): SqlConnection
- query(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): SqlConnection
- preparedQuery(String, Tuple, Handler<AsyncResult<RowSet>>): SqlConnection
- preparedQuery(String, Tuple, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): SqlConnection
- preparedBatch(String, List<Tuple>, Handler<AsyncResult<RowSet>>): SqlConnection
- preparedBatch(String, List<Tuple>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): SqlConnection
- SqlResult
-
Transaction
- prepare(String, Handler<AsyncResult<PreparedQuery>>): Transaction
- commit(): void
- commit(Handler<AsyncResult<Void>>): void
- rollback(): void
- rollback(Handler<AsyncResult<Void>>): void
- abortHandler(Handler<Void>): Transaction
- query(String, Handler<AsyncResult<RowSet>>): Transaction
- query(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): Transaction
- preparedQuery(String, Handler<AsyncResult<RowSet>>): Transaction
- preparedQuery(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): Transaction
- preparedQuery(String, Tuple, Handler<AsyncResult<RowSet>>): Transaction
- preparedQuery(String, Tuple, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): Transaction
- preparedBatch(String, List<Tuple>, Handler<AsyncResult<RowSet>>): Transaction
- preparedBatch(String, List<Tuple>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): Transaction
- close(): void
-
Tuple
- getFloat(int): Float
- JSON_NULL: Object
- tuple(): 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
- getBoolean(int): Boolean
- getValue(int): Object
- getShort(int): Short
- getInteger(int): Integer
- getLong(int): Long
- getDouble(int): Double
- getString(int): String
- getTemporal(int): Temporal
- getLocalDate(int): LocalDate
- getLocalTime(int): LocalTime
- getLocalDateTime(int): LocalDateTime
- getOffsetTime(int): OffsetTime
- getOffsetDateTime(int): OffsetDateTime
- getUUID(int): UUID
- getBigDecimal(int): BigDecimal
- getIntegerArray(int): Integer[]
- getBooleanArray(int): Boolean[]
- getShortArray(int): Short[]
- getLongArray(int): Long[]
- getFloatArray(int): Float[]
- getDoubleArray(int): Double[]
- getStringArray(int): String[]
- getLocalDateArray(int): LocalDate[]
- getLocalTimeArray(int): LocalTime[]
- getOffsetTimeArray(int): OffsetTime[]
- getLocalDateTimeArray(int): LocalDateTime[]
- getOffsetDateTimeArray(int): OffsetDateTime[]
- getBufferArray(int): Buffer[]
- getUUIDArray(int): UUID[]
- getBuffer(int): Buffer
- addBoolean(Boolean): Tuple
- addValue(Object): Tuple
- addShort(Short): Tuple
- addInteger(Integer): Tuple
- addLong(Long): Tuple
- addFloat(Float): Tuple
- addDouble(Double): Tuple
- addString(String): Tuple
- addBuffer(Buffer): Tuple
- addTemporal(Temporal): Tuple
- addLocalDate(LocalDate): Tuple
- addLocalTime(LocalTime): Tuple
- addLocalDateTime(LocalDateTime): Tuple
- addOffsetTime(OffsetTime): Tuple
- addOffsetDateTime(OffsetDateTime): Tuple
- addUUID(UUID): Tuple
- addBigDecimal(BigDecimal): Tuple
- addIntegerArray(Integer[]): Tuple
- addBooleanArray(Boolean[]): Tuple
- addShortArray(Short[]): Tuple
- addLongArray(Long[]): Tuple
- addFloatArray(Float[]): Tuple
- addDoubleArray(Double[]): Tuple
- addStringArray(String[]): Tuple
- addLocalDateArray(LocalDate[]): Tuple
- addLocalTimeArray(LocalTime[]): Tuple
- addOffsetTimeArray(OffsetTime[]): Tuple
- addLocalDateTimeArray(LocalDateTime[]): Tuple
- addOffsetDateTimeArray(OffsetDateTime[]): Tuple
- addBufferArray(Buffer[]): Tuple
- addUUIDArray(UUID[]): Tuple
- get(Class<Object>, int): Object
- getValues(Class<Object>, int): Object[]
- addValues(Object[]): Tuple
- size(): int
- clear(): void
-
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
-
impl
-
ArrayTuple
- EMPTY: Tuple
- ArrayTuple(int): void
- ArrayTuple(Collection<Object>): void
- get(Class<Object>, int): Object
- getValues(Class<Object>, int): Object[]
- getBoolean(int): Boolean
- getValue(int): Object
- getShort(int): Short
- getInteger(int): Integer
- getLong(int): Long
- getFloat(int): Float
- getDouble(int): Double
- getBigDecimal(int): BigDecimal
- getIntegerArray(int): Integer[]
- getBooleanArray(int): Boolean[]
- getShortArray(int): Short[]
- getLongArray(int): Long[]
- getFloatArray(int): Float[]
- getDoubleArray(int): Double[]
- getStringArray(int): String[]
- getLocalDateArray(int): LocalDate[]
- getLocalTimeArray(int): LocalTime[]
- getOffsetTimeArray(int): OffsetTime[]
- getLocalDateTimeArray(int): LocalDateTime[]
- getOffsetDateTimeArray(int): OffsetDateTime[]
- getBufferArray(int): Buffer[]
- getUUIDArray(int): UUID[]
- getString(int): String
- getBuffer(int): Buffer
- getTemporal(int): Temporal
- getLocalDate(int): LocalDate
- getLocalTime(int): LocalTime
- getLocalDateTime(int): LocalDateTime
- getOffsetTime(int): OffsetTime
- getOffsetDateTime(int): OffsetDateTime
- getUUID(int): UUID
- addBoolean(Boolean): Tuple
- addValue(Object): Tuple
- addShort(Short): Tuple
- addInteger(Integer): Tuple
- addLong(Long): Tuple
- addFloat(Float): Tuple
- addDouble(Double): Tuple
- addString(String): Tuple
- addBuffer(Buffer): Tuple
- addTemporal(Temporal): Tuple
- addLocalDate(LocalDate): Tuple
- addLocalTime(LocalTime): Tuple
- addLocalDateTime(LocalDateTime): Tuple
- addOffsetTime(OffsetTime): Tuple
- addOffsetDateTime(OffsetDateTime): Tuple
- addUUID(UUID): Tuple
- addBigDecimal(BigDecimal): Tuple
- addIntegerArray(Integer[]): Tuple
- addBooleanArray(Boolean[]): Tuple
- addShortArray(Short[]): Tuple
- addLongArray(Long[]): Tuple
- addFloatArray(Float[]): Tuple
- addDoubleArray(Double[]): Tuple
- addStringArray(String[]): Tuple
- addLocalDateArray(LocalDate[]): Tuple
- addLocalTimeArray(LocalTime[]): Tuple
- addOffsetTimeArray(OffsetTime[]): Tuple
- addLocalDateTimeArray(LocalDateTime[]): Tuple
- addOffsetDateTimeArray(OffsetDateTime[]): Tuple
- addBufferArray(Buffer[]): Tuple
- addUUIDArray(UUID[]): Tuple
- addValues(Object[]): Tuple
- Connection
-
ConnectionPool
- connector: Consumer<Handler<AsyncResult<Connection>>>
- maxSize: int
- waiters: ArrayDeque<Promise<Connection>>
- all: Set<PooledConnection>
- available: ArrayDeque<PooledConnection>
- size: int
- maxWaitQueueSize: int
- checkInProgress: boolean
- closed: boolean
- ConnectionPool(Consumer<Handler<AsyncResult<Connection>>>): void
- ConnectionPool(Consumer<Handler<AsyncResult<Connection>>>, int): void
- ConnectionPool(Consumer<Handler<AsyncResult<Connection>>>, int, int): void
- available(): int
- size(): int
- acquire(Handler<AsyncResult<Connection>>): void
- close(): void
-
PooledConnection
- conn: Connection
- holder: Holder
- PooledConnection(Connection): void
- isSsl(): boolean
- schedule(CommandBase<Object>): void
- close(): void
- init(Holder): void
- close(Holder): void
- handleClosed(): void
- handleNotification(int, String, String): void
- handleException(Throwable): void
- getProcessId(): int
- getSecretKey(): int
- release(PooledConnection): void
- check(): void
- CursorImpl
- Notice
- Notification
- ParamDesc
-
PoolBase
- context: Context
- pool: ConnectionPool
- closeVertx: boolean
- PoolBase(Context, boolean, PoolOptions): void
- connect(Handler<AsyncResult<Connection>>): void
- getConnection(Handler<AsyncResult<SqlConnection>>): void
- begin(Handler<AsyncResult<Transaction>>): void
- schedule(CommandBase<Object>, Handler<Object>): void
- CommandWaiter
- wrap(Context, Connection): SqlConnectionImpl
- ConnectionWaiter
- doClose(): void
- close(): void
-
PreparedQueryImpl
- ps: PreparedStatement
- context: Context
- conn: Connection
- closed: AtomicBoolean
- PreparedQueryImpl(Connection, Context, PreparedStatement): void
- execute(Tuple, Handler<AsyncResult<RowSet>>): PreparedQuery
- execute(Tuple, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PreparedQuery
- execute(Tuple, boolean, Function<Object, SqlResultBase>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult>>): PreparedQuery
- execute(Tuple, int, String, boolean, boolean, Collector<Row, Object, Object>, QueryResultHandler<Object>, Handler<AsyncResult<Boolean>>): PreparedQuery
- cursor(Tuple): Cursor
- close(): void
- batch(List<Tuple>, Handler<AsyncResult<RowSet>>): PreparedQuery
- batch(List<Tuple>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PreparedQuery
- batch(List<Tuple>, boolean, Function<Object, SqlResultBase>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult>>): PreparedQuery
- createStream(int, Tuple): RowStream<Row>
- close(Handler<AsyncResult<Void>>): void
- closeCursor(String, Handler<AsyncResult<Void>>): void
- PreparedStatement
- PreparedStatementCache
- QueryResultHandler
- RowDecoder
- RowDesc
- RowInternal
- RowSetImpl
-
RowStreamImpl
- ps: PreparedQueryImpl
- fetch: int
- params: Tuple
- endHandler: Handler<Void>
- rowHandler: Handler<Row>
- exceptionHandler: Handler<Throwable>
- demand: long
- emitting: boolean
- cursor: Cursor
- result: Iterator<Row>
- RowStreamImpl(PreparedQueryImpl, int, Tuple): void
- 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>): void
- close(): void
- close(Handler<AsyncResult<Void>>): void
- checkPending(): void
-
SocketConnectionBase
- logger: Logger
- Status
- psCache: PreparedStatementCache
- preparedStatementCacheSqlLimit: int
- psSeq: StringLongSequence
- pending: ArrayDeque<CommandBase<Object>>
- context: Context
- inflight: int
- holder: Holder
- pipeliningLimit: int
- socket: NetSocketInternal
- status: Status
- SocketConnectionBase(NetSocketInternal, boolean, int, int, int, Context): void
- context(): Context
- init(): void
- socket(): NetSocketInternal
- isSsl(): boolean
- init(Holder): void
- getProcessId(): int
- getSecretKey(): int
- close(Holder): void
- schedule(CommandBase<Object>): void
- CachedPreparedStatement
- checkPending(): void
- handleMessage(Object): void
- handleNotification(Notification): void
- handleNotice(Notice): void
- handleClosed(Void): void
- handleException(Throwable): void
- handleClose(Throwable): void
-
SqlClientBase
- query(String, Handler<AsyncResult<RowSet>>): SqlClient
- query(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): SqlClient
- query(String, boolean, Function<Object, SqlResultBase>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult>>): SqlClient
- preparedQuery(String, Tuple, Handler<AsyncResult<RowSet>>): SqlClient
- preparedQuery(String, Tuple, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): SqlClient
- preparedQuery(String, Tuple, boolean, Function<Object, SqlResultBase>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult>>): SqlClient
- preparedQuery(String, Handler<AsyncResult<RowSet>>): SqlClient
- preparedQuery(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): SqlClient
- preparedBatch(String, List<Tuple>, Handler<AsyncResult<RowSet>>): SqlClient
- preparedBatch(String, List<Tuple>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): SqlClient
- preparedBatch(String, List<Tuple>, boolean, Function<Object, SqlResultBase>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult>>): SqlClient
- SqlConnectionBase
-
SqlConnectionImpl
- exceptionHandler: Handler<Throwable>
- closeHandler: Handler<Void>
- tx: TransactionImpl
- SqlConnectionImpl(Context, Connection): void
- handleClosed(): void
- schedule(CommandBase<Object>, Handler<Object>): void
- schedule(CommandBase<Object>): void
- handleException(Throwable): void
- isSSL(): boolean
- closeHandler(Handler<Void>): SqlConnectionImpl
- exceptionHandler(Handler<Throwable>): SqlConnectionImpl
- begin(): Transaction
- begin(boolean): Transaction
- handleNotification(int, String, String): void
- close(): void
- SqlResultBase
-
SqlResultBuilder
- handleResult(SqlResultBase): void
- handler: Handler<AsyncResult<SqlResult>>
- factory: Function<Object, SqlResultBase>
- first: SqlResultBase
- suspended: boolean
- SqlResultBuilder(Function<Object, SqlResultBase>, Handler<AsyncResult<SqlResult>>): void
- handleResult(int, int, RowDesc, Object): void
- handle(AsyncResult<Boolean>): void
- isSuspended(): boolean
- SqlResultImpl
- StringLongSequence
-
TransactionImpl
- ST_BEGIN: int
- ST_PENDING: int
- ST_PROCESSING: int
- ST_COMPLETED: int
- disposeHandler: Handler<Void>
- pending: Deque<CommandBase<Object>>
- failedHandler: Handler<Void>
- status: int
- TransactionImpl(Context, Connection, Handler<Void>): void
- doSchedule(CommandBase<Object>): void
- afterBegin(AsyncResult<Object>): void
- isComplete(CommandBase<Object>): boolean
- checkPending(): void
- schedule(CommandBase<Object>, Handler<Object>): void
- schedule(CommandBase<Object>): void
- wrap(CommandBase<Object>): void
- commit(): void
- commit(Handler<AsyncResult<Void>>): void
- rollback(): void
- rollback(Handler<AsyncResult<Void>>): void
- close(): void
- abortHandler(Handler<Void>): Transaction
- doQuery(String, Handler<AsyncResult<RowSet>>): CommandBase
- TxStatus
-
command
- CloseConnectionCommand
- CloseCursorCommand
- CloseStatementCommand
- CommandBase
-
CommandResponse
- failure(String): CommandResponse<Object>
- failure(String, TxStatus): CommandResponse<Object>
- failure(Throwable): CommandResponse<Object>
- failure(Throwable, TxStatus): CommandResponse<Object>
- success(Object): CommandResponse<Object>
- success(Object, TxStatus): CommandResponse<Object>
- scheduler: CommandScheduler
- cmd: CommandBase<Object>
- txStatus: TxStatus
- CommandResponse(TxStatus): void
- txStatus(): TxStatus
- CommandScheduler
-
ExtendedBatchQueryCommand
- params: List<Tuple>
- ExtendedBatchQueryCommand(PreparedStatement, List<Tuple>, boolean, Collector<Row, Object, Object>, QueryResultHandler<Object>): void
- ExtendedBatchQueryCommand(PreparedStatement, List<Tuple>, int, String, boolean, boolean, Collector<Row, Object, Object>, QueryResultHandler<Object>): void
- params(): List<Tuple>
- ExtendedQueryCommand
-
ExtendedQueryCommandBase
- suspended: boolean
- ps: PreparedStatement
- fetch: int
- cursorId: String
- singleton: boolean
- ExtendedQueryCommandBase(PreparedStatement, int, String, boolean, boolean, Collector<Row, Object, Object>, QueryResultHandler<Object>): void
- preparedStatement(): PreparedStatement
- fetch(): int
- cursorId(): String
- isSuspended(): boolean
- isSingleton(): boolean
- sql(): String
-
InitCommand
- conn: SocketConnectionBase
- username: String
- password: String
- database: String
- properties: Map<String, String>
- InitCommand(SocketConnectionBase, String, String, String, Map<String, String>): void
- connection(): SocketConnectionBase
- username(): String
- password(): String
- database(): String
- properties(): Map<String, String>
- PrepareStatementCommand
- QueryCommandBase
- SimpleQueryCommand
-
ArrayTuple
-
sqlclient
-
vertx