import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
public int getRealSize(RowOutputInterface out) {

        RowOutputBinary bout = (RowOutputBinary) out;
        int             size = out.getSize(this);

        if (updateData != null) {
            size += bout.getSize(updateData, targetTable.getColumnCount(),
                                 targetTable.getColumnTypes());

            if (updateColMap != null) {
                size += bout.getSize(updateColMap);
            }
        }

        return size;
    }
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
 * Creates a new ServerConnection to the specified Server on the
 * specified socket.
 *
 * @param socket the network socket on which Server communication
 *      takes place
 * @param server the Server instance to which the object
 *      represents a connection
 */
ServerConnection(Socket socket, Server server) {

    RowOutputBinary rowOutTemp = new RowOutputBinary(mainBuffer);

    rowIn  = new RowInputBinary(rowOutTemp);
    rowOut = rowOutTemp;

    //
    Thread runnerThread;

    this.socket = socket;
    this.server = server;
    mThread     = mCurrentThread.getAndIncrement();

    synchronized (server.serverConnSet) {
        server.serverConnSet.add(this);
    }
}
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
private void writeMulti(RowOutputBinary out)
throws IOException, HsqlException {

    int startPos = out.size();

    out.writeSize(0);
    out.writeIntData(mode);
    out.writeIntData(databaseID);
    out.writeIntData(sessionID);
    out.writeIntData(size);

    Record n = rRoot;

    while (n != null) {
        ((Result) n.data[0]).write(out);

        n = n.next;
    }

    out.writeIntData(out.size(), startPos);
}
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
 * resultOut is reused to trasmit all remote calls for session management.
 * Here the structure is preset for sending attributes.
 */
private void initStructures() {

    rowOut    = new RowOutputBinary(mainBuffer);
    rowIn     = new RowInputBinary(rowOut);
    resultOut = new Result(ResultConstants.DATA, 7);
    resultOut.metaData.colNames = resultOut.metaData.colLabels =
        resultOut.metaData.tableNames = new String[] {
        "", "", "", "", "", "", ""
    };

    resultOut.add(new Object[7]);

    resultOut.metaData.colTypes = new int[] {
        Types.VARCHAR, Types.VARCHAR, Types.INTEGER, Types.INTEGER,
        Types.BOOLEAN, Types.BOOLEAN, Types.BOOLEAN
    };
}
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
 * Creates a new ServerConnection to the specified Server on the
 * specified socket.
 *
 * @param socket the network socket on which Server communication
 *      takes place
 * @param server the Server instance to which the object
 *      represents a connection
 */
ServerConnection(Socket socket, Server server) {

    RowOutputBinary rowOutTemp = new RowOutputBinary(mainBuffer);

    rowIn  = new RowInputBinary(rowOutTemp);
    rowOut = rowOutTemp;

    //
    Thread runnerThread;

    this.socket = socket;
    this.server = server;

    synchronized (ServerConnection.class) {
        mThread = mCurrentThread++;
    }

    synchronized (server.serverConnSet) {
        server.serverConnSet.add(this);
    }
}
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
public void write(RowOutputInterface out) {

        writeNodes(out);

        if (hasDataChanged) {
            out.writeData(this, table.colTypes);

            if (updateData != null) {
                Type[] targetTypes = targetTable.colTypes;

                out.writeData(targetTypes.length, targetTypes, updateData,
                              null, null);

                RowOutputBinary bout = (RowOutputBinary) out;

                if (updateColMap == null) {
                    bout.writeNull(Type.SQL_ARRAY_ALL_TYPES);
                } else {
                    bout.writeArray(updateColMap);
                }
            }

            out.writeEnd();

            hasDataChanged = false;
        }
    }
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
 * resultOut is reused to transmit all remote calls for session management.
 * Here the structure is preset for sending attributes.
 */
private void initStructures() {

    RowOutputBinary rowOutTemp = new RowOutputBinary(mainBuffer);

    rowOut    = rowOutTemp;
    rowIn     = new RowInputBinary(rowOutTemp);
    resultOut = Result.newSessionAttributesResult();
}
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
 * resultOut is reused to trasmit all remote calls for session management.
 * Here the structure is preset for sending attributes.
 */
