com.impossibl.postgres.system

Class BasicContext

java.lang.Object

com.impossibl.postgres.system.BasicContext

All Implemented Interfaces:

Context

Direct Known Subclasses:

PGConnectionImpl

public class BasicContext
extends Object
implements Context

Nested Class Summary

Nested classes/interfaces inherited from interface com.impossibl.postgres.system.Context

Context.KeyData

Field Summary

Fields

Modifier and Type	Field and Description
protected Charset	charset
protected DecimalFormat	currencyFormatter
protected DateTimeFormat	dateFormatter
protected DecimalFormat	decimalFormatter
protected Context.KeyData	keyData
protected Map<com.impossibl.postgres.system.BasicContext.NotificationKey,NotificationListener>	notificationListeners
protected Protocol	protocol
protected Registry	registry
protected Version	serverVersion
protected Properties	settings
protected Map<String,Class<?>>	targetTypeMap
protected DateTimeFormat	timeFormatter
protected DateTimeFormat	timestampFormatter
protected TimeZone	timeZone
protected Map<String,com.impossibl.postgres.system.BasicContext.PreparedQuery>	utilQueries

Constructor Summary

Constructors

Constructor and Description
BasicContext(SocketAddress address, Properties settings, Map<String,Class<?>> targetTypeMap)

Method Summary

Methods

Modifier and Type	Method and Description
void	addNotificationListener(String name, String channelNameFilter, NotificationListener listener)
Charset	getCharset()
DecimalFormat	getCurrencyFormatter()
DateTimeFormat	getDateFormatter()
DecimalFormat	getDecimalFormatter()
Context.KeyData	getKeyData()
Protocol	getProtocol()
Registry	getRegistry()
Version	getServerVersion()
Object	getSetting(String name)
<T> T	getSetting(String name, Class<T> type)
<T> T	getSetting(String name, Converter<T> converter)
<T> T	getSetting(String name, T defaultValue)
DateTimeFormat	getTimeFormatter()
DateTimeFormat	getTimestampFormatter()
TimeZone	getTimeZone()
protected void	init()
boolean	isSettingEnabled(String name)
boolean	isUtilQueryPrepared(String name)
Class<?>	lookupInstanceType(Type type)
com.impossibl.postgres.system.BasicContext.PreparedQuery	prepareUtilQuery(String name, String sql, List<Type> parameterTypes)
com.impossibl.postgres.system.BasicContext.PreparedQuery	prepareUtilQuery(String name, String sql, String... parameterTypeNames)
void	query(String queryTxt)
QueryCommand.ResultBatch	queryBatch(String queryTxt, Object... params)
String	queryFirstResultString(String queryTxt)
List<DataRow>	queryResults(String queryTxt)
<T> List<T>	queryResults(String queryTxt, Class<T> rowType, Object... params)
void	refreshRelationType(int relationId)
void	refreshType(int typeId)
void	removeNotificationListener(NotificationListener listener)
void	removeNotificationListener(String listenerName)
void	reportNotification(int processId, String channelName, String payload)
void	setKeyData(int processId, int secretKey)
void	setServerVersion(Version serverVersion)
protected void	shutdown()
Context	unwrap()
void	updateSystemParameter(String name, String value)

Methods inherited from class java.lang.Object

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

Field Detail

registry

protected Registry registry

targetTypeMap

protected Map<String,Class<?>> targetTypeMap

charset

protected Charset charset

timeZone

protected TimeZone timeZone

dateFormatter

protected DateTimeFormat dateFormatter

timeFormatter

protected DateTimeFormat timeFormatter

timestampFormatter

protected DateTimeFormat timestampFormatter

decimalFormatter

protected DecimalFormat decimalFormatter

currencyFormatter

protected DecimalFormat currencyFormatter

settings

protected Properties settings

serverVersion

protected Version serverVersion

keyData

protected Context.KeyData keyData

protocol

protected Protocol protocol

notificationListeners

protected Map<com.impossibl.postgres.system.BasicContext.NotificationKey,NotificationListener> notificationListeners

utilQueries

protected Map<String,com.impossibl.postgres.system.BasicContext.PreparedQuery> utilQueries

Constructor Detail

BasicContext

