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
-
PgClientExamples
-
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
-
InitiateSslHandler
-
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
-
PgConnectOptions
-
pgclient
-
vertx