jdbc完美封装-传入类型返回bean或者list集合

liuian 2025-05-27 15:53 32 浏览

程序员打交道最多的还是数据库。一般我们会选择各种各样的框架，其对数据库的操作完全封装了，但是有些小项目，小网站什么的用框架又太小题大作了，还有就是入门的程序员需要了解jdbc的过程。所以小编自己封装了这个jdbc，就当小框架用吧，第一次写，还请朋友们多指点。

废话不多说，上图。

1.采用数据库连接池的

使用数据库连接池的

package com.zhumeng.util;
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.HashMap;
import java.util.List;
import java.util.Map;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;
/**
* @author 刘鹏功能：jdbc连接工具类
* jdbc的简单封装
* */
public class MyConnection {
private static Connection conn = null;// 数据库连接
private static PreparedStatement ps = null;// 预编译声明
private static ResultSet rs = null;// 结果集
/**
* 获取数据库连接
*
* @return Connection
*/
public static Connection getConnection() {
try {
Context c = new InitialContext();
DataSource ds = (DataSource)c.lookup("java:comp/env/jdbc/mysql");
conn = ds.getConnection();
// conn = DriverManager.getConnection(url, user, password);
} catch (Exception e) {
e.printStackTrace();
throw new RuntimeException("获取链接对象connection出现错误");
}
return conn;
}
/**
* 获得预编译声明
* */
public static PreparedStatement getPreparedStatement(String sql) {
getConnection();// conn实例化
try {
ps = conn.prepareStatement(sql);
} catch (SQLException e) {
// e.printStackTrace();
throw new RuntimeException("获取预编译对象PreparedStatement出现错误");
}
return ps;
}
/**
* 执行查找，单个或者多个查找都可以返回List<Map<String, Object>>试用于网站
*
* @return List<Map<String, Object>>
* */
// public static List<Map<String, Object>> find(String sql, Object... obj) {
// // 定义一个list，用来存放resultset的数据，map即一result的某一行的数据，即存的一个对象
// List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
// getPreparedStatement(sql);// 实例化预编译对象ps
// try {
// if (obj.length > 0) {// 如果obj有数据，即有传来的参数
// for (int i = 0; i < obj.length; i++) {// 循环把参数赋给预编译的声明
// ps.setObject(i + 1, obj[i]);
// }
// }
// rs = ps.executeQuery();
// ResultSetMetaData metaDate = rs.getMetaData();// 获得结果集的元数据
// int colsNum = metaDate.getColumnCount();// 获取查询的列数
//
// while (rs.next()) {
// Map<String, Object> map = new HashMap<String, Object>();//
// 定义一个map用来存放结果集的某一行的数据
// for (int i = 0; i < colsNum; i++) {
// String colsName = metaDate.getColumnName(i + 1);// 获得列名
// Object colsValue = rs.getObject(colsName);// 获得列值
// if (colsValue == null) {// 如果或的列值为空，赋值为空字符串
// colsValue = "";
// }
// map.put(colsName, colsValue);// 保存为键值对
// }
// list.add(map);// 添加到list集合
// }
//
// } catch (Exception e) {
// // e.printStackTrace();
// throw new RuntimeException("查询时出现错误");
// } finally {
// closeAll();
// }
// return list;
// }
public static <T> List<T> find(T javaBean, String sql, Object... obj) {
// 定义一个list，用来存放resultset的数据，map即一result的某一行的数据，即存的一个对象
List<Map<String, Object>> mapList = new ArrayList<Map<String, Object>>();
getPreparedStatement(sql);// 实例化预编译对象ps
try {
if (obj.length > 0) {// 如果obj有数据，即有传来的参数
for (int i = 0; i < obj.length; i++) {// 循环把参数赋给预编译的声明
ps.setObject(i + 1, obj[i]);
}
}
rs = ps.executeQuery();
ResultSetMetaData metaDate = rs.getMetaData();// 获得结果集的元数据
int colsNum = metaDate.getColumnCount();// 获取查询的列数
while (rs.next()) {
Map<String, Object> map = new HashMap<String, Object>();// 定义一个map用来存放结果集的某一行的数据
for (int i = 0; i < colsNum; i++) {
String colsName = metaDate.getColumnName(i + 1);// 获得列名
Object colsValue = rs.getObject(colsName);// 获得列值
// if (colsValue == null) {// 如果或的列值为空，赋值为空字符串
// colsValue = "";
// }
map.put(colsName, colsValue);// 保存为键值对
}
mapList.add(map);// 添加到list集合
}
} catch (Exception e) {
e.printStackTrace();
// throw new RuntimeException("查询时出现错误");
} finally {
closeAll();
}
List<T> list = MapUtils.map2Java(javaBean, mapList);// 获得查询的数据，并封装成对应的bean返回list集合
return list;
}
/**
* 单个查询，传入什么类型的，返回什么类型。泛型bean
*
* @return T
* */
public static <T> T findOne(T javaBean, String sql, Object... obj) {
List<T> list = find(javaBean, sql, obj);
if (list == null || list.size() == 0) {// list为空返回null，除去空指针异常
return null;
} else {
return list.get(0);
}
}
/**
* 查询总数据
* */
public static int dateCount(String sql){
ps=getPreparedStatement(sql);
int row=0;
try {
rs = ps.executeQuery();
if(rs.next()){
row= rs.getInt(1);
}
} catch (SQLException e) {
// e.printStackTrace();
throw new RuntimeException("查询总数据条数失败！");
}
return row;
}
/**
* 查询，返回ResultSet结果集
*
* @return ResultSet
* */
// public static ResultSet findMany(String sql, Object... obj) {
// /*
// * 可变参数的特点：只能出现在参数列表的最后；
// * ...位于变量类型和变量名之间，前后有无空格都可以；调用可变参数的方法时，编译器为该可变参数隐含创建一个数组
// * ，在方法体中一数组的形式访问可变参数。
// */
// getPreparedStatement(sql);// 实例化预编译对象ps
// try {
// if (obj.length > 0) {
// for (int i = 0; i < obj.length; i++) {// 循环把参数赋给预编译的声明
// ps.setObject(i + 1, obj[i]);
// }
// }
// rs = ps.executeQuery();// 获得查询结果
// } catch (Exception e) {
// // e.printStackTrace();
// throw new RuntimeException("查询时出现错误");
// } finally {
// closeAll();
// }
// return rs;
// }
/**
* update 执行修改数据
*
* @return int
* */
public static int update(String sql, Object... obj) {
int result = 0;
getPreparedStatement(sql);// 实例化预编译对象ps
try {
if (obj.length > 0) {
for (int i = 0; i < obj.length; i++) {// 循环把参数赋给预编译的声明
ps.setObject(i + 1, obj[i]);
}
}
result = ps.executeUpdate();
} catch (Exception e) {
// e.printStackTrace();
throw new RuntimeException("执行DML语句(增，删，改)时出现错误");
} finally {
closeAll();
}
return result;
}
/**
* 关闭数据库连接
*/
public static void closeAll() {
try {
if (rs != null) {
rs.close();
}
if (ps != null) {
ps.close();
}
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
// e.printStackTrace();
throw new RuntimeException("关闭连接时出现错误");
}
}
}
为了操作方便，我封装了个map转bean的类
package com.zhumeng.util;
import java.beans.BeanInfo;
import java.beans.Introspector;
import java.beans.PropertyDescriptor;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
/**
* Map工具类
* 实习map跟object的转换
*/
public class MapUtils {
/**
* Map集合对象转化成 JavaBean集合对象
*
* @param javaBean JavaBean实例对象
* @param mapList Map数据集对象
* @return
*/
public static <T> List<T> map2Java(T javaBean, List<Map<String, Object>> mapList) {
if(mapList == null || mapList.isEmpty()){
return null;
}
List<T> objectList = new ArrayList<T>();
T object = null;
for(Map<String, Object> map : mapList){
if(map != null){
object = map2Java(javaBean, map);
objectList.add(object);
}
}
return objectList;
}
/**
* Map对象转化成 JavaBean对象
*
* @param javaBean JavaBean实例对象
* @param map Map对象
* @return
*/
@SuppressWarnings("unchecked")
public static <T> T map2Java(T javaBean, Map<String, Object> map) {
try {
// 获取javaBean属性
BeanInfo beanInfo = Introspector.getBeanInfo(javaBean.getClass());
// 创建 JavaBean 对象
Object obj = javaBean.getClass().newInstance();
PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
if (propertyDescriptors != null && propertyDescriptors.length > 0) {
String propertyName = null; // javaBean属性名
Object propertyValue = null; // javaBean属性值
for (PropertyDescriptor pd : propertyDescriptors) {
propertyName = pd.getName();
if (map.containsKey(propertyName)) {
propertyValue = map.get(propertyName);
pd.getWriteMethod().invoke(obj, new Object[] { propertyValue });
}
}
return (T) obj;
}
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* JavaBean对象转化成Map对象
*
* @param javaBean
* @return map
*
*/
// @SuppressWarnings({ "rawtypes", "unchecked" })
// public static Map java2Map(Object javaBean) {
// Map map = new HashMap();
//
// try {
// // 获取javaBean属性
// BeanInfo beanInfo = Introspector.getBeanInfo(javaBean.getClass());
//
// PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
// if (propertyDescriptors != null && propertyDescriptors.length > 0) {
// String propertyName = null; // javaBean属性名
// Object propertyValue = null; // javaBean属性值
// for (PropertyDescriptor pd : propertyDescriptors) {
// propertyName = pd.getName();
// if (!propertyName.equals("class")) {
// Method readMethod = pd.getReadMethod();
// propertyValue = readMethod.invoke(javaBean, new Object[0]);
// map.put(propertyName, propertyValue);
// }
// }
// }
//
// } catch (Exception e) {
// e.printStackTrace();
// }
//
// return map;
// }
//
}
2.从文件外读取参数的方式：
db.properties中的参数
/**
* @author 刘鹏功能：jdbc连接工具类 1.获得连接connection对象（需要从properties文件读取连接信息）
* */
public class MyConnection {
private static String driver;// 驱动
private static String url;// 数据库url
private static String user;// 用户名
private static String password;// 密码
private static Connection conn = null;// 数据库连接
private static PreparedStatement ps = null;// 预编译声明
private static ResultSet rs = null;// 结果集
// 从properties文件读取链接信息
public static void getProperties() {
try (BufferedInputStream bi = new BufferedInputStream(
new FileInputStream("src/com/peng/util/db.properties"));) {
Properties pro = new Properties();
pro.load(bi);
driver = pro.getProperty("jdbc.driver").trim();
url = pro.getProperty("jdbc.url").trim();
user = pro.getProperty("jdbc.user").trim();
password = pro.getProperty("jdbc.password").trim();
} catch (Exception e) {
new RuntimeException("获得链接驱动信息出现错误");
}
}
// 类一装入内存是就加载数据库连接驱动
static {
getProperties();
try {
Class.forName(driver);
} catch (ClassNotFoundException e) {
new RuntimeException("加载驱动类出现错误");
}
}
/**
* 获取数据库连接
*
* @return Connection
*/
public static Connection getConnection() {
try {
conn = DriverManager.getConnection(url, user, password);
} catch (SQLException e) {
// e.printStackTrace();
throw new RuntimeException("获取链接对象connection出现错误");
}
return conn;
}
/**
* 获得预编译声明
* */
public static PreparedStatement getPreparedStatement(String sql) {
getConnection();// conn实例化
try {
ps = conn.prepareStatement(sql);
} catch (SQLException e) {
// e.printStackTrace();
throw new RuntimeException("获取预编译对象PreparedStatement出现错误");
}
return ps;
}
剩下的方法同上边使用数据库连接池的。查询单个数据或者批量查找数据