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.ongres.scram/client/2.1
- com.ongres.scram/common/2.1
- com.ongres.stringprep/saslprep/1.1
- com.ongres.stringprep/stringprep/1.1
- 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
- io.vertx/vertx-sql-client/4.0.0
- 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
-
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
-
reconnectAttempts(PgConnectOptions): void
-
typeMapping01(Pool): void
-
typeMapping02(Pool): void
-
pubsub01(PgConnection): void
-
pubsub02(Vertx): void
-
pubsub03(Vertx): void
-
pubsub04(Vertx): void
-
ex10(Vertx): void
-
jsonExample(): void
-
numericExample(Row): void
-
arrayExample(): void
-
infinitySpecialValue(SqlClient): void
-
customType01Example(SqlClient): void
-
customType02Example(SqlClient): void
-
tsQuery01Example(SqlClient): void
-
tsQuery02Example(SqlClient): void
-
enumeratedType01Example(SqlClient): void
-
Color
-
enumType01Example(SqlClient): void
-
collector01Example(SqlClient): void
-
collector02Example(SqlClient): void
-
cancelRequest(PgConnection): void
-
returning(SqlClient): 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(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(PgConnectOptions): void
-
-
-
io
-
vertx
-
pgclient
-
PgConnectOptions
-
PgConnectOptions(JsonObject): void
-
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(SqlConnectOptions): 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
-
setPreparedStatementCacheSqlFilter(Predicate<String>): 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
-
setIdleTimeout(int): PgConnectOptions
-
setIdleTimeoutUnit(TimeUnit): PgConnectOptions
-
setSsl(boolean): PgConnectOptions
-
setKeyCertOptions(KeyCertOptions): PgConnectOptions
-
setKeyStoreOptions(JksOptions): PgConnectOptions
-
setPfxKeyCertOptions(PfxOptions): PgConnectOptions
-
setPemKeyCertOptions(PemKeyCertOptions): PgConnectOptions
-
setTrustOptions(TrustOptions): PgConnectOptions
-
hashCode(): int
-
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
-
setTracingPolicy(TracingPolicy): PgConnectOptions
-
init(): void
-
toJson(): JsonObject
-
getSocketAddress(): SocketAddress
-
equals(Object): boolean
-
isUsingDomainSocket(): boolean
-
-
PgConnectOptionsConverter
-
PgConnection
-
connect(Vertx, PgConnectOptions, Handler<AsyncResult<PgConnection>>): void
-
connect(Vertx, PgConnectOptions): Future<PgConnection>
-
connect(Vertx, Handler<AsyncResult<PgConnection>>): void
-
connect(Vertx): Future<PgConnection>
-
connect(Vertx, String, Handler<AsyncResult<PgConnection>>): void
-
connect(Vertx, String): Future<PgConnection>
-
notificationHandler(Handler<PgNotification>): PgConnection
-
cancelRequest(Handler<AsyncResult<Void>>): PgConnection
-
processId(): int
-
secretKey(): int
-
prepare(String, Handler<AsyncResult<PreparedStatement>>): PgConnection
-
exceptionHandler(Handler<Throwable>): PgConnection
-
closeHandler(Handler<Void>): PgConnection
-
-
PgException
-
errorMessage: String
-
severity: String
-
code: String
-
detail: String
-
hint: String
-
position: String
-
internalPosition: String
-
internalQuery: String
-
where: String
-
file: String
-
line: String
-
routine: String
-
schema: String
-
table: String
-
column: String
-
dataType: String
-
constraint: String
-
PgException(String, String, String, String): void
-
PgException(String, String, String, String, String, String, String, String, String, String, String, String, String, String, String, String, String): void
-
getErrorMessage(): String
-
getSeverity(): String
-
getCode(): String
-
getDetail(): String
-
getHint(): String
-
getPosition(): String
-
getWhere(): String
-
getFile(): String
-
getLine(): String
-
getRoutine(): String
-
getSchema(): String
-
getTable(): String
-
getColumn(): String
-
getDataType(): String
-
getConstraint(): String
-
getInternalPosition(): String
-
getInternalQuery(): String
-
append(StringBuffer, String, String): void
-
getMessage(): String
-
-
PgNotification
-
PgNotificationConverter
-
PgPool
-
SslMode
-
data
-
Box
-
Circle
-
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
-
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
-
-
Line
-
LineSegment
-
Path
-
Point
-
Polygon
-
-
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
-
sslMode: SslMode
-
pipeliningLimit: int
-
PgConnectionFactory(ContextInternal, PgConnectOptions): void
-
initializeConfiguration(SqlConnectOptions): void
-
configureNetClientOptions(NetClientOptions): void
-
doConnectInternal(Promise<Connection>): void
-
cancelRequest(int, int, Handler<AsyncResult<Void>>): void
-
doConnect(): Future<Connection>
-
doConnect(boolean): Future<Connection>
-
newSocketConnection(NetSocketInternal): PgSocketConnection
-
-
PgConnectionImpl
-
connect(ContextInternal, PgConnectOptions): Future<PgConnection>
-
factory: PgConnectionFactory
-
notificationHandler: Handler<PgNotification>
-
PgConnectionImpl(PgConnectionFactory, ContextInternal, Connection, QueryTracer, ClientMetrics): void
-
appendQueryPlaceholder(StringBuilder, int, int): int
-
notificationHandler(Handler<PgNotification>): PgConnection
-
handleEvent(Object): 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
-
-
PgDatabaseMetadata
-
PgPoolImpl
-
create(ContextInternal, boolean, PgConnectOptions, PoolOptions): PgPoolImpl
-
factory: PgConnectionFactory
-
PgPoolImpl(ContextInternal, PgConnectionFactory, QueryTracer, ClientMetrics, PoolOptions): void
-
appendQueryPlaceholder(StringBuilder, int, int): int
-
connect(Handler<AsyncResult<Connection>>): void
-
wrap(ContextInternal, Connection): SqlConnectionImpl
-
-
PgSocketConnection
-
codec: PgCodec
-
processId: int
-
secretKey: int
-
dbMetaData: PgDatabaseMetadata
-
PgSocketConnection(NetSocketInternal, boolean, int, Predicate<String>, int, ContextInternal): void
-
init(): void
-
sendStartupMessage(String, String, String, Map<String, String>, Promise<Connection>): void
-
sendCancelRequestMessage(int, int, Handler<AsyncResult<Void>>): void
-
handleMessage(Object): void
-
handleNotice(Notice): void
-
getProcessId(): int
-
getSecretKey(): int
-
getDatabaseMetaData(): DatabaseMetadata
-
upgradeToSSLConnection(Handler<AsyncResult<Void>>): void
-
doSchedule(CommandBase<Object>, Handler<AsyncResult<Object>>): void
-
isIndeterminatePreparedStatementError(Throwable): boolean
-
-
RowImpl
-
desc: RowDesc
-
RowImpl(RowDesc): void
-
RowImpl(RowImpl): void
-
getColumnName(int): String
-
getColumnIndex(String): int
-
get(Class<Object>, 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
-
getEnum(Class, int): Object
-
getJsonArray_(int): Object[]
-
getArrayOfPoints(int): Point[]
-
getArrayOfLines(int): Line[]
-
getArrayOfLineSegments(int): LineSegment[]
-
getArrayOfBoxs(int): Box[]
-
getArrayOfPaths(int): Path[]
-
getArrayOfPolygons(int): Polygon[]
-
getArrayOfCircles(int): Circle[]
-
getArrayOfIntervals(int): Interval[]
-
getArrayOfEnums(Class, int): Object[]
-
-
codec
-
Bind
-
CloseConnectionCommandCodec
-
ClosePortalCommandCodec
-
CloseStatementCommandCodec
-
DataFormat
-
DataType
-
DataTypeCodec
-
Describe
-
ErrorResponse
-
ExtendedQueryCommandCodec
-
InitCommandCodec
-
NoticeResponse
-
ParamExtractor
-
PasswordMessage
-
PgCodec
-
PgColumnDesc
-
PgCommandCodec
-
PgDecoder
-
PgEncoder
-
PgParamDesc
-
PgPreparedStatement
-
PgProtocolConstants
-
PgRowDesc
-
PrepareStatementCommandCodec
-
Query
-
QueryCommandBaseCodec
-
Response
-
RowResultDecoder
-
ScramClientFinalMessage
-
ScramClientInitialMessage
-
SimpleQueryCodec
-
StartupMessage
-
- pubsub
- util
-
-
pubsub
-
PgChannel
-
PgSubscriber
-
subscriber(Vertx, PgConnectOptions): PgSubscriber
-
channel(String): PgChannel
-
connect(): Future<Void>
-
connect(Handler<AsyncResult<Void>>): PgSubscriber
-
reconnectPolicy(Function<Integer, Long>): PgSubscriber
-
closeHandler(Handler<Void>): PgSubscriber
-
actualConnection(): PgConnection
-
closed(): boolean
-
close(): Future<Void>
-
close(Handler<AsyncResult<Void>>): void
-
-
- spi
-
-
pgclient
-
vertx