private void initStructures() {

    RowOutputBinary rowOutTemp = new RowOutputBinary(mainBuffer);

    rowOut    = rowOutTemp;
    rowIn     = new RowInputBinary(rowOutTemp);
    resultOut = Result.newSessionAttributesResult();
}
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
protected void initBuffers() throws HsqlException {

        rowOut = RowOutputBase.newRowOutput(cachedRowType);
        rowIn  = RowInputBase.newRowInput(cachedRowType);
        rowStoreExtra = rowOut instanceof RowOutputBinary
                        ? ROW_STORE_EXTRA_170
                        : ROW_STORE_EXTRA_160;
    }
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
void write(RowOutputBinary out,
           int colCount) throws HsqlException, IOException {

    out.writeIntData(colCount);

    for (int i = 0; i < colCount; i++) {
        out.writeType(colTypes[i]);

        // CAREFUL: writeString will throw NPE if passed NULL
        // There is no guarantee that these will all be non-null
        // and there's no point in hanging network communications
        // or doing a big rewrite for null-safety over something
        // like this.  We could explicitly do a writeNull here if
        // detected null, but, frankly, readString on the other
        // end will simply turn it into a zero-length string
        // anyway, as nulls are only handled "properly" by
        // readData(...), not by the individual readXXX methods.
        out.writeString(colLabels[i] == null ? ""
                                             : colLabels[i]);
        out.writeString(tableNames[i] == null ? ""
                                              : tableNames[i]);
        out.writeString(colNames[i] == null ? ""
                                            : colNames[i]);
        out.writeString(classNames[i] == null ? ""
                                              : classNames[i]);

        if (isTableColumn(i)) {
            writeTableColumnAttrs(out, i);
        }

        if (isParameterDescription) {
            out.writeIntData(paramMode[i]);
        }
    }
}
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
void write(RowOutputBinary out,
           int colCount) throws HsqlException, IOException {

    out.writeIntData(colCount);

    for (int i = 0; i < colCount; i++) {
        out.writeType(colTypes[i]);

        // fredt - 1.8.0 added
        out.writeIntData(colSizes[i]);
        out.writeIntData(colScales[i]);
        out.writeString(colLabels[i] == null ? ""
                                             : colLabels[i]);
        out.writeString(tableNames[i] == null ? ""
                                              : tableNames[i]);
        out.writeString(colNames[i] == null ? ""
                                            : colNames[i]);
        out.writeString(classNames[i] == null ? ""
                                              : classNames[i]);

        if (isTableColumn(i)) {
            writeTableColumnAttrs(out, i);
        }

        if (isParameterDescription) {
            out.writeIntData(paramMode[i]);
        }
    }
}
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
 * resultOut is reused to trasmit all remote calls for session management.
 * Here the structure is preset for sending attributes.
 */
private void initStructures() {

    rowOut    = new RowOutputBinary(mainBuffer);
    rowIn     = new RowInputBinary(rowOut);
    resultOut = Result.newSessionAttributesResult();

    resultOut.add(new Object[7]);
}
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
public void write(RowOutputInterface out) {

        try {
            writeNodes(out);

            if (hasDataChanged) {
                out.writeData(this, table.colTypes);

                if (updateData != null) {
                    Type[] targetTypes = targetTable.colTypes;

                    out.writeData(targetTypes.length, targetTypes, updateData,
                                  null, null);

                    RowOutputBinary bout = (RowOutputBinary) out;

                    if (updateColMap == null) {
                        bout.writeNull(Type.SQL_ARRAY_ALL_TYPES);
                    } else {
                        bout.writeArray(updateColMap);
                    }
                }

                out.writeEnd();

                hasDataChanged = false;
            }
        } catch (IOException e) {}
    }
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
protected void initBuffers() {
    rowOut = new RowOutputBinary();
}
 

import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
     * Method declaration
     *
     *
     * @param config
     */
    public void init(ServletConfig config) {

        try {
            super.init(config);

            rowOut = new RowOutputBinary(BUFFER_SIZE);
            rowIn  = new RowInputBinary(rowOut);
        } catch (ServletException exp) {
            log(exp.getMessage());
        }

        String dbStr = getInitParameter("hsqldb.server.database");

        if (dbStr == null) {
            dbStr = ".";
        }

// begin WEB-INF patch */
        String useWebInfStr =
            getInitParameter("hsqldb.server.use_web-inf_path");

        if (!dbStr.equals(".") && "true".equalsIgnoreCase(useWebInfStr)) {
            dbStr = getServletContext().getRealPath("/") + "WEB-INF" + dbStr;
        }

// end WEB-INF patch
        HsqlProperties dbURL = DatabaseManager.parseURL(dbStr, false);

        log("Database filename = " + dbStr);

        if (dbURL == null) {
            errorStr = "Bad Database name";
        } else {
            dbPath = dbURL.getProperty("database");
            dbType = dbURL.getProperty("connection_type");

            try {

// [email protected] 1.7.2 patch properties on the JDBC URL
                DatabaseManager.getDatabase(dbType, dbPath, false, dbURL);
            } catch (HsqlException e) {
                errorStr = e.getMessage();
            }
        }

        log(errorStr);
        log("Initialization completed.");
    }