Package org.h2.server.pg
Class PgServer
java.lang.Object
org.h2.server.pg.PgServer
- All Implemented Interfaces:
Service
This class implements a subset of the PostgreSQL protocol as described here:
https://www.postgresql.org/docs/devel/protocol.html
The PostgreSQL catalog is described here:
https://www.postgresql.org/docs/7.4/catalogs.html
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private String
static final int
The default port to use for the PG server.private boolean
private boolean
private String
private String
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
The VARCHAR type.static final int
private final AtomicInteger
private int
private boolean
private final Set
<PgServerThread> private ServerSocket
private boolean
private boolean
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate boolean
If no key is set, return the original database name.(package private) void
checkType
(int type) Check whether a data type is supported.static int
convertType
(TypeInfo type) Convert the SQL type to a PostgreSQL typestatic String
formatType
(int pgType) Returns the name of the given type.boolean
Check if remote connections are allowed.(package private) String
(package private) boolean
getName()
Get the human readable name of the service.int
getPort()
Gets the port this service is listening on.(package private) PgServerThread
getThread
(int processId) Get the thread with the given process id.(package private) boolean
getTrace()
getType()
Get the human readable short name of the service.Get the type hash set.getURL()
Get the URL of this service in a human readable formvoid
Initialize the service from command line options.boolean
isDaemon()
Check if a daemon thread should be used.boolean
isRunning
(boolean traceError) Check if the service is running.void
listen()
Listen for incoming connections.(package private) void
Remove a thread from the list.void
start()
Start the service.void
stop()
Stop the service.(package private) void
Print a message if the trace flag is enabled.(package private) void
Print the stack trace if the trace flag is enabled.
-
Field Details
-
DEFAULT_PORT
public static final int DEFAULT_PORTThe default port to use for the PG server. This value is also in the documentation and in the Server javadoc.- See Also:
-
PG_TYPE_VARCHAR
public static final int PG_TYPE_VARCHARThe VARCHAR type.- See Also:
-
PG_TYPE_BOOL
public static final int PG_TYPE_BOOL- See Also:
-
PG_TYPE_BYTEA
public static final int PG_TYPE_BYTEA- See Also:
-
PG_TYPE_BPCHAR
public static final int PG_TYPE_BPCHAR- See Also:
-
PG_TYPE_INT8
public static final int PG_TYPE_INT8- See Also:
-
PG_TYPE_INT2
public static final int PG_TYPE_INT2- See Also:
-
PG_TYPE_INT4
public static final int PG_TYPE_INT4- See Also:
-
PG_TYPE_TEXT
public static final int PG_TYPE_TEXT- See Also:
-
PG_TYPE_FLOAT4
public static final int PG_TYPE_FLOAT4- See Also:
-
PG_TYPE_FLOAT8
public static final int PG_TYPE_FLOAT8- See Also:
-
PG_TYPE_UNKNOWN
public static final int PG_TYPE_UNKNOWN- See Also:
-
PG_TYPE_INT2_ARRAY
public static final int PG_TYPE_INT2_ARRAY- See Also:
-
PG_TYPE_INT4_ARRAY
public static final int PG_TYPE_INT4_ARRAY- See Also:
-
PG_TYPE_VARCHAR_ARRAY
public static final int PG_TYPE_VARCHAR_ARRAY- See Also:
-
PG_TYPE_DATE
public static final int PG_TYPE_DATE- See Also:
-
PG_TYPE_TIME
public static final int PG_TYPE_TIME- See Also:
-
PG_TYPE_TIMETZ
public static final int PG_TYPE_TIMETZ- See Also:
-
PG_TYPE_TIMESTAMP
public static final int PG_TYPE_TIMESTAMP- See Also:
-
PG_TYPE_TIMESTAMPTZ
public static final int PG_TYPE_TIMESTAMPTZ- See Also:
-
PG_TYPE_NUMERIC
public static final int PG_TYPE_NUMERIC- See Also:
-
typeSet
-
port
private int port -
portIsSet
private boolean portIsSet -
stop
private boolean stop -
trace
private boolean trace -
serverSocket
-
running
-
pid
-
baseDir
-
allowOthers
private boolean allowOthers -
isDaemon
private boolean isDaemon -
ifExists
private boolean ifExists -
key
-
keyDatabase
-
-
Constructor Details
-
PgServer
public PgServer()
-
-
Method Details
-
init
Description copied from interface:Service
Initialize the service from command line options. -
getTrace
boolean getTrace() -
trace
Print a message if the trace flag is enabled.- Parameters:
s
- the message
-
remove
Remove a thread from the list.- Parameters:
t
- the thread to remove
-
traceError
Print the stack trace if the trace flag is enabled.- Parameters:
e
- the exception
-
getURL
Description copied from interface:Service
Get the URL of this service in a human readable form -
getPort
public int getPort()Description copied from interface:Service
Gets the port this service is listening on. -
allow
-
start
public void start()Description copied from interface:Service
Start the service. This usually means create the server socket. This method must not block. -
listen
public void listen()Description copied from interface:Service
Listen for incoming connections. This method blocks. -
stop
public void stop()Description copied from interface:Service
Stop the service. -
isRunning
public boolean isRunning(boolean traceError) Description copied from interface:Service
Check if the service is running. -
getThread
Get the thread with the given process id.- Parameters:
processId
- the process id- Returns:
- the thread
-
getBaseDir
String getBaseDir() -
getAllowOthers
public boolean getAllowOthers()Description copied from interface:Service
Check if remote connections are allowed.- Specified by:
getAllowOthers
in interfaceService
- Returns:
- true if remote connections are allowed
-
getType
Description copied from interface:Service
Get the human readable short name of the service. -
getName
Description copied from interface:Service
Get the human readable name of the service. -
getIfExists
boolean getIfExists() -
formatType
Returns the name of the given type.- Parameters:
pgType
- the PostgreSQL type oid- Returns:
- the name of the given type
-
convertType
Convert the SQL type to a PostgreSQL type- Parameters:
type
- the SQL type- Returns:
- the PostgreSQL type
-
getTypeSet
Get the type hash set.- Returns:
- the type set
-
checkType
void checkType(int type) Check whether a data type is supported. A warning is logged if not.- Parameters:
type
- the type
-
checkKeyAndGetDatabaseName
If no key is set, return the original database name. If a key is set, check if the key matches. If yes, return the correct database name. If not, throw an exception.- Parameters:
db
- the key to test (or database name if no key is used)- Returns:
- the database name
- Throws:
DbException
- if a key is set but doesn't match
-
isDaemon
public boolean isDaemon()Description copied from interface:Service
Check if a daemon thread should be used.
-