JDBC的简单封装

　　JDBC的简单封装

　　使用JDBC来处理数据库的接口主要有三个，即Connection，PreparedStatement和ResultSet这三个，而对于这三个接口，还可以获取不同类型的元数据，通过这些元数据类获得一些数据库的信息。
元数据(MetaData)，即定义数据的数据。打个比方，就好像我们要想搜索一首歌(歌本身是数据)，而我们可以通过歌名，作者，专辑等信息来搜索，那么这些歌名，作者，专辑等等就是这首歌的元数据。因此数据库的元数据就是一些注明数据库信息的数据。

　　① 由Connection对象的getMetaData()方法获取的是DatabaseMetaData对象。

　　② 由PreparedStatement对象的getParameterMetaData ()方法获取的是ParameterMetaData对象。

　　③由ResultSet对象的getMetaData()方法获取的是ResultSetMetaData对象。

　　今天仅仅使用第二点，所以就解释一下第二点
　　　　ParameterMetaData是由PreparedStatement对象通过getParameterMetaData方法获取而来，主要是针对PreparedStatement对象和其预编译的SQL命令语句提供一些信息，比如像”insert into account(id,name,money) values(?,?,?)”这样的预编译SQL语句，ParameterMetaData能提供占位符参数的个数，获取指定位置占位符的SQL类型等等，功能也比较多，这里不列举完，详细请看有关ParameterMetaData的API文档。
Eg: getParameterCount：获取预编译SQL语句中占位符参数的个数

下面就是贴代码了：封装了几个类（类中对功能做了详细的说明）

第一个类：CommonDao  封装了对JDBC的获取连接和连接关闭， 查询和更新功能

package jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ParameterMetaData;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Types;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;

public class CommonDAO {
	// 数据库连接url
	private static final String url = "jdbc:mysql://localhost:3306/test?Unicode=true&characterEncoding=UTF-8";
	// 数据库连接用户名
	private static final String username = "root";
	// 数据库连接密码
	private static final String password = "root";
	// 数据库驱动
	private static final String jdbcDriver = "com.mysql.jdbc.Driver";

	// 调用 ParameterMetaData.getParameterType(i + 1) 是否会抛出异常
	protected boolean pmdKnownBroken = false;

	public CommonDAO() {
	}

	public CommonDAO(boolean pmdKnownBroken) {
		this.pmdKnownBroken = pmdKnownBroken;
	}

	// 获取连接
	public Connection getConnetion() {
		Connection conn = null;
		try {
			Class.forName(jdbcDriver);
			conn = DriverManager.getConnection(url, username, password);
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}
		return conn;
	}

	/**
	 * @Title: executeQuery
	 * @Description: 执行Sql 查询语句，把结果集合放在一个 List<Map<String,Object>> 里面
	 * @param sql
	 * @param parmas
	 * @return
	 * @return List<Map<String,Object>>
	 */

	@SuppressWarnings("unchecked")
	public List<Map<String, Object>> executeQuery(String sql, Object[] params) {
		return (List<Map<String, Object>>) this.excuteQuery(sql, params, new ListMapHander());
	}

	/**
	 * @Title: excuteQuery
	 * @Description: 查询给定的SQL语句，并且自定义的处理结果集。 调用者需要自己手动实现
	 *               接口<code>ResultSetHander.doHander(ResultSet rs)</code>
	 *               方法以得结果集里面的数据
	 * @param sql
	 * @param params
	 * @param rsh
	 * @return
	 * @return Object
	 */

	public Object excuteQuery(String sql, Object[] params, ResultSetHander rsh) {
		PreparedStatement stmt = null;
		ResultSet rs = null;
		Connection con = this.getConnetion();
		List<Map<String, Object>> resultList = new ArrayList<Map<String, Object>>();
		try {
			stmt = con.prepareStatement(sql);

			System.out.println("SQL:" + sql + "; Parameters:" + Arrays.deepToString(params));

			// 填充Statement的参数
			fillStatement(stmt, params);
			// 执行查询
			rs = stmt.executeQuery();

			Object obj = rsh.doHander(rs);
			return obj;

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			// 关闭数据库连接
			close(con, stmt, rs);
		}
		return resultList;
	}

