Modifier and Type	Class and Description
pack-priv static class	PgServerThread.Portal Represents a PostgreSQL Portal object.
pack-priv static class	PgServerThread.Prepared Represents a PostgreSQL Prepared object.

Field Summary

Modifier and Type	Field and Description
private CommandInterface	activeRequest
private String	clientEncoding
private String	databaseName
private DataInputStream	dataIn
private DataInputStream	dataInRaw
private DataOutputStream	dataOut
private String	dateStyle
private boolean	initDone
private static final boolean	INTEGER_DATE_TYPES
private static final int	MAX_GROUP_SCALE
private static final int	MAX_GROUP_SIZE
private int	messageType
private static final BigInteger	NUMERIC_CHUNK_MULTIPLIER
private static final short	NUMERIC_NAN
private static final short	NUMERIC_NEGATIVE
private static final short	NUMERIC_POSITIVE
private OutputStream	out
private ByteArrayOutputStream	outBuffer
private final HashMap<String, PgServerThread.Portal>	portals
private static final int[]	POWERS10
private final HashMap<String, PgServerThread.Prepared>	prepared
private int	processId
private final int	secret
private final PgServer	server
private SessionLocal	session
private static final Pattern	SHOULD_QUOTE
private Socket	socket
private boolean	stop
private Thread	thread
private TimeZoneProvider	timeZone
private String	userName

Constructor Summary

Access	Constructor and Description
pack-priv	PgServerThread(Socket socket, PgServer server)

Method Summary

Modifier and Type	Method and Description
private synchronized void	cancelRequest() Kill a currently running query on this thread.
private static void	checkParamLength(int expected, int got)
pack-priv void	close() Close this connection.
private static String	convertTimeZone(String value, String prefix)
private static int	divide(BigInteger[] unscaled, int divisor)
private void	executeQuery(PgServerThread.Prepared prepared, CommandInterface prep, int[] resultColumnFormat, int maxRows)
private static boolean	Returns: true for text formatAsText(int data type pgType, int[] format codes, or `null` formatCodes, int 0-based column number column) Check whether the given type should be formatted as text.
private Charset	getEncoding()
pack-priv int	getProcessId()
private String	getSQL(String s)
pack-priv Thread	getThread()
private static int	getTypeSize(int pgType, int precision)
private void	initDb()
private static String	pgTimeZone(String value)
private void	process()
private byte	readByte()
private void	readFully(byte[] buff)
private int	readInt()
private Value	readNumericBinary(int paramLen)
private short	readShort()
private String	readString()
public void	run() Implements java.lang.Runnable.run. Runs this operation.
private void	sendAuthenticationCleartextPassword()
private void	sendAuthenticationOk()
private void	sendBackendKeyData()
private void	sendBindComplete()
private void	sendCancelQueryResponse()
private void	sendCloseComplete()
private void	sendCommandComplete(CommandInterface command, long updateCount)
private void	sendCommandSuspended()
private void	sendDataRow(ResultInterface result, int[] formatCodes)
private void	sendErrorOrCancelResponse(Exception e)
private void	sendErrorResponse(Exception re)
private void	sendErrorResponse(String message)
private void	sendMessage()
private void	sendNoData()
private void	sendParameterDescription(ArrayList<? extends ParameterInterface> parameters, int[] paramTypes)
private void	sendParameterStatus(String param, String value)
private void	sendParseComplete()
private void	sendReadyForQuery()
private void	sendRowDescription(ResultInterface result, int[] formatCodes)
private synchronized void	setActiveRequest(CommandInterface statement)
private void	setParameter(ArrayList<? extends ParameterInterface> parameters, int pgType, int i, int[] formatCodes)
pack-priv void	setProcessId(int id)
pack-priv void	setThread(Thread thread)
private void	startMessage(int newMessageType)
private static long	toPostgreDays(long dateValue)
private void	write(byte[] data)
private void	write(ByteArrayOutputStream baos)
private void	write(int b)
private void	writeDataColumn(Value v, int pgType, boolean text)
private void	writeInt(int i)
private void	writeNumericBinary(BigDecimal value)
private void	writeShort(int i)
private void	writeString(String s)
private void	writeStringPart(String s)
private void	writeTimeBinary(long m, int numBytes)
private void	writeTimestampBinary(long m, long nanos)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

activeRequest	back to summary
private CommandInterface activeRequest

clientEncoding	back to summary
private String clientEncoding

databaseName	back to summary
private String databaseName

dataIn	back to summary
private DataInputStream dataIn

dataInRaw	back to summary
private DataInputStream dataInRaw

