dbsql.java

来自「黑魔方JSP基础教程源代码(耿祥义编著)是这里有课件和jsp源代码」· Java 代码 · 共 95 行

/**
 * Title:        软件超市
 * Description:  管理类DBSQL，实现对数据库的访问
 * Copyright:    Copyright (c) 2001
 * Company:
 * @author
 * @version 1.0
 */

import java.sql.*;

public class DBSQL {
  Connection conn;
  Statement stmt;
  String strCon;
  
/**
 * 构造函数
 */
public DBSQL() {
  conn = null;
  stmt = null;
  strCon = "jdbc:odbc:soft";

  try {
    Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
  } catch (Exception ex) {
    System.err.println("没有找到JDBC-ODBC数据库驱动器");
  }
}

/**
 * 打开数据库，准备操作
 */
public void openDB() {
  try {
    //连接数据库
    conn = DriverManager.getConnection(strCon);
    //创建一个可以滚动的只读的SQL语句对象
    stmt = conn.createStatement();
  } catch (SQLException ex) {
    System.err.println("aq.executeQuery: " + ex.getMessage());
  }
}

/**
 * 关闭数据库
 */
public void closeDB() {
  try {
    //关闭SQL语句对象
    stmt.close();
    //关闭数据库
    conn.close();
  } catch (SQLException ex) {
    System.err.println("aq.executeQuery: " + ex.getMessage());
  }
}

/**
 * 执行数据库SELECT查询
 *
 * @param sql 查询数据库的SELECT语句
 */
public ResultSet executeQuery(String sql) {
  ResultSet rs = null;

  try {
    rs = stmt.executeQuery(sql);
  } catch(SQLException ex) {
    //记录一个错误
    System.err.println("aq.executeQuery: " + ex.getMessage());
  }
  return rs;
}

/**
 * 执行数据库INSERT, UPDATE, DELETE查询
 *
 * @param sql 查询数据库的SELECT语句
 */
public int executeUpdate(String sql) {
  int ret = 0;

  try {
    ret = stmt.executeUpdate(sql);
  } catch(SQLException ex) {
    System.err.println("aq.executeQuery: " + ex.getMessage());
  }

  return ret;
}

} //end of DBSQL