dbaccess.java

用java实现的一个论坛,可以供大家参考

package liuxiaobo.db;

import java.sql.*;

public class DBAccess {

  protected Statement statement;
  protected Connection connection;

  public DBAccess(Connection connection) {
    this.connection=connection;
  }
  public void closeSelect() throws SQLException {
    if (statement != null)
      statement.close();
  }
  public ResultSet openSelect(String sql) throws SQLException {
    //System.out.println(sql);
    statement = connection.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
    ResultSet rs=statement.executeQuery(sql);
    return rs;
  }

  public int runSql(String sql) throws SQLException {
    //System.out.println(sql);
    statement = connection.createStatement();
    int result=statement.executeUpdate(sql);
    statement.close();
    return result;
  }
}