dataOut	back to summary
private DataOutputStream dataOut

dateStyle	back to summary
private String dateStyle

initDone	back to summary
private boolean initDone

INTEGER_DATE_TYPES	back to summary
private static final boolean INTEGER_DATE_TYPES

MAX_GROUP_SCALE	back to summary
private static final int MAX_GROUP_SCALE

MAX_GROUP_SIZE	back to summary
private static final int MAX_GROUP_SIZE

messageType	back to summary
private int messageType

NUMERIC_CHUNK_MULTIPLIER	back to summary
private static final BigInteger NUMERIC_CHUNK_MULTIPLIER

NUMERIC_NAN	back to summary
private static final short NUMERIC_NAN

NUMERIC_NEGATIVE	back to summary
private static final short NUMERIC_NEGATIVE

NUMERIC_POSITIVE	back to summary
private static final short NUMERIC_POSITIVE

out	back to summary
private OutputStream out

outBuffer	back to summary
private ByteArrayOutputStream outBuffer

portals	back to summary
private final HashMap<String, PgServerThread.Portal> portals

POWERS10	back to summary
private static final int[] POWERS10

prepared	back to summary
private final HashMap<String, PgServerThread.Prepared> prepared

processId	back to summary
private int processId

secret	back to summary
private final int secret

server	back to summary
private final PgServer server

session	back to summary
private SessionLocal session

SHOULD_QUOTE	back to summary
private static final Pattern SHOULD_QUOTE

socket	back to summary
private Socket socket

stop	back to summary
private boolean stop

thread	back to summary
private Thread thread

timeZone	back to summary
private TimeZoneProvider timeZone

userName	back to summary
private String userName

Constructor Detail

PgServerThread	back to summary
pack-priv PgServerThread(Socket socket, PgServer server)

Method Detail

cancelRequest	back to summary
private synchronized void cancelRequest() Kill a currently running query on this thread.

checkParamLength	back to summary
private static void checkParamLength(int expected, int got)

close	back to summary
pack-priv void close() Close this connection.

convertTimeZone	back to summary
private static String convertTimeZone(String value, String prefix)

divide	back to summary
private static int divide(BigInteger[] unscaled, int divisor)

executeQuery	back to summary
private void executeQuery(PgServerThread.Prepared prepared, CommandInterface prep, int[] resultColumnFormat, int maxRows) throws Exception

formatAsText back to summary

formatAsText	back to summary
private static boolean formatAsText(int pgType, int[] formatCodes, int column) Check whether the given type should be formatted as text. Parameters pgType:int data type formatCodes:int[] format codes, or `null` column:int 0-based column number Returns:boolean true for text

private static boolean formatAsText(int pgType, int[] formatCodes, int column)

Check whether the given type should be formatted as text.

Parameters

pgType:int: data type
formatCodes:int[]: format codes, or null
column:int: 0-based column number

Returns:boolean

true for text

getEncoding	back to summary
private Charset getEncoding()

getProcessId	back to summary
pack-priv int getProcessId()

getSQL	back to summary
private String getSQL(String s)

getThread	back to summary
pack-priv Thread getThread()

getTypeSize	back to summary
private static int getTypeSize(int pgType, int precision)

initDb	back to summary
private void initDb()

pgTimeZone	back to summary
private static String pgTimeZone(String value)

process	back to summary
private void process() throws IOException

readByte	back to summary
private byte readByte() throws IOException

readFully	back to summary
private void readFully(byte[] buff) throws IOException

readInt	back to summary
private int readInt() throws IOException

readNumericBinary	back to summary
private Value readNumericBinary(int paramLen) throws IOException

readShort	back to summary
private short readShort() throws IOException

readString	back to summary
private String readString() throws IOException

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

sendAuthenticationCleartextPassword	back to summary
private void sendAuthenticationCleartextPassword() throws IOException

sendAuthenticationOk	back to summary
private void sendAuthenticationOk() throws IOException

sendBackendKeyData	back to summary
private void sendBackendKeyData() throws IOException

sendBindComplete	back to summary
private void sendBindComplete() throws IOException

sendCancelQueryResponse	back to summary
private void sendCancelQueryResponse() throws IOException

sendCloseComplete	back to summary
private void sendCloseComplete() throws IOException

sendCommandComplete	back to summary
private void sendCommandComplete(CommandInterface command, long updateCount) throws IOException

sendCommandSuspended	back to summary
private void sendCommandSuspended() throws IOException

sendDataRow	back to summary
private void sendDataRow(ResultInterface result, int[] formatCodes) throws IOException

sendErrorOrCancelResponse	back to summary
private void sendErrorOrCancelResponse(Exception e) throws IOException

