db7manager.java

一套DB2 7到8版本的程序。内附创建ZIP的JAVA类

package com.highsoft.database;

import java.io.IOException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.List;
import java.util.Properties;


/**
 * @author 张毅
 * @exception MyException
 */
public class DB7Manager {

	/**
	 * 日志对象
	 */
	//static Logger log = Logger.getLogger(DBManager.class);

	/**
	 * 数据库的连接对象
	 */
	private  Connection con;

	/**
	 * 查询数据库返回的结果集对象
	 */
	private ResultSet rs;

	/**
	 * 操作数据库对象
	 */
	private Statement st;

	private Properties db;
	public DB7Manager(){
		OpenDB();
	}

	/**
	 * 数据库连接方法
	 * @throws MyException 
	 */
	public void OpenDB(){
		db=new Properties();
		try {
			db.load(DB7Manager.class.getResourceAsStream("jhsy.properties"));
		} catch (IOException e1) {
			// TODO Auto-generated catch block
			System.out.println(e1.getMessage());
		}
		try {
			Class.forName(db.getProperty("boot.className"));
			con = java.sql.DriverManager.getConnection(db.getProperty("boot.url"), db.getProperty("boot.username"), db.getProperty("boot.password"));
			st = con.createStatement();
			System.out.println("DB2 7数据库连接成功");
		} catch (ClassNotFoundException e) {
			// TODO 自动生成 catch 块
			//log.error("OpenDB_数据库驱动不存在"+e);
			//throw new MyException("driver");
			System.out.println("ClassNotFoundException="+e.getMessage());
		} catch (SQLException e) {
			//log.error("OpenDB_获取数据库连接出错"+e);
			//throw new MyException("error");
			System.out.println("SQLException="+e.getMessage());
		} 
	}
	

	/**
	 * 查询数据库时使用此方法
	 * @param strSql 完整的SQL查询语句
	 * @return ResultSet 结果集对象
	 * @throws MyException 
	 */
	public synchronized ResultSet queryDB(String strSql) {
		try {
			st = con.createStatement();
			rs = st.executeQuery(strSql);
			
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			System.out.println(e.getMessage());
		}
		return rs;
	}

	/**
	 * 关闭数据库所有连接对象时调用这个close()方法.
	 * @throws MyException 
	 */
	public void close(){
		if (rs != null) {
			try {
				rs.close();
			} catch (SQLException ex) {
				System.out.println(ex.getMessage());
			}
		}
		if (st != null) {
			try {
				st.close();
			} catch (SQLException ex1) {
				System.out.println(ex1.getMessage());
			}
		}
		if (con != null) {
			try {
				con.close();
			} catch (SQLException ex2) {
				System.out.println(ex2.getMessage());
			}
		}
	}
	
	/**
	 * 对数据库执行添加、删除语句时调用此方法 
	 * @param strSql 完整的SQL语句
	 * @return boolean 布尔型值 true为执行成功,false时失败。
	 * @throws MyException 
	 */

	public boolean executeDB(String strSql){
		boolean flag=false;
		try {
			st = con.createStatement();
			st.execute(strSql);
			flag=true;
		} catch (SQLException ex) {
			//log.error("executeDB_操作失败SQL" + strSql);
			//log.error("executeDB_操作失败!" + ex.toString());
			//throw new MyException("executeerror");
			System.out.println(ex.getMessage());
		}finally{
			if(st!=null)
			{
				try {
					st.close();
				} catch (SQLException e) {
					// TODO 自动生成 catch 块
					//throw new MyException("exestclose");
					System.out.println(e.getMessage());
				}
			}
			if(con!=null)
			{
				try {
					con.close();
				} catch (SQLException e) {
					// TODO 自动生成 catch 块
					//throw new MyException("execonclose");
					System.out.println(e.getMessage());
				}
			}
		}
		return flag;
	}
	public static void main(String[] args) {
		DB7Manager db=new DB7Manager();
	}

}