dbaccess.java

来自「本系统提供在线商品浏览和购买功能」· Java 代码 · 共 42 行

package test.db;

import test.*;
import java.sql.Connection;
import java.sql.*;
import java.sql.ResultSet;
import java.sql.SQLException;

public class DBAccess {

  protected Statement statement;
  protected Connection connection;

  public DBAccess() {
    try{
      this.connection = DBConnectionManager.getInstance().getConnection();
    }catch(Exception e){
    }
  }

  public void closeSelect() throws SQLException {
    if (statement != null)
      statement.close();
  }

  public ResultSet openSelect(String sql) throws SQLException {
    Debug.out(sql);
    statement = connection.createStatement();
    ResultSet rs=statement.executeQuery(sql);
    return rs;
  }

  public int runSql(String sql) throws SQLException {
    Debug.out(sql);
    statement = connection.createStatement();
    int result=statement.executeUpdate(sql);
    this.closeSelect();
    return result;
  }

}