sendErrorResponse	back to summary
private void sendErrorResponse(Exception re) throws IOException

sendErrorResponse	back to summary
private void sendErrorResponse(String message) throws IOException

sendMessage	back to summary
private void sendMessage() throws IOException

sendNoData	back to summary
private void sendNoData() throws IOException

sendParameterDescription	back to summary
private void sendParameterDescription(ArrayList<? extends ParameterInterface> parameters, int[] paramTypes) throws Exception

sendParameterStatus	back to summary
private void sendParameterStatus(String param, String value) throws IOException

sendParseComplete	back to summary
private void sendParseComplete() throws IOException

sendReadyForQuery	back to summary
private void sendReadyForQuery() throws IOException

sendRowDescription	back to summary
private void sendRowDescription(ResultInterface result, int[] formatCodes) throws IOException

setActiveRequest	back to summary
private synchronized void setActiveRequest(CommandInterface statement)

setParameter	back to summary
private void setParameter(ArrayList<? extends ParameterInterface> parameters, int pgType, int i, int[] formatCodes) throws IOException

setProcessId	back to summary
pack-priv void setProcessId(int id)

setThread	back to summary
pack-priv void setThread(Thread thread)

startMessage	back to summary
private void startMessage(int newMessageType)

toPostgreDays	back to summary
private static long toPostgreDays(long dateValue)

write	back to summary
private void write(byte[] data) throws IOException

write	back to summary
private void write(ByteArrayOutputStream baos) throws IOException

write	back to summary
private void write(int b) throws IOException

writeDataColumn	back to summary
private void writeDataColumn(Value v, int pgType, boolean text) throws IOException

writeInt	back to summary
private void writeInt(int i) throws IOException

writeNumericBinary	back to summary
private void writeNumericBinary(BigDecimal value) throws IOException

writeShort	back to summary
private void writeShort(int i) throws IOException

writeString	back to summary
private void writeString(String s) throws IOException

writeStringPart	back to summary
private void writeStringPart(String s) throws IOException

writeTimeBinary	back to summary
private void writeTimeBinary(long m, int numBytes) throws IOException

writeTimestampBinary	back to summary
private void writeTimestampBinary(long m, long nanos) throws IOException

org.h2.server.pg back to summary

pack-priv Class PgServerThread.Portal

Class Inheritance

extends Object

java.lang.Object
org.h2.server.pg.PgServerThread.Portal

Represents a PostgreSQL Portal object.

Field Summary

Modifier and Type	Field and Description
pack-priv String	name The portal name.
pack-priv PgServerThread.Prepared	prep The prepared object.
pack-priv int[]	resultColumnFormat The format used in the result set columns (if set).

Constructor Summary

Access	Constructor and Description
pack-priv	Portal()

Method Summary

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

name	back to summary
pack-priv String name The portal name.

prep	back to summary
pack-priv PgServerThread.Prepared prep The prepared object.

resultColumnFormat	back to summary
pack-priv int[] resultColumnFormat The format used in the result set columns (if set).

Constructor Detail

Portal	back to summary
pack-priv Portal()

org.h2.server.pg back to summary

pack-priv Class PgServerThread.Prepared

Class Inheritance

extends Object

java.lang.Object
org.h2.server.pg.PgServerThread.Prepared

Represents a PostgreSQL Prepared object.

Field Summary

Modifier and Type	Field and Description
pack-priv String	name The object name.
pack-priv int[]	paramType The list of parameter types (if set).
pack-priv CommandInterface	prep The prepared statement.
pack-priv ResultInterface	result The current result (for suspended portal).
pack-priv String	sql The SQL statement.

Constructor Summary

Access	Constructor and Description
pack-priv	Prepared()

Method Summary

Modifier and Type	Method and Description
pack-priv void	close() Closes prepared statement and result, if any.
pack-priv void	closeResult() Closes the result, if any.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

name	back to summary
pack-priv String name The object name.

paramType	back to summary
pack-priv int[] paramType The list of parameter types (if set).

prep	back to summary
pack-priv CommandInterface prep The prepared statement.

result	back to summary
pack-priv ResultInterface result The current result (for suspended portal).

sql	back to summary
pack-priv String sql The SQL statement.

Constructor Detail

Prepared	back to summary
pack-priv Prepared()

Method Detail

close	back to summary
pack-priv void close() Closes prepared statement and result, if any.

closeResult	back to summary
pack-priv void closeResult() Closes the result, if any.

public final Class PgServerThread

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class PgServerThread.Portal

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

pack-priv Class PgServerThread.Prepared

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail