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
-
-
-
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
-
-
-
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
-
-
-
-
sqlclient
-
vertx