https://github.com/eclipse-vertx/vertx-sql-client: The Reactive PostgreSQL client
(Eclipse)
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
- io.vertx/vertx-sql-client/3.8.0
- io.vertx/vertx-sql-client/3.8.0/tests
- 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
-
PgClientExamples
-
gettingStarted(): void
-
configureFromEnv(Vertx): void
-
configureFromDataObject(Vertx): void
-
configureDefaultSchema(): void
-
configureFromUri(Vertx): void
-
connecting01(): void
-
connecting02(Vertx): void
-
connecting03(PgPool): void
-
connecting04(Vertx): void
-
connecting05(Vertx): void
-
connecting06(Vertx): void
-
typeMapping01(Pool): void
-
typeMapping02(Pool): void
-
pubsub01(PgConnection): void
-
collector01Example(SqlClient): void
-
pubsub02(Vertx): void
-
pubsub03(Vertx): void
-
pubsub04(Vertx): void
-
ex10(Vertx): void
-
jsonExample(): void
-
numericExample(Row): void
-
arrayExample(): void
-
customType01Example(SqlClient): void
-
customType02Example(SqlClient): void
-
collector02Example(SqlClient): void
-
cancelRequest(PgConnection): void
-
-
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
-
pgclient
-
PgConnectOptions
-
fromUri(String): PgConnectOptions
-
fromEnv(): PgConnectOptions
-
DEFAULT_HOST: String
-
DEFAULT_PORT: int
-
DEFAULT_DATABASE: String
-
DEFAULT_USER: String
-
DEFAULT_PASSWORD: String
-
DEFAULT_PIPELINING_LIMIT: int
-
DEFAULT_SSLMODE: SslMode
-
DEFAULT_PROPERTIES: Map<String, String>
-
static class initializer
-
pipeliningLimit: int
-
sslMode: SslMode
-
PgConnectOptions(): void
-
PgConnectOptions(JsonObject): void
-
PgConnectOptions(PgConnectOptions): void
-
setHost(String): PgConnectOptions
-
setPort(int): PgConnectOptions
-
setUser(String): PgConnectOptions
-
setPassword(String): PgConnectOptions
-
setDatabase(String): PgConnectOptions
-
getPipeliningLimit(): int
-
setPipeliningLimit(int): PgConnectOptions
-
setCachePreparedStatements(boolean): PgConnectOptions
-
setPreparedStatementCacheMaxSize(int): PgConnectOptions
-
setPreparedStatementCacheSqlLimit(int): PgConnectOptions
-
setProperties(Map<String, String>): PgConnectOptions
-
addProperty(String, String): PgConnectOptions
-
getSslMode(): SslMode
-
setSslMode(SslMode): PgConnectOptions
-
setSendBufferSize(int): PgConnectOptions
-
setReceiveBufferSize(int): PgConnectOptions
-
setReuseAddress(boolean): PgConnectOptions
-
setTrafficClass(int): PgConnectOptions
-
setTcpNoDelay(boolean): PgConnectOptions
-
setTcpKeepAlive(boolean): PgConnectOptions
-
setSoLinger(int): PgConnectOptions
-
setUsePooledBuffers(boolean): PgConnectOptions
-
setIdleTimeout(int): PgConnectOptions
-
setIdleTimeoutUnit(TimeUnit): PgConnectOptions
-
setSsl(boolean): PgConnectOptions
-
setKeyCertOptions(KeyCertOptions): PgConnectOptions
-
setKeyStoreOptions(JksOptions): PgConnectOptions
-
setPfxKeyCertOptions(PfxOptions): PgConnectOptions
-
setPemKeyCertOptions(PemKeyCertOptions): PgConnectOptions
-
setTrustOptions(TrustOptions): PgConnectOptions
-
setTrustStoreOptions(JksOptions): PgConnectOptions
-
setPemTrustOptions(PemTrustOptions): PgConnectOptions
-
setPfxTrustOptions(PfxOptions): PgConnectOptions
-
addEnabledCipherSuite(String): PgConnectOptions
-
addEnabledSecureTransportProtocol(String): PgConnectOptions
-
addCrlPath(String): PgConnectOptions
-
addCrlValue(Buffer): PgConnectOptions
-
setTrustAll(boolean): PgConnectOptions
-
setConnectTimeout(int): PgConnectOptions
-
setMetricsName(String): PgConnectOptions
-
setReconnectAttempts(int): PgConnectOptions
-
setHostnameVerificationAlgorithm(String): PgConnectOptions
-
setLogActivity(boolean): PgConnectOptions
-
setReconnectInterval(long): PgConnectOptions
-
setProxyOptions(ProxyOptions): PgConnectOptions
-
setLocalAddress(String): PgConnectOptions
-
setUseAlpn(boolean): PgConnectOptions
-
setSslEngineOptions(SSLEngineOptions): PgConnectOptions
-
setJdkSslEngineOptions(JdkSSLEngineOptions): PgConnectOptions
-
setOpenSslEngineOptions(OpenSSLEngineOptions): PgConnectOptions
-
setReusePort(boolean): PgConnectOptions
-
setTcpFastOpen(boolean): PgConnectOptions
-
setTcpCork(boolean): PgConnectOptions
-
setTcpQuickAck(boolean): PgConnectOptions
-
setEnabledSecureTransportProtocols(Set<String>): PgConnectOptions
-
setSslHandshakeTimeout(long): PgConnectOptions
-
setSslHandshakeTimeoutUnit(TimeUnit): PgConnectOptions
-
init(): void
-
toJson(): JsonObject
-
equals(Object): boolean
-
hashCode(): int
-
isUsingDomainSocket(): boolean
-
-
PgConnectOptionsConverter
-
PgConnection
-
connect(Vertx, PgConnectOptions, Handler<AsyncResult<PgConnection>>): void
-
connect(Vertx, Handler<AsyncResult<PgConnection>>): void
-
connect(Vertx, String, Handler<AsyncResult<PgConnection>>): void
-
notificationHandler(Handler<PgNotification>): PgConnection
-
cancelRequest(Handler<AsyncResult<Void>>): PgConnection
-
processId(): int
-
secretKey(): int
-
prepare(String, Handler<AsyncResult<PreparedQuery>>): PgConnection
-
exceptionHandler(Handler<Throwable>): PgConnection
-
closeHandler(Handler<Void>): PgConnection
-
preparedQuery(String, Handler<AsyncResult<RowSet>>): PgConnection
-
preparedQuery(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PgConnection
-
query(String, Handler<AsyncResult<RowSet>>): PgConnection
-
query(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PgConnection
-
preparedQuery(String, Tuple, Handler<AsyncResult<RowSet>>): PgConnection
-
preparedQuery(String, Tuple, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PgConnection
-
preparedBatch(String, List<Tuple>, Handler<AsyncResult<RowSet>>): PgConnection
-
preparedBatch(String, List<Tuple>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PgConnection
-
-
PgException
-
PgNotification
-
PgNotificationConverter
-
PgPool
-
pool(): PgPool
-
pool(PoolOptions): PgPool
-
pool(String): PgPool
-
pool(String, PoolOptions): PgPool
-
pool(Vertx, PoolOptions): PgPool
-
pool(Vertx, String, PoolOptions): PgPool
-
pool(PgConnectOptions, PoolOptions): PgPool
-
pool(Vertx, PgConnectOptions, PoolOptions): PgPool
-
preparedQuery(String, Handler<AsyncResult<RowSet>>): PgPool
-
preparedQuery(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PgPool
-
query(String, Handler<AsyncResult<RowSet>>): PgPool
-
query(String, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PgPool
-
preparedQuery(String, Tuple, Handler<AsyncResult<RowSet>>): PgPool
-
preparedQuery(String, Tuple, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PgPool
-
preparedBatch(String, List<Tuple>, Handler<AsyncResult<RowSet>>): PgPool
-
preparedBatch(String, List<Tuple>, Collector<Row, Object, Object>, Handler<AsyncResult<SqlResult<Object>>>): PgPool
-
-
SslMode
-
data
-
Box
-
upperRightCorner: Point
-
lowerLeftCorner: Point
-
Box(): void
-
Box(Point, Point): void
-
Box(JsonObject): void
-
getUpperRightCorner(): Point
-
setUpperRightCorner(Point): void
-
getLowerLeftCorner(): Point
-
setLowerLeftCorner(Point): void
-
equals(Object): boolean
-
hashCode(): int
-
toString(): String
-
toJson(): JsonObject
-
-
BoxConverter
-
Circle
-
CircleConverter
-
Interval
-
years: int
-
months: int
-
days: int
-
hours: int
-
minutes: int
-
seconds: int
-
microseconds: int
-
Interval(): void
-
Interval(int, int, int, int, int, int, int): void
-
Interval(int, int, int, int, int, int): void
-
Interval(int, int, int, int, int): void
-
Interval(int, int, int, int): void
-
Interval(int, int, int): void
-
Interval(int, int): void
-
Interval(int): void
-
Interval(JsonObject): void
-
of(): Interval
-
of(int, int, int, int, int, int, int): Interval
-
of(int, int, int, int, int, int): Interval
-
of(int, int, int, int, int): Interval
-
of(int, int, int, int): Interval
-
of(int, int, int): Interval
-
of(int, int): Interval
-
of(int): Interval
-
years(int): Interval
-
months(int): Interval
-
days(int): Interval
-
hours(int): Interval
-
minutes(int): Interval
-
seconds(int): Interval
-
microseconds(int): Interval
-
getYears(): int
-
setYears(int): void
-
getMonths(): int
-
setMonths(int): void
-
getDays(): int
-
setDays(int): void
-
getHours(): int
-
setHours(int): void
-
getMinutes(): int
-
setMinutes(int): void
-
getSeconds(): int
-
setSeconds(int): void
-
getMicroseconds(): int
-
setMicroseconds(int): void
-
equals(Object): boolean
-
hashCode(): int
-
toString(): String
-
toJson(): JsonObject
-
-
IntervalConverter
-
Line
-
LineConverter
-
LineSegment
-
LineSegmentConverter
-
Path
-
PathConverter
-
Point
-
PointConverter
-
Polygon
-
PolygonConverter
-
-
impl
-
InitiateSslHandler
-
code: int
-
conn: SocketConnectionBase
-
upgradePromise: Promise<Void>
-
InitiateSslHandler(SocketConnectionBase, Promise<Void>): void
-
channelActive(ChannelHandlerContext): void
-
channelRead(ChannelHandlerContext, Object): void
-
exceptionCaught(ChannelHandlerContext, Throwable): void
-
channelInactive(ChannelHandlerContext): void
-
-
PgConnectionFactory
-
client: NetClient
-
ctx: Context
-
registerCloseHook: boolean
-
host: String
-
port: int
-
sslMode: SslMode
-
trustOptions: TrustOptions
-
hostnameVerificationAlgorithm: String
-
database: String
-
username: String
-
password: String
-
properties: Map<String, String>
-
cachePreparedStatements: boolean
-
preparedStatementCacheSize: int
-
preparedStatementCacheSqlLimit: int
-
pipeliningLimit: int
-
isUsingDomainSocket: boolean
-
hook: Closeable
-
PgConnectionFactory(Context, boolean, PgConnectOptions): void
-
close(Handler<AsyncResult<Void>>): void
-
close(): void
-
connectAndInit(Handler<AsyncResult<Connection>>): void
-
connect(Handler<AsyncResult<PgSocketConnection>>): void
-
doConnect(boolean, Handler<AsyncResult<PgSocketConnection>>): void
-
newSocketConnection(NetSocketInternal): PgSocketConnection
-
-
PgConnectionImpl
-
connect(Vertx, PgConnectOptions, Handler<AsyncResult<PgConnection>>): void
-
factory: PgConnectionFactory
-
notificationHandler: Handler<PgNotification>
-
PgConnectionImpl(PgConnectionFactory, Context, Connection): void
-
notificationHandler(Handler<PgNotification>): PgConnection
-
handleNotification(int, String, String): void
-
processId(): int
-
secretKey(): int
-
cancelRequest(Handler<AsyncResult<Void>>): PgConnection
-
-
PgConnectionUriParser
-
SCHEME_DESIGNATOR_REGEX: String
-
USER_INFO_REGEX: String
-
NET_LOCATION_REGEX: String
-
PORT_REGEX: String
-
DATABASE_REGEX: String
-
PARAMS_REGEX: String
-
FULL_URI_REGEX: String
-
parse(String): JsonObject
-
doParse(String, JsonObject): void
-
parseUserAndPassword(String, JsonObject): void
-
parseNetLocation(String, JsonObject): void
-
parsePort(String, JsonObject): void
-
parseDatabaseName(String, JsonObject): void
-
parseParameters(String, JsonObject): void
-
parseNetLocationValue(String, JsonObject): void
-
isRegardedAsIpv6Address(String): boolean
-
decodeUrl(String): String
-
occurExactlyOnce(String, String): boolean
-
-
PgPoolImpl
-
PgSocketConnection
-
codec: PgCodec
-
processId: int
-
secretKey: int
-
PgSocketConnection(NetSocketInternal, boolean, int, int, int, Context): void
-
init(): void
-
sendStartupMessage(String, String, String, Map<String, String>, Handler<Object>): void
-
sendCancelRequestMessage(int, int, Handler<AsyncResult<Void>>): void
-
getProcessId(): int
-
getSecretKey(): int
-
upgradeToSSLConnection(Handler<AsyncResult<Void>>): void
-
-
RowImpl
-
next: RowInternal
-
desc: RowDesc
-
RowImpl(RowDesc): void
-
RowImpl(RowImpl): void
-
getColumnName(int): String
-
getColumnIndex(String): int
-
get(Class<Object>, int): Object
-
getValues(Class<Object>, int): Object[]
-
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
-
getNumeric(String): Numeric
-
getPoint(String): Point
-
getLine(String): Line
-
getLineSegment(String): LineSegment
-
getBox(String): Box
-
getPath(String): Path
-
getPolygon(String): Polygon
-
getCircle(String): Circle
-
getInterval(String): Interval
-
getBooleanArray(String): Boolean[]
-
getShortArray(String): Short[]
-
getIntegerArray(String): Integer[]
-
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[]
-
getJsonArray(String): Object[]
-
getNumericArray(String): Numeric[]
-
getPointArray(String): Point[]
-
getLineArray(String): Line[]
-
getLineSegmentArray(String): LineSegment[]
-
getBoxArray(String): Box[]
-
getPathArray(String): Path[]
-
getPolygonArray(String): Polygon[]
-
getCircleArray(String): Circle[]
-
getIntervalArray(String): Interval[]
-
getCharArray(String): Character[]
-
getChar(int): Character
-
getNumeric(int): Numeric
-
getJson(int): Object
-
getPoint(int): Point
-
getLine(int): Line
-
getLineSegment(int): LineSegment
-
getBox(int): Box
-
getPath(int): Path
-
getPolygon(int): Polygon
-
getCircle(int): Circle
-
getInterval(int): Interval
-
getCharArray(int): Character[]
-
getJsonArray(int): Object[]
-
getNumericArray(int): Numeric[]
-
getPointArray(int): Point[]
-
getLineArray(int): Line[]
-
getLineSegmentArray(int): LineSegment[]
-
getBoxArray(int): Box[]
-
getPathArray(int): Path[]
-
getPolygonArray(int): Polygon[]
-
getCircleArray(int): Circle[]
-
getIntervalArray(int): Interval[]
-
setNext(RowInternal): void
-
getNext(): RowInternal
-
-
codec
-
Bind
-
CloseConnectionCommandCodec
-
ClosePortalCommandCodec
-
CloseStatementCommandCodec
-
DataFormat
-
DataType
-
DataTypeCodec
-
Describe
-
ErrorResponse
-
ExtendedBatchQueryCommandCodec
-
ExtendedQueryCommandBaseCodec
-
ExtendedQueryCommandCodec
-
InitCommandCodec
-
NoticeResponse
-
Parse
-
PasswordMessage
-
PgCodec
-
PgColumnDesc
-
PgCommandCodec
-
PgDecoder
-
PgEncoder
-
PgParamDesc
-
PgPreparedStatement
-
PgProtocolConstants
-
PgRowDesc
-
PrepareStatementCommandCodec
-
Query
-
QueryCommandBaseCodec
-
Response
-
RowResultDecoder
-
SimpleQueryCodec
-
StartupMessage
-
-
pubsub
-
util
-
-
pubsub
-
-
-
Java files
examples/
Class files