JDBC的一个基本的封装

  最近在学习JDBC的时候，编写了一个封装程序，此外用于记录。

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

import java.sql.Connection;

/**
 * JDBC辅助类
 * 
 * @author jiangduxi
 * 
 */
public final class JdbcUtils {
	private static String url = "jdbc:mysql://localhost:3306/jdbc"; //连接数据库连接
	private static String use = "root"; // 登陆数据库用户名
	private static String password = "123456"; //登陆数据库密码

	private JdbcUtils() {

	}

	/**
	 * 使用静态模块来进行注册驱动
	 */
	static {
		// 1. 注册驱动
		try {
			Class.forName("com.mysql.jdbc.Driver");
		} catch (ClassNotFoundException e) {
			throw new ExceptionInInitializerError(e);
		}
	}

	/**
	 * 建立数据库连接
	 * 
	 * @return 返回数据库连接
	 * @throws SQLException
	 */
	public static Connection getConnection() throws SQLException {
		return DriverManager.getConnection(url, use, password);
	}

	/**
	 * 释放数据资源
	 * 
	 * @param rs
	 * @param st
	 * @param conn
	 */
	public static void free(ResultSet rs, Statement st, Connection conn) {
		try {
			if (rs != null)
				rs.close();
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			try {
				if (st != null)
					st.close();
			} catch (SQLException e) {
				e.printStackTrace();
			} finally {
				if (conn != null)
					try {
						conn.close();
					} catch (SQLException e) {
						e.printStackTrace();
					}
			}
		}
	}

}

下面看看怎么在Add操作中使用该上面的封装类吧！
该AddData方法是用于对user表进行简单的添加操作

 public static void AddData() throws SQLException{
   Connection conn = null
   Statement st = null;
   ResultSet rs = null;
   try{
        //建立连接
        conn = JdbcUtils.getConnection();
        //创建sql语句
        st = conn.createStatement();
        String sql = "INSERT INTO user(name,birthday,money)VALUES('XXXXX','1985-05-19','500.99')";
        //执行SQL语句
       int i = st.executeUpdate(sql);

    }finally {
      JdbcUtils.free(rs, st, conn);
   }
 }

其他的Update、Delete、Search方法都类似。就不给出方法了。
一般的JDBC的步骤是

引用

1. Class.forName()进行注册驱动
2. getConnection() 获取连接
3. 创建SQL语句
4. 执行SQL语句
5. 释放资源

在上述的步骤中尤其要注意释放资源。而且在释放资源的时候尤其要注意，当参数传过来的含有未释放的参数。这个释放资源一般属于慢性病。如果你忘记了，那么系统会慢慢的死掉。

评论

4 楼 dandan_5956 2010-03-11  

package com.chm.webservice.dao.impl;

import java.lang.reflect.Field;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.springframework.dao.DataAccessException;
import org.springframework.dao.DataRetrievalFailureException;
import org.springframework.jdbc.core.PreparedStatementCallback;
import org.springframework.jdbc.core.PreparedStatementCreator;
import org.springframework.jdbc.core.simple.SimpleJdbcDaoSupport;

import com.chm.webservice.dao.BaseDAO;

/**
 * @version 1.0 Mar 1, 2010
 * @author danjiang
 */
@SuppressWarnings("unchecked")
public class BaseDAOImpl extends SimpleJdbcDaoSupport implements BaseDAO {

	/**
	 * 查询列表（POJO的属性名一定要与sql中列名一致）
	 * 
	 * @param clazz
	 *            POJO类模板,支持基本类型int.class,long.class和String
	 * @param sql
	 *            查询SQL
	 * @param args
	 *            SQL参数
	 * @return 指定类型的列表
	 * @throws Exception
	 */
	public List queryList(final Class clazz, final String sql,
			final Object[] args) {

		return (List) getJdbcTemplate().execute(new PreparedStatementCreator() {

			public PreparedStatement createPreparedStatement(Connection con)
					throws SQLException {

				PreparedStatement pstmt = con.prepareStatement(sql);
				if (args != null) {
					for (int i = 0; i < args.length; i++)
						pstmt.setObject(i + 1, args[i]);
				}
				return pstmt;

			}

		}, new PreparedStatementCallback() {

			public Object doInPreparedStatement(PreparedStatement pstmt)
					throws SQLException, DataAccessException {

				ResultSet rs = pstmt.executeQuery();
				ResultSetMetaData meta = rs.getMetaData();
				List results = null;
				boolean hasNext = rs.next();
				if (hasNext)
					results = new ArrayList();
				try {
					while (hasNext) {
						Object obj = null;
						if (!"String".equals(clazz.getSimpleName())
								&& !clazz.isPrimitive()) {
							obj = clazz.newInstance();
							for (int i = 1; i <= meta.getColumnCount(); i++) {
								Field field = clazz.getDeclaredField(meta
										.getColumnName(i).toLowerCase());
								field.setAccessible(true);
								field.set(obj, convert(rs, i, field.getType()));
							}
						} else {
							obj = convert(rs, 1, clazz);
						}
						results.add(obj);
						hasNext = rs.next();
					}
				} catch (Exception e) {
					throw new DataRetrievalFailureException("BaseDAO装载数据出错", e);
				}
				return results;

			}

		});
	}

	/**
	 * 查询实体（POJO的属性名一定要与sql中列名一致）
	 * 
	 * @param clazz
	 *            POJO类模板,支持基本类型int.class,long.class和String
	 * @param sql
	 *            查询SQL
	 * @param args
	 *            SQL参数
	 * @return 指定类型的实体
	 * @throws Exception
	 */
	public Object queryObject(Class clazz, String sql, Object[] args) {
		
		List results = queryList(clazz, sql, args);
		if (results != null && !results.isEmpty())
			return results.get(0);
		else
			return null;
		
	}

	/**
	 * 将结果集中值转换为所需类型
	 * 
	 * @param rs
	 *            结果集
	 * @param i
	 *            第几个值
	 * @param clazz
	 *            类型
	 * @return
	 * @throws SQLException
	 */
	private Object convert(ResultSet rs, int i, Class clazz)
			throws SQLException {
		
		Object obj = null;
		if ("String".equals(clazz.getSimpleName()))
			obj = rs.getString(i);
		else if ("int".equals(clazz.getSimpleName()))
			obj = rs.getInt(i);
		else if ("long".equals(clazz.getSimpleName()))
			obj = rs.getLong(i);
		else
			obj = rs.getObject(i);
		return obj;
		
	}
}

3 楼 gundumw100 2010-03-11  

每次都getConnection，不觉得浪费？

2 楼 zzzlyr 2010-03-11  

这好像是在练习

1 楼 dandan_5956 2010-03-11  

这也是封装