编写通用的增删改查方法
不明白的可以看代码中注释,写的很详细。
1 通用的增删改
//通用的更新数据库的方法:insert,update,delete 语句时
public static int update(String sql)throws SQLException{
//1、获取连接
Connection conn = JDBCUtils.getConnection();
//2、获取 Statement 对象,这个对象是用来给服务器传 sql 并执行 sql
Statement st = conn.createStatement();
//3、执行 sql
int len = st.executeUpdate(sql);
//4、释放资源
JDBCUtils.closeQuietly(st, conn);
return len;
}
// 通用的更新数据库的方法:insert,update,delete 语句,允许 sql 带?
public static int update(String sql, Object... args)throws SQLException{
Connection conn = JDBCUtils.getConnection();
int len = update(conn,sql,args);
JDBCUtils.closeQuietly(conn);
return len;
}
// 通用的更新数据库的方法:insert,update,delete 语句,允许 sql 带?
public static int update(Connection conn, String sql, Object... args)throws SQLException{
//2、获取 PreparedStatement 对象,这个对象是用来 sql 进行预编译
PreparedStatement pst = conn.prepareStatement(sql);
//3、设置 sql 中的?
if(args!=null && args.length>0){
//数组的下标是从 0 开始,?的编号是 1 开始
for (int i = 0; i < args.length; i++) {
pst.setObject(i+1, args[i]);
}
}
//4、执行 sql
int len = pst.executeUpdate();
//5、释放资源
JDBCUtils.closeQuietly(pst);
return len;
}
2.工具类通用的查询一个实体的方法
//通用的查询方法之一:查询一行,即一个对象
public static <T> T get(Class<T> clazz,String sql,Object... args)throws Exception{
//1、注册驱动
//2、获取连接
Connection conn = JDBCUtils.getConnection();
//3、对 sql 进行预编译
PreparedStatement pst = conn.prepareStatement(sql);
//4、设置?
if(args!=null && args.length>0){
//数组的下标是从 0 开始,?的编号是 1 开始
for (int i = 0; i < args.length; i++) {
pst.setObject(i+1, args[i]);
}
}
//5、查询
ResultSet rs = pst.executeQuery();
//获取查询的结果集的元数据信息
ResultSetMetaData rsmd = rs.getMetaData();
//这是查询的结果集中,一共有几列
int count = rsmd.getColumnCount();
T t = clazz.newInstance();//要求这个 Javabean 类型必须有无参构造
while(rs.next()){
//循环每一行有几列
for (int i = 0; i < count; i++) {
//第几列的名称
// String columnName = rsmd.getColumnName(i+1);
//如果 sql 中没有取别名,那么就是列名,如果有别名,返回的是别名
String fieldName = rsmd.getColumnLabel(i+1);
//该列的值
// Object value = rs.getObject(columnName);
Object value = rs.getObject(fieldName);
//设置 obj 对象的某个属性中
Field field = clazz.getDeclaredField(fieldName);//JavaBean 的属性名
field.setAccessible(true);
field.set(t, value);
}
}
//5、释放资源
JDBCUtils.closeQuietly(rs,pst,conn);
return t;
}
3.工具类通用的查询多个实体的方法
//通用的查询方法之二:查询多行,即多个对象
//Class<T> clazz:用来创建实例对象,获取对象的属性,并设置属性值
public static <T> ArrayList<T> getList(Class<T> clazz,String sql,Object... args)throws Exception{
//1、注册驱动,不用了
//2、获取连接
Connection conn = JDBCUtils.getConnection();
//3、对 sql 进行预编译
PreparedStatement pst = conn.prepareStatement(sql);
//4、对?进行设置值
if(args!=null && args.length>0){
for (int i = 0; i < args.length; i++) {
pst.setObject(i+1, args[i]);
}
}
//5、执行 sql
ResultSet rs = pst.executeQuery();
//获取结果集的元数据
ResultSetMetaData metaData = rs.getMetaData();
//获取结果中总列数
int count = metaData.getColumnCount();
//创建集合对象
ArrayList<T> list = new ArrayList<T>();
while(rs.next()){//遍历的行
//1、每一行是一个对象
T obj = clazz.newInstance();
//2、每一行有很多列
//for 的作用是为 obj 对象的每一个属性设置值
for (int i = 0; i < count; i++) {
//(1)每一列的名称
String fieldName = metaData.getColumnLabel(i+1);//获取第几列的名称,如果有别名获取别名,如
果没有别名获取列名
//(2)每一列的值
Object value = rs.getObject(i+1);//获取第几列的值
//(3)获取属性对象
Field field = clazz.getDeclaredField(fieldName);
//(4)设置可见性
field.setAccessible(true);
//(5)设置属性值
field.set(obj, value);
}
//3、把 obj 对象放到集合中
list.add(obj);
}
//6、释放资源
JDBCUtils.closeQuietly(rs,pst,conn);
//7、返回结果
return list;
}
4. 工具类通用的查询单值
//通用的查询方法之三:查询单个值
//单值:select max(salary) from employee; 一行一列
//select count(*) from t_goods; 一共几件商品
public static Object getValue(String sql,Object... args)throws Exception{
//2、获取连接
Connection conn = JDBCUtils.getConnection();
//3、对 sql 进行预编译
PreparedStatement pst = conn.prepareStatement(sql);
//4、对?进行设置值
if(args!=null && args.length>0){
for (int i = 0; i < args.length; i++) {
pst.setObject(i+1, args[i]);
}
}
//5、执行 sql
ResultSet rs = pst.executeQuery();
Object value = null;
if(rs.next()){//一行
value = rs.getObject(1);//一列
}
//6、释放资源
JDBCUtils.closeQuietly(rs,pst,conn);
return value;
}
如果有收获!!! 希望老铁们来个三连,点赞、收藏、转发
创作不易,别忘点个赞,可以让更多的人看到这篇文章,顺便鼓励我写出更好的博客