import weka.experiment.ResultProducer; //导入依赖的package包/类
/**
 * Executes a database query to see whether a result for the supplied key is
 * already in the database.
 *
 * @param tableName the name of the table to search for the key in
 * @param rp        the ResultProducer who will generate the result if required
 * @param key       the key for the result
 * @return true if the result with that key is in the database already
 * @throws Exception if an error occurs
 */
protected boolean isKeyInTable(String tableName, ResultProducer rp,
                               Object[] key) throws Exception {

    String query = "SELECT Key_Run" + " FROM " + tableName;
    String[] keyNames = rp.getKeyNames();
    if (keyNames.length != key.length) {
        throw new Exception("Key names and key values of different lengths");
    }
    boolean first = true;
    for (int i = 0; i < key.length; i++) {
        if (key[i] != null) {
            if (first) {
                query += " WHERE ";
                first = false;
            } else {
                query += " AND ";
            }
            query += "Key_" + keyNames[i] + '=';
            if (key[i] instanceof String) {
                query += "'" + processKeyString(key[i].toString()) + "'";
            } else {
                query += key[i].toString();
            }
        }
    }
    boolean retval = false;
    ResultSet rs = select(query);
    if (rs.next()) {
        retval = true;
        if (rs.next()) {
            throw new Exception("More than one result entry " + "for result key: "
                    + query);
        }
    }
    close(rs);
    return retval;
}
 

import weka.experiment.ResultProducer; //导入依赖的package包/类
/**
 * Gets the name of the experiment table that stores results from a particular
 * ResultProducer.
 *
 * @param rp the ResultProducer
 * @return the name of the table where the results for this ResultProducer are
 * stored, or null if there is no table for this ResultProducer.
 * @throws Exception if an error occurs
 */
public String getResultsTableName(ResultProducer rp) throws Exception {
    // Get the experiment table name, or create a new table if necessary.
    if (m_Debug) {
        System.err.println("Getting results table name...");
    }
    String expType = rp.getClass().getName();
    String expParams = rp.getCompatibilityState();
    String query = "SELECT " + EXP_RESULT_COL + " FROM " + EXP_INDEX_TABLE
            + " WHERE " + EXP_TYPE_COL + "='" + expType + "' AND " + EXP_SETUP_COL
            + "='" + expParams + "'";
    String tableName = null;
    ResultSet rs = select(query);
    if (rs.next()) {
        tableName = rs.getString(1);
        if (rs.next()) {
            throw new Exception("More than one index entry "
                    + "for experiment config: " + query);
        }
    }
    close(rs);
    if (m_Debug) {
        System.err.println("...results table = "
                + ((tableName == null) ? "<null>" : EXP_RESULT_PREFIX + tableName));
    }
    return (tableName == null) ? tableName : EXP_RESULT_PREFIX + tableName;
}
 

import weka.experiment.ResultProducer; //导入依赖的package包/类
/**
 * Executes a database query to extract a result for the supplied key from the
 * database.
 *
 * @param tableName the name of the table where the result is stored
 * @param rp        the ResultProducer who will generate the result if required
 * @param key       the key for the result
 * @return true if the result with that key is in the database already
 * @throws Exception if an error occurs
 */
public Object[] getResultFromTable(String tableName, ResultProducer rp,
                                   Object[] key) throws Exception {

    String query = "SELECT ";
    String[] resultNames = rp.getResultNames();
    for (int i = 0; i < resultNames.length; i++) {
        if (i != 0) {
            query += ", ";
        }
        query += resultNames[i];
    }
    query += " FROM " + tableName;
    String[] keyNames = rp.getKeyNames();
    if (keyNames.length != key.length) {
        throw new Exception("Key names and key values of different lengths");
    }
    boolean first = true;
    for (int i = 0; i < key.length; i++) {
        if (key[i] != null) {
            if (first) {
                query += " WHERE ";
                first = false;
            } else {
                query += " AND ";
            }
            query += "Key_" + keyNames[i] + '=';
            if (key[i] instanceof String) {
                query += "'" + processKeyString(key[i].toString()) + "'";
            } else {
                query += key[i].toString();
            }
        }
    }
    ResultSet rs = select(query);
    ResultSetMetaData md = rs.getMetaData();
    int numAttributes = md.getColumnCount();
    if (!rs.next()) {
        throw new Exception("No result for query: " + query);
    }
    // Extract the columns for the result
    Object[] result = new Object[numAttributes];
    for (int i = 1; i <= numAttributes; i++) {
        switch (translateDBColumnType(md.getColumnTypeName(i))) {
            case STRING:
                result[i - 1] = rs.getString(i);
                if (rs.wasNull()) {
                    result[i - 1] = null;
                }
                break;
            case FLOAT:
            case DOUBLE:
                result[i - 1] = new Double(rs.getDouble(i));
                if (rs.wasNull()) {
                    result[i - 1] = null;
                }
                break;
            default:
                throw new Exception("Unhandled SQL result type (field " + (i + 1)
                        + "): " + ExtendedDatabaseUtils.typeName(md.getColumnType(i)));
        }
    }
    if (rs.next()) {
        throw new Exception("More than one result entry " + "for result key: "
                + query);
    }
    close(rs);
    return result;
}
 

import weka.experiment.ResultProducer; //导入依赖的package包/类
/**
 * Executes a database query to insert a result for the supplied key into the
 * database.
 *
 * @param tableName the name of the table where the result is stored
 * @param rp        the ResultProducer who will generate the result if required
 * @param key       the key for the result
 * @param result    the result to store
 * @throws Exception if an error occurs
 */
public void putResultInTable(String tableName, ResultProducer rp,
                             Object[] key, Object[] result) throws Exception {

    String query = "INSERT INTO " + tableName + " VALUES ( ";
    // Add the results to the table
    for (int i = 0; i < key.length; i++) {
        if (i != 0) {
            query += ',';
        }
        if (key[i] != null) {
            if (key[i] instanceof String) {
                query += "'" + processKeyString(key[i].toString()) + "'";
            } else if (key[i] instanceof Double) {
                query += safeDoubleToString((Double) key[i]);
            } else {
                query += key[i].toString();
            }
        } else {
            query += "NULL";
        }
    }
    for (Object element : result) {
        query += ',';
        if (element != null) {
            if (element instanceof String) {
                query += "'" + element.toString() + "'";
            } else if (element instanceof Double) {
                query += safeDoubleToString((Double) element);
            } else {
                query += element.toString();
                // !!
                // System.err.println("res: "+ result[i].toString());
            }
        } else {
            query += "NULL";
        }
    }
    query += ')';

    if (m_Debug) {
        System.err.println("Submitting result: " + query);
    }
    update(query);
    close();
}