public BasicContext(SocketAddress address,
            Properties settings,
            Map<String,Class<?>> targetTypeMap)
             throws IOException,
                    NoticeException

Throws:

IOException

NoticeException

Method Detail

shutdown

protected void shutdown()

getServerVersion

public Version getServerVersion()

setServerVersion

public void setServerVersion(Version serverVersion)

getRegistry

public Registry getRegistry()

Specified by:

getRegistry in interface Context

getProtocol

public Protocol getProtocol()

Specified by:

getProtocol in interface Context

getSetting

public Object getSetting(String name)

Specified by:

getSetting in interface Context

getSetting

public <T> T getSetting(String name,
               Class<T> type)

Specified by:

getSetting in interface Context

getSetting

public <T> T getSetting(String name,
               Converter<T> converter)

getSetting

public <T> T getSetting(String name,
               T defaultValue)

Specified by:

getSetting in interface Context

isSettingEnabled

public boolean isSettingEnabled(String name)

Specified by:

isSettingEnabled in interface Context

lookupInstanceType

public Class<?> lookupInstanceType(Type type)

Specified by:

lookupInstanceType in interface Context

getCharset

public Charset getCharset()

Specified by:

getCharset in interface Context

getTimeZone

public TimeZone getTimeZone()

Specified by:

getTimeZone in interface Context

getKeyData

public Context.KeyData getKeyData()

Specified by:

getKeyData in interface Context

getDateFormatter

public DateTimeFormat getDateFormatter()

Specified by:

getDateFormatter in interface Context

getTimeFormatter

public DateTimeFormat getTimeFormatter()

Specified by:

getTimeFormatter in interface Context

getTimestampFormatter

public DateTimeFormat getTimestampFormatter()

Specified by:

getTimestampFormatter in interface Context

getDecimalFormatter

public DecimalFormat getDecimalFormatter()

Specified by:

getDecimalFormatter in interface Context

getCurrencyFormatter

public DecimalFormat getCurrencyFormatter()

Specified by:

getCurrencyFormatter in interface Context

init

protected void init()
             throws IOException,
                    NoticeException

Throws:

IOException

NoticeException

refreshType

public void refreshType(int typeId)

Specified by:

refreshType in interface Context

refreshRelationType

public void refreshRelationType(int relationId)

Specified by:

refreshRelationType in interface Context

isUtilQueryPrepared

public boolean isUtilQueryPrepared(String name)

prepareUtilQuery

public com.impossibl.postgres.system.BasicContext.PreparedQuery prepareUtilQuery(String name,
                                                                        String sql,
                                                                        String... parameterTypeNames)
                                                                          throws IOException

Throws:

IOException

prepareUtilQuery

public com.impossibl.postgres.system.BasicContext.PreparedQuery prepareUtilQuery(String name,
                                                                        String sql,
                                                                        List<Type> parameterTypes)
                                                                          throws IOException

Throws:

IOException

queryResults

public <T> List<T> queryResults(String queryTxt,
                       Class<T> rowType,
                       Object... params)
                     throws IOException,
                            NoticeException

Throws:

IOException

NoticeException

queryResults

public List<DataRow> queryResults(String queryTxt)
                           throws IOException,
                                  NoticeException

Throws:

IOException

NoticeException

query

public void query(String queryTxt)
           throws IOException,
                  NoticeException

Throws:

IOException

NoticeException

queryFirstResultString

public String queryFirstResultString(String queryTxt)
                              throws IOException,
                                     NoticeException

Throws:

IOException

NoticeException

queryBatch

public QueryCommand.ResultBatch queryBatch(String queryTxt,
                                  Object... params)
                                    throws IOException,
                                           NoticeException

Throws:

IOException

NoticeException

setKeyData

public void setKeyData(int processId,
              int secretKey)

updateSystemParameter

public void updateSystemParameter(String name,
                         String value)

addNotificationListener

public void addNotificationListener(String name,
                           String channelNameFilter,
                           NotificationListener listener)

removeNotificationListener

public void removeNotificationListener(NotificationListener listener)

removeNotificationListener

public void removeNotificationListener(String listenerName)

reportNotification

public void reportNotification(int processId,
                      String channelName,
                      String payload)

Specified by:

reportNotification in interface Context

unwrap

public Context unwrap()

Specified by:

unwrap in interface Context