	public int executeUpdate(String sql, Object[] params) {
		PreparedStatement stmt = null;
		Connection con = this.getConnetion();

		int rs = 0;
		try {
			con.setAutoCommit(false);
			// 创建PreparedStatement对象
			stmt = con.prepareStatement(sql);
			// 填充Statement的参数
			fillStatement(stmt, params);
			System.out.println("SQL:" + sql + "; Parameters:" + Arrays.deepToString(params));
			// 执行查询
			rs = stmt.executeUpdate();
			// 提交事务
			con.commit();
			// 把事务设置为原来的
			con.setAutoCommit(true);
		} catch (SQLException e) {
			// 在捕获到异常的时候事务回滚
			try {
				con.rollback();
				if (!con.getAutoCommit()) {
					con.setAutoCommit(true);
				}
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
			e.printStackTrace();
		} finally {
			// 关闭数据库连接
			close(con, stmt, null);
		}
		return rs;
	}

	/**
	 * @Title: fillStatement
	 * @Description: 填充SQL参数
	 * @param stmt
	 * @param params
	 * @throws SQLException
	 * @return void
	 */
	private void fillStatement(PreparedStatement stmt, Object[] params) throws SQLException {

		// 检测参数的个数是否合法，但是有的数据库驱动不支持 stmt.getParameterMetaData()这个方法。
		// 因此我们有一个一个pmdKnownBroken 变量来标识当前数据驱动是否支持该方法的调用。
		ParameterMetaData pmd = null;
		if (!pmdKnownBroken) {
			pmd = stmt.getParameterMetaData();
			int stmtCount = pmd.getParameterCount();
			int paramsCount = params == null ? 0 : params.length;

			if (stmtCount != paramsCount) {
				System.out.println("stmtCount:" + stmtCount + ",paramsCount:" + paramsCount);
				throw new SQLException(
						"Wrong number of parameters: expected " + stmtCount + ", was given " + paramsCount);
			}
		}

		// 如果 params 为 null 直接返回
		if (params == null) {
			return;
		}

		for (int i = 0; i < params.length; i++) {
			if (params[i] != null) {
				stmt.setObject(i + 1, params[i]);
			} else {
				int sqlType = Types.VARCHAR;
				if (!pmdKnownBroken) {
					try {
						sqlType = pmd.getParameterType(i + 1);
					} catch (SQLException e) {
						pmdKnownBroken = true;
					}
				}
				stmt.setNull(i + 1, sqlType);
			}
		}
	}

	/**
	 * @Title: close
	 * @Description: 关闭数据库连接
	 * @param con
	 * @param stmt
	 * @param rs
	 * @return void
	 */
	private void close(Connection con, Statement stmt, ResultSet rs) {

		if (rs != null) {
			try {
				rs.close();
			} catch (Exception e) {
			} finally {
				if (stmt != null) {
					try {
						stmt.close();
					} catch (SQLException e) {
						e.printStackTrace();
					} finally {
						if (con != null) {
							try {
								con.close();
							} catch (SQLException e) {
								e.printStackTrace();
							}
						}
					}
				}
			}
		}

	}
}

　　下面是自封装集合处理类：

---

package jdbc;

import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class ListMapHander implements ResultSetHander {

    @Override
    public List<Map<String, Object>> doHander(ResultSet rs) throws SQLException {
        List<Map<String, Object>> resultList = new ArrayList<Map<String, Object>>();
        ResultSetMetaData rsmd = rs.getMetaData();
        int cols = rsmd.getColumnCount();

        HashMap<String, Object> m = null;

        // System.out.println("list 结果：");
        // 遍历结果集
        while (rs.next()) {
            m = new HashMap<String, Object>();
            // 将结果集中的数据保存到HashMap中
            for (int i = 1; i <= cols; i++) {
                System.out.println("Label:" + rsmd.getColumnLabel(i));
                System.out.println(rsmd.getColumnName(i) + "," + rs.getObject(i));
                m.put(rsmd.getColumnLabel(i), rs.getObject(i));
            }
            resultList.add(m);
        }
        return resultList;
    }

}

---

 数据处理接口类：

package jdbc;

import java.sql.ResultSet;
import java.sql.SQLException;

public interface ResultSetHander {
    //自定义处理结果集
    public Object doHander(ResultSet rs) throws SQLException;
}

实现上面的接口类：

---

package jdbc;

import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class ListMapHander implements ResultSetHander {

    @Override
    public List<Map<String, Object>> doHander(ResultSet rs) throws SQLException {
        List<Map<String, Object>> resultList = new ArrayList<Map<String, Object>>();
        ResultSetMetaData rsmd = rs.getMetaData();
        int cols = rsmd.getColumnCount();

        HashMap<String, Object> m = null;

        // System.out.println("list 结果：");
        // 遍历结果集
        while (rs.next()) {
            m = new HashMap<String, Object>();
            // 将结果集中的数据保存到HashMap中
            for (int i = 1; i <= cols; i++) {
                System.out.println("Label:" + rsmd.getColumnLabel(i));
                System.out.println(rsmd.getColumnName(i) + "," + rs.getObject(i));
                m.put(rsmd.getColumnLabel(i), rs.getObject(i));
            }
            resultList.add(m);
        }
        return resultList;
    }

}

 下面是测试类：数据以Objcet对象数组的形式传入， 利用占位符。

---

package jdbc;

public class Test {
    public static void main(String[] args) {
        CommonDAO commonDAO = new CommonDAO();
        String sql = "select * from student";
        commonDAO.executeQuery(sql, null);
        /*commonDAO.executeUpdate("insert into student values (?,?,?,?,?)",
                new Object[] { "210", "彭宇", "男", "1995-02-02", "955330" });*/
        
    }
}