简单的jdbc封装

工作中经常用到jdbc，嫌每次创建连接麻烦。自己简单的封装了下，也没有测试，不知道能不能用。

package com.geap.utils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;
import javax.sql.RowSet;
import javax.sql.rowset.CachedRowSet;

import com.sun.rowset.CachedRowSetImpl; //com.sun.rowset.jar包


/**
 * jdbc工具类，提供了三个方法
 * <ul>
 * <li>execute(sql)</li>
 * <li>executeQuery(sql)</li>
 * <li>executeUpdate(sql)</li>
 * </ul>
 * @author QiuLu
 */
public class JdbcUtil {
	
	/**
	 * 查询
	 * @param sql sql语句
	 * @return RowSet 离线结果集（CachedRowSet接口，CachedRowSetImpl实现）
	 * @throws Exception
	 */
	public static RowSet executeQuery(String sql) throws Exception{

		Context ctx = null;
		DataSource ds = null;
		Connection cn = null;
		Statement st = null;
		ResultSet rs = null;
		CachedRowSet crs = null;
		
		try {
			ctx = new InitialContext();
			crs = new CachedRowSetImpl();
			ds = (DataSource) ctx.lookup("java:comp/env/jdbc/OracleDS");
			cn = ds.getConnection();
			st = cn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
			rs = st.executeQuery(sql);
			crs.populate(rs);
			return crs;
			
		} catch (Exception e) {
			throw new RuntimeException(e);
		} finally {
			if(rs != null)
				try {
					rs.close();
				} catch ( Exception e) {
					e.printStackTrace();
				}
			if(st != null)
				try {
					st.close();
				} catch ( Exception e) {
					e.printStackTrace();
				}
			if(cn != null)
				try {
					cn.close();
				} catch ( Exception e) {
					e.printStackTrace();
				}
			if(ctx != null)
				try {
					ctx.close();
				} catch ( Exception e) {
					e.printStackTrace();
				}
		}
	}
	
	/**
	 * 执行sql
	 * @param sql sql语句
	 * @return 如果第一个结果为 ResultSet 对象，则返回 true；如果其为更新计数或者不存在任何结果，则返回 false 
	 * @throws SQLException
	 */
	public static boolean execute(String sql) throws SQLException{
		Context ctx = null;
		DataSource ds = null;
		Connection cn = null;
		Statement st = null;
		ResultSet rs = null;
		
		try {
			ctx = new InitialContext();
			ds = (DataSource) ctx.lookup("java:comp/env/jdbc/OracleDS");
			cn = ds.getConnection();
			st = cn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
			return st.execute(sql);
			
		} catch (Exception e) {
			throw new RuntimeException(e);
		} finally {
			if(rs != null)
				try {
					rs.close();
				} catch ( Exception e) {
					e.printStackTrace();
				}
			if(st != null)
				try {
					st.close();
				} catch ( Exception e) {
					e.printStackTrace();
				}
			if(cn != null)
				try {
					cn.close();
				} catch ( Exception e) {
					e.printStackTrace();
				}
			if(ctx != null)
				try {
					ctx.close();
				} catch ( Exception e) {
					e.printStackTrace();
				}
		}
	}
	
	/**
	 * 执行更新
	 * @param sql sql语句
	 * @return (1) 对于 SQL 数据操作语言 (DML) 语句，返回行计数 (2) 对于什么都不返回的 SQL 语句，返回 0 
	 * @throws SQLException
	 */
	public static int executeUpdate(String sql) throws SQLException{
		Context ctx = null;
		DataSource ds = null;
		Connection cn = null;
		Statement st = null;
		ResultSet rs = null;
		
		try {
			ctx = new InitialContext();
			ds = (DataSource) ctx.lookup("java:comp/env/jdbc/OracleDS");
			cn = ds.getConnection();
			st = cn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
			return st.executeUpdate(sql);
			
		} catch (Exception e) {
			throw new RuntimeException(e);
		} finally {
			if(rs != null)
				try {
					rs.close();
				} catch ( Exception e) {
					e.printStackTrace();
				}
			if(st != null)
				try {
					st.close();
				} catch ( Exception e) {
					e.printStackTrace();
				}
			if(cn != null)
				try {
					cn.close();
				} catch ( Exception e) {
					e.printStackTrace();
				}
			if(ctx != null)
				try {
					ctx.close();
				} catch ( Exception e) {
					e.printStackTrace();
				}
		}
	}
	
}

// 调用JdbcUtil.executeQuery()

public List getList() {
	RowSet crs = null;
	List<E> list = new ArrayList<E>();
	try {
		crs = JdbcUtil.executeQuery("select * from user");
		while(crs.next()){
			// todo
			list.add();
		}
		return list;
	} catch (Exception e) {
		e.printStackTrace();
	} finally{
		if(crs != null)
			try {
				crs.close();
			} catch ( Exception e) {
				e.printStackTrace();
			}
	}
	return null;
}

