dbaccess.java

雷霆论坛是用J2EE技术开发的功能强大、扩展性强、易于定制

package lightningboard.db;

import java.sql.Connection;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.SQLException;
import lightningboard.Debug;
/**
 * Database access
 * @version 0.3.5
 * @author Xiaobo Liu
 */
public class DBAccess {

  protected Statement statement;
  protected Connection connection;
  /**
   * Constructor, Create a new DBAccess object.
   * @param connection a certain connection.
   */
  public DBAccess(Connection connection) {
    this.connection=connection;
  }
  /**
   * Close select
   * @throws SQLException this method
   */
  public void closeSelect() throws SQLException {
    if (statement != null)
      statement.close();
  }
  /**
  * open select
  * @param sql sql string
  * @return ResultSet
  * @throws SQLException this method
  */
  public ResultSet openSelect(String sql) throws SQLException {
    Debug.out(sql);
    statement = connection.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
    ResultSet rs=statement.executeQuery(sql);
    return rs;
  }
  /**
  * Run a sql string
  * @param sql sql string
  * @return int
  * @throws SQLException this method
  */
  public int runSql(String sql) throws SQLException {
    Debug.out(sql);
    statement = connection.createStatement();
    int result=statement.executeUpdate(sql);
    statement.close();
    return result;
  }
}