commdboperation.java

本人编写的数据库连接池的基本应用

package dbaccess.common;
/**
 * @author 			阙韧杰
 * @Title:			CommDBOperation
 * @Description: 	通用数据库的操作
 * @Copyright:(c) 	2006-04-11
 * @Company: 		TIREN
 * @version 		1.0
 * @modify by 
 */

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Vector;

public class CommDBOperation {
	/**
	 * @description 数据源类型
	 * @value		0:"jdbc/myOracle";  1:"jdbc/myOracle_test"
	 * @see			ConnPoolMgr
	 */
	private int intDsType = 0;
	
	/**
	 * @param intparamDsType
	 */
	public CommDBOperation(int intparamDsType) {
		this.intDsType = intparamDsType;
	}

	/**
	 * @param strSql
	 * @return	返回查询结果集
	 */
	public Vector select(String strSql) {
		Vector vtDataRow = new Vector();
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;
		try {
			conn = ConnPoolMgr.getInstance(this.intDsType).getConnection();
			stmt = conn.createStatement();
			rs = stmt.executeQuery(strSql);
			ResultSetMetaData metadata = rs.getMetaData();
			int intColumns = metadata.getColumnCount();
			String strTemp = "";
			String rowData[];
			for (; rs.next(); vtDataRow.addElement(rowData)) {
				rowData = new String[intColumns];
				for (int i = 0; i < intColumns; i++) {
					strTemp = rs.getString(i + 1);
					if (strTemp == null)
						strTemp = "";
					rowData[i] = strTemp;
				}
			}
			if (vtDataRow.size() == 0)
				vtDataRow = null;
		} catch (Exception e) {
			System.out
					.println("Error in CommDBOperation.select(String strSql)");
			System.out.println("SQL:" + strSql);
			vtDataRow = null;
		} finally {
			ConnPoolMgr.getInstance(this.intDsType).close(rs,stmt,conn);
			return vtDataRow;
		}
	}
	
	/**
	 * @param strSql
	 * @return	
	 * @description 	用于执行insert, update, delete一类的语句
	 */
	public int execute(String strSql) {
		int intReturn = -1;
		Connection conn = null;
		Statement stmt = null;
		try {
			conn = ConnPoolMgr.getInstance(this.intDsType).getConnection();
			stmt = conn.createStatement();
			intReturn = stmt.executeUpdate(strSql);
		} catch (Exception e) {
			System.out.println("Error in CommDBOperation.execute(String strSql)");
			System.out.println("SQL:" + strSql);
		} finally {
			ConnPoolMgr.getInstance(this.intDsType).close(stmt,conn);
			return intReturn;
		}
	}
}