javabean: Database Manager

/**
* 大家用的时候只需要把配置文件里的内容改掉就可以啦!
*
* 配置文件Database.Property内容
* jdbc.drivers=sun.jdbc.odbc.JdbcOdbcDriver
* jdbc.url=jdbc:odbc:mydata
* jdbc.username=system
* jdbc.password=manager
*
*/

package pro03;

// package community.database;
import java.io.*;
import java.util.*;
import java.sql.*;

/**
* Title: Database Manager
* Description: Connect Database
* Copyright: Copyright  2002 YaoGuodong
* Company:
* @author unascribed YaoGuodong 姚国栋
* @version 1.0
* @email [email protected]
* @QQ 16898283
* @转载的时候请保留版权信息
*/
public class DBManager {
  /**getConnection() 得到连接数据库的属性文件内容，并返回连接结果集
    @throws SQLException
    @throws IOException
    @throws Exception
    声明drivers，得到数据库的驱动程序
    声明url，得到连接远程数据库的URL
    声明username，得到连接远程数据库的用户名
    声明password，得到连接远程数据库的密码
    @return DriverManger.getConnection(url,username,passowrd);
   */
  public Connection getConnection() throws SQLException, IOException, Exception {
    Properties props = new Properties();
    //String fileName = "e:\\Database.Property";
    //FileInputStream in = new FileInputStream(fileName);
    InputStream in = getClass().getResourceAsStream("/Database.Property");
    props.load(in);
    String drivers = props.getProperty("jdbc.drivers");
    if (drivers != null) {
      System.setProperty("jdbc.drives", drivers);
    }
    String url = props.getProperty("jdbc.url");
    String username = props.getProperty("jdbc.username");
    String password = props.getProperty("jdbc.password");
    Class.forName(drivers);
    return DriverManager.getConnection(url, username, password);
  }

  /**DBManager()
   * 连接数据库
   */
  public DBManager() {
    try {
      conn = getConnection();
      stmt = conn.createStatement();
      System.out.println("Connect Database is Ok!");
    }
    catch (Exception e) {
      System.out.println("Connect Database Failed!:" + e);
    }
  }

  /** executeQuery()方法,查询SQL结果
    @param sqlwords 为传入的查询的sql语句
    @return rs　为返回的查询结果集
   */
  public ResultSet executeQuery(String sqlwords) {
    this.sqlwords = sqlwords;
    try {
      rs = stmt.executeQuery(sqlwords);
    }
    catch (SQLException ex) {
      System.out.println("Execute Query Sql Failed!:" + ex.getMessage());
    }
    return rs;
  }

  /** executeUpdate()方法，修改数据库记录
    @param sqlwords 为传入的查询的sql语
    @return true|false
   */
  public boolean executeUpdate(String sqlwords) {
    this.sqlwords = sqlwords;
    try {
      stmt.executeUpdate(sqlwords);
      return true;
    }
    catch (SQLException ex) {
      System.err.println("Execute Update Sql Failed!: " + ex.getMessage());
      return false;
    }
  }

  /** executeInsert()方法，插入新的数据库记录
    @param sqlwords 为传入的插入的sql语
    @return true|false
   */
  public boolean executeInsert(String sqlwords) {
    this.sqlwords = sqlwords;
    try {
      stmt.executeUpdate(sqlwords);
      return true;
    }
    catch (SQLException ex) {
      System.err.println("Execute Insert Sql Failed!: " + ex.getMessage());
      return false;
    }
  }

  /** executeDelete()方法，删除数据库记录
    @param sqlwords 为传入的删除的sql语
    @return true|false
   */
  public boolean executeDelete(String sqlwords) {
    this.sqlwords = sqlwords;
    try {
      stmt.executeUpdate(sqlwords);
      return true;
    }
    catch (SQLException ex) {
      System.err.println("Execute Delete Sql Failed!: " + ex.getMessage());
      return false;
    }
  }

  /** close()方法，断开数据库的连接
   *@return true|false
   */
  public boolean close() {
    try {
      if (rs != null) {
        rs.close();
      }
      if (stmt != null) {
        stmt.close();
      }
      if (conn != null) {
        conn.close();
      }
      return true;
    }
    catch (Exception e) {
      System.out.print("Clost Database Connect Failed!:" + e);
      return false;
    }
  }

  /**
   * 声明conn
   * 声明rs结果集
   * 声明stmt语气
   * 声明sqlwords关键字
   */
  Connection conn = null;
  ResultSet rs = null;
  Statement stmt = null;
  private String sqlwords = null;

本文地址：http://com.8s8s.com/it/it17146.htm