SqlServer

SqlServer 用于遍历 SQL 查询的结果。

类定义

    public  class SqlServer
    {
 
        public static class OpenParameters
        {
            public SqlLocalConnection conn;
            public int port;
            public int bufsize;
            public int nThreads;
            public int listenQueueSize;
            public boolean localDomain;
            public Database.SSLParameters sslParameters;
            public boolean authenticationRequired;
            public int interruptTimeout;
            public int compressionLevel;
            public String netInterface;
            public OpenParameters(SqlLocalConnection conn, int port) 
            {
                this.conn = conn;
                this.port = port;
                bufsize = 65536;
                nThreads = 4;
                listenQueueSize = 5;
                localDomain = false;
                sslParameters = null;
                authenticationRequired = false;
                interruptTimeout = 100;
                compressionLevel = 0;
                netInterface = null;
            }
        }
 
        /**
        * SQL server constructors
        *
        */
        public SqlServer(SqlLocalConnection conn, int port)
        {
            engine = conn.getEngine();
            OpenParameters op = new OpenParameters(conn, port);
            init(op);
        }
        public SqlServer(SqlLocalConnection conn, int port, int bufsize)
        {
            engine = conn.getEngine();
            OpenParameters op = new OpenParameters(conn, port);
            op.bufsize = bufsize;
            init(op);
        }
        public SqlServer(OpenParameters op)
        {
            engine = op.conn.getEngine();
            init(op);
        }
 
        private void init(SqlServer.OpenParameters op) 
        {
            server = serverInit(engine, op.port, op.bufsize, op.nThreads, op.listenQueueSize, op.localDomain,
                        op.sslParameters, op.authenticationRequired, op.interruptTimeout, op.netInterface);
        }
 
        /**
        * start SQL server
        *
        */
        public void start()
        {
            serverStart(server);
        }
 
        /**
        * stop SQL server
        *
        */
        public void stop()
        {
            serverStop(server);
        }
 
        public enum SessionState 
        {
            Wait, Active, Done, Canceled;
            private static final SessionState values[] = values();
            public static final SessionState from_value(int v) 
            { 
                return values[v];
            }
        };
 
        public static class SessionInfo
        {
            public String       peerAddr;
            public int          peerPort;
            public SessionState peerState;
            public SessionInfo(String addr, int port, SessionState state) 
            {
                peerAddr = addr;
                peerPort = port;
                peerState = state;
            }
        }
 
        /**
        * Get SQL server sessions info
        *
        */
        public SessionInfo[] getSessionsInfo()
        {
            return serverGetSessionsInfo(server);
        }
     
        private long engine;
        private long server;
        private native long serverInit(long con, int port, int bufsize, int nThreads, 
                            int listenQueueSize, boolean localDomain, 
                            Database.SSLParameters sslParameters,
                            boolean authenticationRequired, int interruptTimeout, 
                            String netInterface);
        private native void serverStart(long server);
        private native void serverStop(long server);
        private native SessionInfo[] serverGetSessionsInfo(long server);
    };