scoreitemsquery.java

java网站源代码,有数据库的操作代码,业务逻辑代码等内容

package com.itsv.gankao.database;
import java.sql.*;
import java.util.*;

import com.itsv.gankao.common.*;

public class ScoreItemsQuery extends Query {
  public ScoreItemsQuery() {
  }

  public void searchByPersonId(Connection conn, String periodId, String personId)
              throws SQLException{

  String sql = "SELECT * FROM " + ScoreItemsTable.TABLE_NAME
               + " WHERE " + ScoreItemsTable.FULL_COL_PERSON_ID
               + " = " + "'" + personId + "'"
               + " AND " + ScoreItemsTable.FULL_COL_PERIOD_ID
               + "=?";

  PreparedStatement statement = conn.prepareStatement(sql);
  long lPeriodId = new Long(periodId).longValue();
  long lPersonId = new Long(personId).longValue();

//  statement.setString(1, personId);
  statement.setLong(1, lPeriodId);
  statement_ = statement;
  result_ = statement.executeQuery();
}

  public String getName() throws SQLException{
    return result_.getString(ScoreItemsTable.COL_NAME);
  }

  public String getTvalue() throws SQLException{
    return new Double(result_.getDouble(ScoreItemsTable.COL_TVALUE)).toString();
  }
}