com.impossibl.postgres.system

Class BasicContext

java.lang.Object

com.impossibl.postgres.system.AbstractContext

com.impossibl.postgres.system.BasicContext

All Implemented Interfaces:

Configuration, Context

Direct Known Subclasses:

PGDirectConnection

public class BasicContext
extends AbstractContext

Field Summary

Fields

Modifier and Type	Field and Description
protected Charset	charset
protected Registry	registry
protected Settings	settings
protected Map<String,Class<?>>	typeMap

Constructor Summary

Constructors

Constructor and Description
BasicContext(SocketAddress address, Settings settings)

Method Summary

Modifier and Type	Method and Description
protected void	connectionClosed() Called when serverConnection was closed externally (i.e.
protected void	connectionNotificationReceived(int processId, String channelName, String payload) Called when serverConnection received an asynchronous notification
io.netty.buffer.ByteBufAllocator	getAllocator()
Charset	getCharset()
NumberFormat	getClientCurrencyFormatter()
DateTimeFormat	getClientDateFormat()
NumberFormat	getClientDecimalFormatter()
NumberFormat	getClientIntegerFormatter()
IntervalFormat	getClientIntervalFormat()
DateTimeFormat	getClientTimeFormat()
DateTimeFormat	getClientTimestampFormat()
Map<String,Class<?>>	getCustomTypeMap()
ServerConnection.KeyData	getKeyData()
Registry	getRegistry()
RequestExecutor	getRequestExecutor()
protected ServerConnection	getServerConnection()
NumberFormat	getServerCurrencyFormatter()
DateTimeFormat	getServerDateFormat()
ServerInfo	getServerInfo()
IntervalFormat	getServerIntervalFormat()
DateTimeFormat	getServerTimeFormat()
DateTimeFormat	getServerTimestampFormat()
<T> T	getSetting(Setting<T> setting)
TimeZone	getTimeZone()
ZoneId	getTimeZoneId()
protected void	init(SharedRegistry.Factory sharedRegistryFactory)
boolean	isUtilQueryPrepared(String name)
void	prepareUtilQuery(String name, String sql, String... parameterTypeNames)
void	query(String queryTxt, long timeout)
protected ResultBatch	queryBatch(String queryTxt, long timeout) Queries for a single (the first) result batch.
protected ResultBatch	queryBatchPrepared(String queryTxt, FieldFormatRef[] paramFormats, io.netty.buffer.ByteBuf[] paramBuffers, long timeout) Queries a single result batch (the first) via a parameterized query.
ResultBatch	queryBatchPrepared(String queryTxt, Object[] paramValues, long timeout) Queries a single result batch (the first) via a parameterized query.
protected String	queryString(String queryTxt, long timeout)
protected io.netty.channel.ChannelFuture	shutdown()
Context	unwrap()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.impossibl.postgres.system.Configuration

getSetting

Field Detail

registry

protected Registry registry

typeMap

protected Map<String,Class<?>> typeMap

charset

protected Charset charset

settings

protected Settings settings

Constructor Detail

BasicContext

public BasicContext(SocketAddress address,
                    Settings settings)
             throws IOException

Throws:

IOException

Method Detail

shutdown

protected io.netty.channel.ChannelFuture shutdown()

connectionClosed

protected void connectionClosed()

Called when serverConnection was closed externally (i.e. without calling shutdown()

connectionNotificationReceived

protected void connectionNotificationReceived(int processId,
                                              String channelName,
                                              String payload)

Called when serverConnection received an asynchronous notification

getAllocator

public io.netty.buffer.ByteBufAllocator getAllocator()

getServerConnection

protected ServerConnection getServerConnection()

getRegistry

public Registry getRegistry()

getRequestExecutor

public RequestExecutor getRequestExecutor()

getSetting

public <T> T getSetting(Setting<T> setting)

Specified by:

getSetting in interface Configuration

Overrides:

getSetting in class AbstractContext

getCustomTypeMap

public Map<String,Class<?>> getCustomTypeMap()

getCharset

public Charset getCharset()

getTimeZone

public TimeZone getTimeZone()

getTimeZoneId

public ZoneId getTimeZoneId()

getServerInfo

public ServerInfo getServerInfo()

getKeyData

public ServerConnection.KeyData getKeyData()

getServerDateFormat

public DateTimeFormat getServerDateFormat()

getClientDateFormat

public DateTimeFormat getClientDateFormat()

getServerTimeFormat

public DateTimeFormat getServerTimeFormat()

getClientTimeFormat

public DateTimeFormat getClientTimeFormat()

getServerIntervalFormat

public IntervalFormat getServerIntervalFormat()

getClientIntervalFormat

public IntervalFormat getClientIntervalFormat()

getServerTimestampFormat

public DateTimeFormat getServerTimestampFormat()

getClientTimestampFormat

public DateTimeFormat getClientTimestampFormat()

getClientIntegerFormatter

public NumberFormat getClientIntegerFormatter()

getClientDecimalFormatter

public NumberFormat getClientDecimalFormatter()

getServerCurrencyFormatter

public NumberFormat getServerCurrencyFormatter()

getClientCurrencyFormatter

public NumberFormat getClientCurrencyFormatter()

init

protected void init(SharedRegistry.Factory sharedRegistryFactory)
             throws IOException

Throws:

IOException

isUtilQueryPrepared

public boolean isUtilQueryPrepared(String name)

prepareUtilQuery

public void prepareUtilQuery(String name,
                             String sql,
                             String... parameterTypeNames)
                      throws IOException

Throws:

IOException

query

public void query(String queryTxt,
                  long timeout)
           throws IOException

Throws:

IOException

queryString

protected String queryString(String queryTxt,
                             long timeout)
                      throws IOException

Throws:

IOException

queryBatch

protected ResultBatch queryBatch(String queryTxt,
                                 long timeout)
                          throws IOException

Queries for a single (the first) result batch. The batch must be released.

Throws:

IOException

queryBatchPrepared

public ResultBatch queryBatchPrepared(String queryTxt,
                                      Object[] paramValues,
                                      long timeout)
                               throws IOException

Queries a single result batch (the first) via a parameterized query. The batch must be released.

Throws:

IOException

queryBatchPrepared

protected ResultBatch queryBatchPrepared(String queryTxt,
                                         FieldFormatRef[] paramFormats,
                                         io.netty.buffer.ByteBuf[] paramBuffers,
                                         long timeout)
                                  throws IOException

Queries a single result batch (the first) via a parameterized query. The batch must be released.

Throws:

IOException

unwrap

public Context unwrap()