Package org.h2.server.pg

Class PgServer

  • All Implemented Interfaces:
    Service
    public class PgServer
extends java.lang.Object
implements 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 Detail

      • DEFAULT_PORT

        public static final int DEFAULT_PORT
        The default port to use for the PG server. This value is also in the documentation and in the Server javadoc.
        See Also:
        Constant Field Values

      • PG_TYPE_VARCHAR

        public static final int PG_TYPE_VARCHAR
        The VARCHAR type.
        See Also:
        Constant Field Values

      • typeSet

        private final java.util.HashSet<java.lang.Integer> typeSet

      • port

        private int port

      • portIsSet

        private boolean portIsSet

      • stop

        private boolean stop

      • trace

        private boolean trace

      • serverSocket

        private java.net.ServerSocket serverSocket

      • pid

        private final java.util.concurrent.atomic.AtomicInteger pid

      • baseDir

        private java.lang.String baseDir

      • allowOthers

        private boolean allowOthers

      • isDaemon

        private boolean isDaemon

      • ifExists

        private boolean ifExists

      • key

        private java.lang.String key

      • keyDatabase

        private java.lang.String keyDatabase

    • Constructor Detail

      • PgServer

        public PgServer()

    • Method Detail

      • init

        public void init​(java.lang.String... args)
        Description copied from interface: Service
        Initialize the service from command line options.
        Specified by:
        init in interface Service
        Parameters:
        args - the command line options

      • getTrace

        boolean getTrace()

      • trace

        void trace​(java.lang.String s)
        Print a message if the trace flag is enabled.
        Parameters:
        s - the message

      • remove

        void remove​(PgServerThread t)
        Remove a thread from the list.
        Parameters:
        t - the thread to remove

      • traceError

        void traceError​(java.lang.Exception e)
        Print the stack trace if the trace flag is enabled.
        Parameters:
        e - the exception

      • getURL

        public java.lang.String getURL()
        Description copied from interface: Service
        Get the URL of this service in a human readable form
        Specified by:
        getURL in interface Service
        Returns:
        the url

      • getPort

        public int getPort()
        Description copied from interface: Service
        Gets the port this service is listening on.
        Specified by:
        getPort in interface Service
        Returns:
        the port

      • allow

        private boolean allow​(java.net.Socket socket)

      • start

        public void start()
        Description copied from interface: Service
        Start the service. This usually means create the server socket. This method must not block.
        Specified by:
        start in interface Service

      • listen

        public void listen()
        Description copied from interface: Service
        Listen for incoming connections. This method blocks.
        Specified by:
        listen in interface Service

      • stop

        public void stop()
        Description copied from interface: Service
        Stop the service.
        Specified by:
        stop in interface Service

      • isRunning

        public boolean isRunning​(boolean traceError)
        Description copied from interface: Service
        Check if the service is running.
        Specified by:
        isRunning in interface Service
        Parameters:
        traceError - if errors should be written
        Returns:
        if the server is running

      • getThread

        PgServerThread getThread​(int processId)
        Get the thread with the given process id.
        Parameters:
        processId - the process id
        Returns:
        the thread

      • getBaseDir

        java.lang.String getBaseDir()

      • getAllowOthers

        public boolean getAllowOthers()
        Description copied from interface: Service
        Check if remote connections are allowed.
        Specified by:
        getAllowOthers in interface Service
        Returns:
        true if remote connections are allowed

      • getType

        public java.lang.String getType()
        Description copied from interface: Service
        Get the human readable short name of the service.
        Specified by:
        getType in interface Service
        Returns:
        the type

      • getName

        public java.lang.String getName()
        Description copied from interface: Service
        Get the human readable name of the service.
        Specified by:
        getName in interface Service
        Returns:
        the name

      • getIfExists

        boolean getIfExists()

      • formatType

        public static java.lang.String formatType​(int pgType)
        Returns the name of the given type.
        Parameters:
        pgType - the PostgreSQL type oid
        Returns:
        the name of the given type

      • convertType

        public static int convertType​(TypeInfo type)
        Convert the SQL type to a PostgreSQL type
        Parameters:
        type - the SQL type
        Returns:
        the PostgreSQL type

      • getTypeSet

        java.util.HashSet<java.lang.Integer> 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

        public java.lang.String checkKeyAndGetDatabaseName​(java.lang.String db)
        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.
        Specified by:
        isDaemon in interface Service
        Returns:
        true if a daemon thread should be used