评论

5 楼 敲木鱼的男孩 2012-11-26  

以上是我个人的理解，有不对之处望指正。

giraffeql 写道

敲木鱼的男孩 写道

恩，明白你的意思了。本人经常用到的就是finally中再次try,,catch以此类推，至到关闭connection具体写法如下：
try {
set.close();
} catch (SQLException e) {

e.printStackTrace();
}
finally{   //防止set.close()异常，st.close不能执行，把它放finally块中
try {
st.close();
} catch (SQLException e) {

e.printStackTrace();
}
finally{//防止st.close()异常，conn不能执行，把它放到finally块中
try {
conn.close();
} catch (SQLException e) {

e.printStackTrace();
}
}
不知道这种方式和你写的那种方式有什么不同之处和各自的优点，以及真正项目中应该如何写，请指教。
}

嗯，理解你的意思。
个人感觉两种方法都行，区别在于，你写的是层级式的，我写的是并列式的。
至于优缺点，我只理解到了两点：
1. 我的并列式，结构简单，但不能做异常转换。
2. 你的层级式，结构相对复杂，优点在于可以做异常转换。

异常转换的意思就是说，你可以在
try {
	st.close();
} catch (SQLException e) {
	e.printStackTrace();
	throw new RuntimeException(e); //此处抛出异常不影响后面的关闭方法
}
的catch中抛出新的异常，而不影响后面的关闭操作。

对于本实例来说，finally中使用了try catch 语句，不会有新异常抛出（至少我没想到如何抛出），所以采用并列式或层级式都行。
…………
以上是我个人的理解，有不对之处望指正。

明白了，谢谢了，共同学习，共同进步！

4 楼 giraffeql 2012-11-26  

敲木鱼的男孩 写道

恩，明白你的意思了。本人经常用到的就是finally中再次try,,catch以此类推，至到关闭connection具体写法如下：
try {
set.close();
} catch (SQLException e) {

e.printStackTrace();
}
finally{   //防止set.close()异常，st.close不能执行，把它放finally块中
try {
st.close();
} catch (SQLException e) {

e.printStackTrace();
}
finally{//防止st.close()异常，conn不能执行，把它放到finally块中
try {
conn.close();
} catch (SQLException e) {

e.printStackTrace();
}
}
不知道这种方式和你写的那种方式有什么不同之处和各自的优点，以及真正项目中应该如何写，请指教。
}

嗯，理解你的意思。
个人感觉两种方法都行，区别在于，你写的是层级式的，我写的是并列式的。
至于优缺点，我只理解到了两点：
1. 我的并列式，结构简单，但不能做异常转换。
2. 你的层级式，结构相对复杂，优点在于可以做异常转换。

异常转换的意思就是说，你可以在
try {
	st.close();
} catch (SQLException e) {
	e.printStackTrace();
	throw new RuntimeException(e); //此处抛出异常不影响后面的关闭方法
}
的catch中抛出新的异常，而不影响后面的关闭操作。

对于本实例来说，finally中使用了try catch 语句，不会有新异常抛出（至少我没想到如何抛出），所以采用并列式或层级式都行。
…………
以上是我个人的理解，有不对之处望指正。

3 楼 敲木鱼的男孩 2012-11-25  

恩，明白你的意思了。本人经常用到的就是finally中再次try,,catch以此类推，至到关闭connection具体写法如下：
try {
set.close();
} catch (SQLException e) {

e.printStackTrace();
}
finally{   //防止set.close()异常，st.close不能执行，把它放finally块中
try {
st.close();
} catch (SQLException e) {

e.printStackTrace();
}
finally{//防止st.close()异常，conn不能执行，把它放到finally块中
try {
conn.close();
} catch (SQLException e) {

e.printStackTrace();
}
}
不知道这种方式和你写的那种方式有什么不同之处和各自的优点，以及真正项目中应该如何写，请指教。
}

2 楼 giraffeql 2012-11-24  

敲木鱼的男孩 写道

好像有点问题吧，就是关闭resultset和statement和connection时，如果任一个的close()方法出错的话都不会再向下执行了，应该把statement或者connection的close()方法放入到finally代块中，使它们最终都会执行吧，不知道说的对不对？

首先谢谢你的评论。
关于你说的这个问题是这么考虑的，rs.close()即使抛出异常，也会被随后的catch抓住。catch里的方法e.printStackTrace()是打印错误信息（这个异常在此就结束了，并不会往外抛）。代码还会继续往下执行，直到finally结束。
你看呢！

1 楼 敲木鱼的男孩 2012-11-21  

好像有点问题吧，就是关闭resultset和statement和connection时，如果任一个的close()方法出错的话都不会再向下执行了，应该把statement或者connection的close()方法放入到finally代块中，使它们最终都会执行吧，不知道说的对不对？