Class PgServerThread

java.lang.Object

org.h2.server.pg.PgServerThread

All Implemented Interfaces:

Runnable

public final class PgServerThread
extends Object
implements Runnable

One server thread is opened for each client.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	PgServerThread.Portal	Represents a PostgreSQL Portal object.
(package private) static class	PgServerThread.Prepared	Represents a PostgreSQL Prepared object.

Field Summary

Fields

Modifier and Type	Field	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 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

Constructors

Constructor	Description
PgServerThread(Socket socket, PgServer server)

Method Summary

Modifier and Type	Method	Description
private void	cancelRequest()	Kill a currently running query on this thread.
private static void	checkParamLength(int expected, int got)
(package private) 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	formatAsText(int pgType, int[] formatCodes, int column)	Check whether the given type should be formatted as text.
private Charset	getEncoding()
(package private) int	getProcessId()
private String	getSQL(String s)
(package private) 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 short	readShort()
private String	readString()
void	run()
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 void	setActiveRequest(CommandInterface statement)
private void	setParameter(ArrayList<? extends ParameterInterface> parameters, int pgType, int i, int[] formatCodes)
(package private) void	setProcessId(int id)
(package private) void	setThread(Thread thread)
private void	startMessage(int newMessageType)
private static long	toPostgreDays(long dateValue)
private void	write(byte[] data)
private void	write(int b)
private void	write(ByteArrayOutputStream baos)
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)

Methods inherited from class Object

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

Field Details

INTEGER_DATE_TYPES

private static final boolean INTEGER_DATE_TYPES

See Also:

• Constant Field Values

SHOULD_QUOTE

private static final Pattern SHOULD_QUOTE

server

private final PgServer server

socket

private Socket socket

session

private SessionLocal session

stop

private boolean stop

dataInRaw

private DataInputStream dataInRaw

dataIn

private DataInputStream dataIn

out

private OutputStream out

messageType

private int messageType

outBuffer

private ByteArrayOutputStream outBuffer

dataOut

private DataOutputStream dataOut

thread

private Thread thread

initDone

private boolean initDone

userName

private String userName

databaseName

private String databaseName

processId

private int processId

secret

private final int secret

activeRequest

private CommandInterface activeRequest

clientEncoding

private String clientEncoding

dateStyle

private String dateStyle

timeZone

private TimeZoneProvider timeZone

prepared

private final HashMap<String, PgServerThread.Prepared> prepared

portals

private final HashMap<String, PgServerThread.Portal> portals

POWERS10

private static final int[] POWERS10

MAX_GROUP_SCALE

private static final int MAX_GROUP_SCALE

See Also:

• Constant Field Values

MAX_GROUP_SIZE

private static final int MAX_GROUP_SIZE

Constructor Details

PgServerThread

PgServerThread(Socket socket,
 PgServer server)

Method Details

pgTimeZone

private static String pgTimeZone(String value)

convertTimeZone

private static String convertTimeZone(String value,
 String prefix)

run

public void run()

Specified by:

run in interface Runnable

readString

private String readString()
                   throws IOException

Throws:

IOException

readInt

private int readInt()
             throws IOException

Throws:

IOException

readShort

private short readShort()
                 throws IOException

Throws:

IOException

readByte

private byte readByte()
               throws IOException

Throws:

IOException

readFully

private void readFully(byte[] buff)
                throws IOException

Throws:

IOException

process

private void process()
              throws IOException

Throws:

IOException

executeQuery

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

Throws:

Exception

getSQL

private String getSQL(String s)

sendCommandComplete

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

Throws:

IOException

sendCommandSuspended

private void sendCommandSuspended()
                           throws IOException

Throws:

IOException

sendDataRow

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

Throws:

IOException

toPostgreDays

private static long toPostgreDays(long dateValue)

writeDataColumn

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

Throws:

IOException

divide

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

writeNumericBinary

private void writeNumericBinary(BigDecimal value)
                         throws IOException

Throws:

IOException

writeTimeBinary

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

Throws:

IOException

writeTimestampBinary

private void writeTimestampBinary(long m,
 long nanos)
                           throws IOException

Throws:

IOException

getEncoding

private Charset getEncoding()

setParameter

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

Throws:

IOException

checkParamLength

private static void checkParamLength(int expected,
 int got)

sendErrorOrCancelResponse

private void sendErrorOrCancelResponse(Exception e)
                                throws IOException

Throws:

IOException

sendErrorResponse

private void sendErrorResponse(Exception re)
                        throws IOException

Throws:

IOException

sendCancelQueryResponse

private void sendCancelQueryResponse()
                              throws IOException

Throws:

IOException

sendParameterDescription

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

Throws:

Exception

sendNoData

private void sendNoData()
                 throws IOException

Throws:

IOException

sendRowDescription

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

Throws:

IOException

formatAsText

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

Check whether the given type should be formatted as text.

Parameters:

pgType - data type

formatCodes - format codes, or null

column - 0-based column number

Returns:

true for text

getTypeSize

private static int getTypeSize(int pgType,
 int precision)

sendErrorResponse

private void sendErrorResponse(String message)
                        throws IOException

Throws:

IOException

sendParseComplete

private void sendParseComplete()
                        throws IOException

Throws:

IOException

sendBindComplete

private void sendBindComplete()
                       throws IOException

Throws:

IOException

sendCloseComplete

private void sendCloseComplete()
                        throws IOException

Throws:

IOException

initDb

private void initDb()

close

void close()

Close this connection.

sendAuthenticationCleartextPassword

private void sendAuthenticationCleartextPassword()
                                          throws IOException

Throws:

IOException

sendAuthenticationOk

private void sendAuthenticationOk()
                           throws IOException

Throws:

IOException

sendReadyForQuery

private void sendReadyForQuery()
                        throws IOException

Throws:

IOException

sendBackendKeyData

private void sendBackendKeyData()
                         throws IOException

Throws:

IOException

writeString

private void writeString(String s)
                  throws IOException

Throws:

IOException

writeStringPart

private void writeStringPart(String s)
                      throws IOException

Throws:

IOException

writeInt

private void writeInt(int i)
               throws IOException

Throws:

IOException

writeShort

private void writeShort(int i)
                 throws IOException

Throws:

IOException

write

private void write(byte[] data)
            throws IOException

Throws:

IOException

write

private void write(ByteArrayOutputStream baos)
            throws IOException

Throws:

IOException

write

private void write(int b)
            throws IOException

Throws:

IOException

startMessage

private void startMessage(int newMessageType)

sendMessage

private void sendMessage()
                  throws IOException

Throws:

IOException

sendParameterStatus

private void sendParameterStatus(String param,
 String value)
                          throws IOException

Throws:

IOException

setThread

void setThread(Thread thread)

getThread

Thread getThread()

setProcessId

void setProcessId(int id)

getProcessId

int getProcessId()

setActiveRequest

private void setActiveRequest(CommandInterface statement)

cancelRequest

private void cancelRequest()

Kill a currently running query on this thread.