JavaWeb之JDBC（2.2）：数据库事务、数据库连接池、DBUtils、DAO及其子类代码演示

2024-03-23 22:50
文章标签 java 代码 web jdbc 数据库 连接池 2.2 演示 事务 dao 子类 dbutils

本文主要是介绍JavaWeb之JDBC（2.2）：数据库事务、数据库连接池、DBUtils、DAO及其子类代码演示，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

写在前面：JDBCUtils类代码主要提供对MySQL数据库的连接、关闭功能，Customer和Order等bean类主要封装对应数据库相关属性并提供get、set、toString方法及构造器，具体代码请看前面的博文。

附上JDBCUTils类代码

package JavaWeb.JDBC.day3.util;import java.io.FileInputStream;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;import javax.sql.DataSource;import JavaWeb.JDBC.day3.connection.DBCPTest;
import org.apache.commons.dbcp.BasicDataSourceFactory;
import org.apache.commons.dbutils.DbUtils;import com.mchange.v2.c3p0.ComboPooledDataSource;/*** 提供数据库连接、关闭等操作的工具类*/
public class JDBCUtils {/*** 测试main方法* @param args* @throws SQLException*/public static void main(String[] args) throws SQLException {Connection conn = getC3P0Connection();System.out.println(conn);}// 关闭资源的操作public static void closeResource(Connection conn, Statement st, ResultSet rs) {try {DbUtils.close(conn);} catch (SQLException e) {e.printStackTrace();}try {DbUtils.close(st);} catch (SQLException e) {e.printStackTrace();}try {DbUtils.close(rs);} catch (SQLException e) {e.printStackTrace();}}// 关闭资源的操作public static void closeResource(Connection conn, Statement st) {if (conn != null) {try {conn.close();} catch (SQLException e) {e.printStackTrace();}}if (st != null) {try {st.close();} catch (SQLException e) {e.printStackTrace();}}}// 获取连接的操作public static Connection getConnection() throws Exception {// 1.加载配置文件Properties pros = new Properties();FileInputStream fis = new FileInputStream("D:\\Workspaces\\Java20190715\\TeacherProgram\\src\\jdbc.properties");pros.load(fis);// 2.获取连接所需的四个基本信息String driverClass = pros.getProperty("driverClass");String url = pros.getProperty("url");String user = pros.getProperty("user");String password = pros.getProperty("password");// 3.加载驱动Class.forName(driverClass);// 4.获取连接Connection conn = DriverManager.getConnection(url, user, password);return conn;}//使用c3p0数据库连接池的方式private static ComboPooledDataSource cpds = new ComboPooledDataSource("helloc3p0"); //保证此数据源是唯一的！public static Connection getC3P0Connection() throws SQLException {Connection conn = cpds.getConnection();return conn;}//使用dbcp数据库连接池的方式private static DataSource source;//保证此数据源是唯一的！static{try {Properties pros = new Properties();InputStream is = DBCPTest.class.getClassLoader().getResourceAsStream("dbcp.properties");pros.load(is);source = BasicDataSourceFactory.createDataSource(pros);} catch (Exception e) {e.printStackTrace();}}public static Connection getDBCPConnection() throws SQLException {Connection conn = source.getConnection();return conn;}}

1.事务：一组逻辑操作单元,使数据从一种状态变换到另一种状态。
2.事务处理的原则：
保证所有事务都作为一个工作单元来执行，即使出现了故障，都不能改变这种执行方式。
当在一个事务中执行多个操作时，要么所有的事务都被提交(commit)，那么这些修改就永久地保存下来；
要么数据库管理系统将放弃所作的所有修改，整个事务回滚(rollback)到最初状态。

演示转账问题

例子：
AA 向 BB 转账 100
过程一：
update user_table set balance = balance - 100 where user = AA.
假设中途服务器宕机
过程二：
update user_table set balance = balance + 100 where user = BB.

注意：最下面是转账失败代码，阅读请留意

package JavaWeb.JDBC.day3.java;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 JavaWeb.JDBC.day3.util.JDBCUtils;
import org.junit.Test;public class TransactionTest {// 通用的查询，返回一条记录 （version 2.0）public <T> T getInstance(Connection conn,Class<T> clazz, String sql, Object... args) {PreparedStatement ps = null;ResultSet rs = null;try {// 1.预编译sql语句ps = conn.prepareStatement(sql);// 2.填充占位符for (int i = 0; i < args.length; i++) {ps.setObject(i + 1, args[i]);}// 3.调用executeQuery()，获取结果集rs = ps.executeQuery();// 4.获取结果集的元数据ResultSetMetaData rsmd = rs.getMetaData();// 5.获取结果集中列的个数int columnCount = rsmd.getColumnCount();// 6.处理结果集if (rs.next()) {// ①判断指针的下一个位置是否有数据 ②如果返回true,指针下移。如果返回false,指针不下移。T t = clazz.newInstance();for (int i = 0; i < columnCount; i++) {// 处理列Object columnValue = rs.getObject(i + 1);// 获取列值String columnLabel = rsmd.getColumnLabel(i + 1);// 获取结果集中列的别名// 反射Field field = clazz.getDeclaredField(columnLabel);field.setAccessible(true);field.set(t, columnValue);}return t;}} catch (Exception e) {e.printStackTrace();} finally {// 7.关闭资源JDBCUtils.closeResource(null, ps, rs);}return null;}/** 演示转账操作* */@Testpublic void testUpdateWithTx() {Connection conn = null;try {String sql1 = "update user_table set balance = balance - 100 where user = ?";String sql2 = "update user_table set balance = balance + 100 where user = ?";conn = JDBCUtils.getConnection();//1.设置不能自动提交数据conn.setAutoCommit(false);//过程一：updateWithTx(conn,sql1,"AA");//出现异常System.out.println(10 / 0);//过程二：updateWithTx(conn,sql2,"BB");//2.提交数据conn.commit();System.out.println("转账成功！");} catch (Exception e) {e.printStackTrace();try {//3.回滚数据conn.rollback();} catch (SQLException e1) {e1.printStackTrace();}}finally {if(conn != null) {//关闭连接JDBCUtils.closeResource(conn, null);}}}//通用的增删改 （version 2.0）public void updateWithTx(Connection conn ,String sql, Object... args) {PreparedStatement ps = null;try {// 1.ps = conn.prepareStatement(sql);// 2.填充占位符for(int i = 0;i < args.length;i++) {ps.setObject(i + 1, args[i]);}// 3.执行int count = ps.executeUpdate();System.out.println("影响了" + count + "条数据");} catch (Exception e) {e.printStackTrace();} finally {// 4.连接一定不要关闭！JDBCUtils.closeResource(null, ps,null);}}

在这里插入图片描述
使用2.0版本转账方法发生了事务回滚
在这里插入图片描述
/*
* 1. 数据一旦提交，不可回滚。
* 2. 哪些操作，会导致数据的提交：
* 情况一：执行的DML操作，默认情况下，一旦执行完，就会自动提交数据。 （set autocommit = false）
* 情况二：一旦断开数据库的连接，也会提交之前未提交的数据。
*
*/

	@Testpublic void testUpdate() {String sql1 = "update user_table set balance = balance - 100 where user = ?";String sql2 = "update user_table set balance = balance + 100 where user = ?";update(sql1,"AA");//模拟网络出现阻塞的异常System.out.println(10 / 0);update(sql2,"BB");System.out.println("转账成功");}//通用的增删改 （version 1.0）public void update(String sql, Object... args) {Connection conn = null;PreparedStatement ps = null;try {// 1.conn = JDBCUtils.getConnection();// 2.ps = conn.prepareStatement(sql);// 3.填充占位符for(int i = 0;i < args.length;i++) {ps.setObject(i + 1, args[i]);}			// 4.执行int count = ps.executeUpdate();System.out.println("影响了" + count + "条数据");} catch (Exception e) {e.printStackTrace();} finally {// 5.JDBCUtils.closeResource(conn, ps,null);}}}

在这里插入图片描述
使用1.0版本方法转账失败，没有回滚
在这里插入图片描述

dbutils工具包包下QueryRunner、handlers.BeanHandler、handlers.BeanListHandler、handlers.MapHandler、handlers.ScalarHandler的使用

package JavaWeb.JDBC.day3.java;import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;import JavaWeb.JDBC.day3.bean.Customer;
import JavaWeb.JDBC.day3.util.JDBCUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.MapHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
import org.junit.Test;public class QueryRunnerTest {//查询一些特殊数据：查询最大值 、 平均数@Testpublic void testScalarValue() throws Exception {QueryRunner runner = new QueryRunner();Connection conn = JDBCUtils.getConnection();ScalarHandler handler = new ScalarHandler();//需求一：查询birth的最大值
//		String sql = "select max(birth) from customers";
//		Date birth = (Date) runner.query(conn, sql, handler);
//		System.out.println(birth);//需求二：查询表中的数据的数量String sql = "select count(*) from customers";long count = (long) runner.query(conn, sql, handler);System.out.println(count);JDBCUtils.closeResource(conn, null);
}

在这里插入图片描述

//查询表中的一条记录，以key-value的方式显示
@Test
public void testQueryForMap() throws Exception {QueryRunner runner = new QueryRunner();Connection conn = JDBCUtils.getConnection();String sql = "select id,name,email,birth from customers where id = ?";MapHandler handler = new MapHandler();Map<String, Object> map = runner.query(conn, sql, handler, 6);System.out.println(map);JDBCUtils.closeResource(conn, null);
}

在这里插入图片描述

//查询表中的多条记录构成的集合：BeanListHandler
@Test
public void testQueryForList() throws Exception {QueryRunner runner = new QueryRunner();Connection conn = JDBCUtils.getConnection();String sql = "select id,name,email,birth from customers where id < ?";BeanListHandler<Customer> handler = new BeanListHandler<>(Customer.class);List<Customer> list = runner.query(conn, sql, handler, 10);list.forEach(System.out::println);JDBCUtils.closeResource(conn, null);
}

在这里插入图片描述

//查询表中的一条记录:BeanHandler
@Test
public void testQueryInstance() throws Exception {QueryRunner runner = new QueryRunner();Connection conn = JDBCUtils.getConnection();String sql = "select id,name,email,birth from customers where id = ?";BeanHandler<Customer> handler = new BeanHandler<>(Customer.class);Customer customer = runner.query(conn, sql, handler, 6);System.out.println(customer);JDBCUtils.closeResource(conn, null);
}

在这里插入图片描述

@Test
public void testInsert() {Connection conn = null;try {QueryRunner runner = new QueryRunner();conn = JDBCUtils.getC3P0Connection();String sql = "insert into customers(name,email,birth)values(?,?,?)";//调用如下的update()方法实现增、删、改的操作runner.update(conn, sql,"张三","zhangsan@gmail.com","2019-08-04");} catch (SQLException e) {e.printStackTrace();}JDBCUtils.closeResource(conn, null);
}
}

插入成功
在这里插入图片描述
以上是JDBC重点，下面介绍c3p0与dbcp连接池

使用 c3p0数据库连接池技术实现数据库连接

package JavaWeb.JDBC.day3.connection;import java.sql.Connection;
import java.sql.SQLException;import com.mchange.v2.c3p0.ComboPooledDataSource;
import org.junit.Test;

/**

  • 1.实现数据库连接的方式：
  • ① 手动实现的连接 （DriverManager)
  • ② 使用数据库连接池
  • 2.使用数据库连接池的好处：
  • ① 更快的连接速度
  • ② 更好的资源重用
  • ③ 更便捷的数据库连接的管理
  • 3.JDBC 的数据库连接池使用 javax.sql.DataSource 来表示，DataSource 只是一个接口

*4.两种数据库连接池技术：
① C3P0 数据库连接池 ② DBCP数据库连接池
*/

public class C3P0Test {//方式二：使用配置文件
@Test
public void testConnection2() throws SQLException {ComboPooledDataSource cpds = new ComboPooledDataSource("helloc3p0");Connection conn = cpds.getConnection();System.out.println(conn);	
}//方式一：
@Test
public void testConnection1() throws Exception {ComboPooledDataSource cpds = new ComboPooledDataSource();cpds.setDriverClass( "com.mysql.jdbc.Driver" ); cpds.setJdbcUrl( "jdbc:mysql://localhost:3306/test" );cpds.setUser("root");                                  cpds.setPassword("abc123");//cpds.setMaxPoolSize(100);Connection conn = cpds.getConnection();System.out.println(conn);
}}

在这里插入图片描述
c3p0配置文件代码
在这里插入图片描述

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config><named-config name="helloc3p0"><!-- 数据库连接的4个基本信息 --><property name="driverClass">com.mysql.jdbc.Driver</property><property name="jdbcUrl">jdbc:mysql:///test</property><property name="user">root</property><property name="password">abc123</property><!-- 涉及数据库连接池管理的其他信息 --><!-- 当数据库连接池中的连接不足时，c3p0数据源一次性向数据库服务器申请的连接数 --><property name="acquireIncrement">5</property><!-- 初始化时，数据库连接池中的连接数 --><property name="initialPoolSize">10</property><!-- 连接池中最少的连接数 --><property name="minPoolSize">10</property><!-- 数据库连接池中维护的连接数的最大容量 --><property name="maxPoolSize">100</property><!-- 数据库连接池中，最多维护的Statement的个数 --><property name="maxStatements">50</property><!-- 一次连接中最多可以使用的Statement的个数 --><property name="maxStatementsPerConnection">2</property></named-config>
</c3p0-config>

使用DBCP数据库连接池技术实现数据库连接

package JavaWeb.JDBC.day3.connection;import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;import javax.sql.DataSource;import org.apache.commons.dbcp.BasicDataSource;
import org.apache.commons.dbcp.BasicDataSourceFactory;
import org.junit.Test;/*** 使用DBCP数据库连接池技术实现数据库连接* @author Administrator**/
public class DBCPTest {//方式二：使用配置文件@Testpublic void testGetConnection2() throws Exception {Properties pros = new Properties();//方式1：
//		FileInputStream is = new FileInputStream("src/dbcp.properties");//方式2：InputStream is = DBCPTest.class.getClassLoader().getResourceAsStream("dbcp.properties");pros.load(is);DataSource source = BasicDataSourceFactory.createDataSource(pros);Connection conn = source.getConnection();System.out.println(conn);
}//方式一：
@Test
public void testGetConnection1() throws SQLException {BasicDataSource source = new BasicDataSource();source.setDriverClassName("com.mysql.jdbc.Driver");source.setUrl("jdbc:mysql://localhost:3306/test");source.setUsername("root");source.setPassword("abc123");//source.setInitialSize(10);//...Connection conn = source.getConnection();System.out.println(conn);
}}

在这里插入图片描述
dbcp配置文件则要简单很多，看不懂请学下io流的properties
在这里插入图片描述

driverClassName=com.mysql.jdbc.Driver
url=Jdbc:mysql:///test
username=root
password=abc123

DAO

DAO: data(base) access object 数据访问对象

不考虑事务的DAO1.0介绍

package JavaWeb.JDBC.day3.dao;import JavaWeb.JDBC.day3.util.JDBCUtils;import java.lang.reflect.Field;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.util.ArrayList;
import java.util.List;public class DAO {// 通用的查询，返回多条记录 （version 2.0:考虑到事务）public <T> List<T> getForList(Connection conn, Class<T> clazz, String sql, Object... args) {PreparedStatement ps = null;ResultSet rs = null;List<T> list = new ArrayList<>();try {// 1.预编译sql语句ps = conn.prepareStatement(sql);// 2.填充占位符for (int i = 0; i < args.length; i++) {ps.setObject(i + 1, args[i]);}// 3.调用executeQuery()，获取结果集rs = ps.executeQuery();// 4.获取结果集的元数据ResultSetMetaData rsmd = rs.getMetaData();// 5.获取结果集中列的个数int columnCount = rsmd.getColumnCount();// 6.处理结果集while (rs.next()) {// ①判断指针的下一个位置是否有数据 ②如果返回true,指针下移。如果返回false,指针不下移。T t = clazz.newInstance();for (int i = 0; i < columnCount; i++) {// 处理列Object columnValue = rs.getObject(i + 1);// 获取列值String columnLabel = rsmd.getColumnLabel(i + 1);// 获取结果集中列的别名// 反射Field field = clazz.getDeclaredField(columnLabel);field.setAccessible(true);field.set(t, columnValue);}list.add(t);}return list;} catch (Exception e) {e.printStackTrace();} finally {// 7.关闭资源JDBCUtils.closeResource(null, ps, rs);}	return null;}// 通用的查询，返回一条记录 （version 2.0:考虑到事务）public <T> T getInstance(Connection conn, Class<T> clazz, String sql, Object... args) {PreparedStatement ps = null;ResultSet rs = null;try {// 1.预编译sql语句ps = conn.prepareStatement(sql);// 2.填充占位符for (int i = 0; i < args.length; i++) {ps.setObject(i + 1, args[i]);}// 3.调用executeQuery()，获取结果集rs = ps.executeQuery();// 4.获取结果集的元数据ResultSetMetaData rsmd = rs.getMetaData();// 5.获取结果集中列的个数int columnCount = rsmd.getColumnCount();// 6.处理结果集if (rs.next()) {// ①判断指针的下一个位置是否有数据 ②如果返回true,指针下移。如果返回false,指针不下移。T t = clazz.newInstance();for (int i = 0; i < columnCount; i++) {// 处理列Object columnValue = rs.getObject(i + 1);// 获取列值String columnLabel = rsmd.getColumnLabel(i + 1);// 获取结果集中列的别名// 反射Field field = clazz.getDeclaredField(columnLabel);field.setAccessible(true);field.set(t, columnValue);}return t;}} catch (Exception e) {e.printStackTrace();} finally {// 7.关闭资源JDBCUtils.closeResource(null, ps, rs);}return null;}// 通用的增删改 （version 2.0:考虑到事务）public void update(Connection conn, String sql, Object... args) {PreparedStatement ps = null;try {// 1.ps = conn.prepareStatement(sql);// 2.填充占位符for (int i = 0; i < args.length; i++) {ps.setObject(i + 1, args[i]);}// 3.执行int count = ps.executeUpdate();System.out.println("影响了" + count + "条数据");} catch (Exception e) {e.printStackTrace();} finally {// 4.连接一定不要关闭！JDBCUtils.closeResource(null, ps, null);}}
}

创建CustomerDAO类继承DAO，添加对customers表的增删改查方法
package JavaWeb.JDBC.day3.dao;

import JavaWeb.JDBC.day3.bean.Customer;import java.sql.Connection;
import java.util.List;public class CustomerDAO extends DAO{/*** 查询表中的所有记录* @param conn* @return*/public List<Customer> getAll(Connection conn){String sql = "select id,name,email,birth from customers ";List<Customer> list = getForList(conn, Customer.class, sql);return list;}/*** 查询指定id的对象* @param conn* @param id* @return*/public Customer getById(Connection conn,int id) {String sql = "select id,name,email,birth from customers where id = ?";Customer customer = getInstance(conn,Customer.class, sql, id);return customer;}/*** 修改数据表中的一条记录* @param conn* @param cust*/public void updateCustomer(Connection conn,Customer cust) {//cust = new Customer(10,"迪丽热巴",..,..)String sql = "update customers set name = ?,email = ?,birth = ? where id = ?";update(conn, sql,cust.getName(),cust.getEmail(),cust.getBirth(),cust.getId());}/*** 删除数据表中指定id对应的数据* @param conn* @param id*/public void deleteById(Connection conn,int id) {String sql = "delete from customers where id = ?";update(conn, sql,id);}/*** 向customers表中插入一条数据* @param conn* @param cust*/public void addCustomer(Connection conn,Customer cust) {String sql = "insert into customers(name,email,birth)values(?,?,?)";update(conn, sql,cust.getName(),cust.getEmail(),cust.getBirth());}
}

创建CustomerDAO的测试类CustomerDAOTest测试类测试以上方法
package JavaWeb.JDBC.day3.dao;

import java.sql.Connection;
import java.sql.Date;
import java.util.List;import JavaWeb.JDBC.day3.bean.Customer;
import JavaWeb.JDBC.day3.util.JDBCUtils;
import org.junit.Test;/*** CustomerDAO的测试类**/
public class CustomerDAOTest {@Testpublic void testGetAll() throws Exception {CustomerDAO dao = new CustomerDAO();//		Connection conn = JDBCUtils.getConnection();
//		Connection conn = JDBCUtils.getC3P0Connection();Connection conn = JDBCUtils.getDBCPConnection();List<Customer> list = dao.getAll(conn);list.forEach(System.out::println);JDBCUtils.closeResource(conn, null);}

在这里插入图片描述

	@Testpublic void testGetOne() throws Exception {CustomerDAO dao = new CustomerDAO();Connection conn = JDBCUtils.getConnection();Customer cust = dao.getById(conn, 8);System.out.println(cust);JDBCUtils.closeResource(conn, null);}

在这里插入图片描述

	@Testpublic void testAdd() throws Exception {CustomerDAO dao = new CustomerDAO();Connection conn = JDBCUtils.getConnection();Customer cust = new Customer(1,"任鑫","ren@126.com",new Date(1242423423L));dao.addCustomer(conn, cust);JDBCUtils.closeResource(conn, null);}}

在这里插入图片描述
添加成功
在这里插入图片描述

考虑事务的DAO2.0介绍

反射工具类ReflectionUtil 准备

package JavaWeb.JDBC.day3.dao1;import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;public class ReflectionUtil {//反射的工具类/*** 获取形参clazz的父类的泛型* @param clazz* @return*/public static Class getGenericParam(Class clazz) {//Class clazz = CustomerDAO.classType type = clazz.getGenericSuperclass();ParameterizedType paramType = (ParameterizedType) type;Type[] typeArguments = paramType.getActualTypeArguments();//返回泛型参数构成的数组return (Class) typeArguments[0];}
}

DAO2.0代码（考虑事务）
package JavaWeb.JDBC.day3.dao1;

import JavaWeb.JDBC.day3.util.JDBCUtils;import java.lang.reflect.Field;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.util.ArrayList;
import java.util.List;/** DAO: data(base) access object 数据访问对象*/
public class DAO<T> {private Class<T>  clazz = null;{//给clazz赋值clazz = ReflectionUtil.getGenericParam(this.getClass());//比如：CustomerDAO}// 通用的查询，返回一条记录 （version 2.0:考虑到事务）public List<T> getForList(Connection conn, String sql, Object... args) {PreparedStatement ps = null;ResultSet rs = null;List<T> list = new ArrayList<>();try {// 1.预编译sql语句ps = conn.prepareStatement(sql);// 2.填充占位符for (int i = 0; i < args.length; i++) {ps.setObject(i + 1, args[i]);}// 3.调用executeQuery()，获取结果集rs = ps.executeQuery();// 4.获取结果集的元数据ResultSetMetaData rsmd = rs.getMetaData();// 5.获取结果集中列的个数int columnCount = rsmd.getColumnCount();// 6.处理结果集while (rs.next()) {// ①判断指针的下一个位置是否有数据 ②如果返回true,指针下移。如果返回false,指针不下移。T t = clazz.newInstance();for (int i = 0; i < columnCount; i++) {// 处理列Object columnValue = rs.getObject(i + 1);// 获取列值String columnLabel = rsmd.getColumnLabel(i + 1);// 获取结果集中列的别名// 反射Field field = clazz.getDeclaredField(columnLabel);field.setAccessible(true);field.set(t, columnValue);}list.add(t);}return list;} catch (Exception e) {e.printStackTrace();} finally {// 7.关闭资源JDBCUtils.closeResource(null, ps, rs);}return null;}// 通用的查询，返回一条记录 （version 2.0:考虑到事务）public T getInstance(Connection conn,  String sql, Object... args) {PreparedStatement ps = null;ResultSet rs = null;try {// 1.预编译sql语句ps = conn.prepareStatement(sql);// 2.填充占位符for (int i = 0; i < args.length; i++) {ps.setObject(i + 1, args[i]);}// 3.调用executeQuery()，获取结果集rs = ps.executeQuery();// 4.获取结果集的元数据ResultSetMetaData rsmd = rs.getMetaData();// 5.获取结果集中列的个数int columnCount = rsmd.getColumnCount();// 6.处理结果集if (rs.next()) {// ①判断指针的下一个位置是否有数据 ②如果返回true,指针下移。如果返回false,指针不下移。T t = clazz.newInstance();for (int i = 0; i < columnCount; i++) {// 处理列Object columnValue = rs.getObject(i + 1);// 获取列值String columnLabel = rsmd.getColumnLabel(i + 1);// 获取结果集中列的别名// 反射Field field = clazz.getDeclaredField(columnLabel);field.setAccessible(true);field.set(t, columnValue);}return t;}} catch (Exception e) {e.printStackTrace();} finally {// 7.关闭资源JDBCUtils.closeResource(null, ps, rs);}return null;}// 通用的增删改 （version 2.0:考虑到事务）public void update(Connection conn, String sql, Object... args) {PreparedStatement ps = null;try {// 1.ps = conn.prepareStatement(sql);// 2.填充占位符for (int i = 0; i < args.length; i++) {ps.setObject(i + 1, args[i]);}// 3.执行int count = ps.executeUpdate();System.out.println("影响了" + count + "条数据");} catch (Exception e) {e.printStackTrace();} finally {// 4.连接一定不要关闭！JDBCUtils.closeResource(null, ps, null);}}
}

另外两个CustomerDAO和CustomerDAOTest类代码不变

这篇关于JavaWeb之JDBC（2.2）：数据库事务、数据库连接池、DBUtils、DAO及其子类代码演示的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/839747。

相关文章

Spring boot整合dubbo+zookeeper的详细过程

Spring boot整合dubbo+zookeeper的详细过程

《Springboot整合dubbo+zookeeper的详细过程》本文讲解SpringBoot整合Dubbo与Zookeeper实现API、Provider、Consumer模式,包含依赖配置、... 目录Spring boot整合dubbo+zookeeper1.创建父工程2.父工程引入依赖3.创建ap
阅读更多...
SQL server数据库如何下载和安装

SQL server数据库如何下载和安装

《SQLserver数据库如何下载和安装》本文指导如何下载安装SQLServer2022评估版及SSMS工具,涵盖安装配置、连接字符串设置、C#连接数据库方法和安全注意事项,如混合验证、参数化查... 目录第一步：打开官网下载对应文件第二步：程序安装配置第三部：安装工具SQL Server Manageme
阅读更多...
C#连接SQL server数据库命令的基本步骤

C#连接SQL server数据库命令的基本步骤

《C#连接SQLserver数据库命令的基本步骤》文章讲解了连接SQLServer数据库的步骤,包括引入命名空间、构建连接字符串、使用SqlConnection和SqlCommand执行SQL操作,... 目录建议配合使用：如何下载和安装SQL server数据库-CSDN博客1. 引入必要的命名空间2.
阅读更多...
SpringBoot结合Docker进行容器化处理指南

SpringBoot结合Docker进行容器化处理指南

《SpringBoot结合Docker进行容器化处理指南》在当今快速发展的软件工程领域,SpringBoot和Docker已经成为现代Java开发者的必备工具,本文将深入讲解如何将一个SpringBo... 目录前言一、为什么选择 Spring Bootjavascript + docker1. 快速部署与
阅读更多...
Spring Boot spring-boot-maven-plugin 参数配置详解(最新推荐)

Spring Boot spring-boot-maven-plugin 参数配置详解(最新推荐)

《SpringBootspring-boot-maven-plugin参数配置详解(最新推荐)》文章介绍了SpringBootMaven插件的5个核心目标（repackage、run、start... 目录一 spring-boot-maven-plugin 插件的5个Goals二 应用场景1 重新打包应用
阅读更多...
SpringBoot+EasyExcel实现自定义复杂样式导入导出

SpringBoot+EasyExcel实现自定义复杂样式导入导出

《SpringBoot+EasyExcel实现自定义复杂样式导入导出》这篇文章主要为大家详细介绍了SpringBoot如何结果EasyExcel实现自定义复杂样式导入导出功能,文中的示例代码讲解详细,... 目录安装处理自定义导出复杂场景1、列不固定，动态列2、动态下拉3、自定义锁定行/列，添加密码4、合并
阅读更多...
Spring Boot集成Druid实现数据源管理与监控的详细步骤

Spring Boot集成Druid实现数据源管理与监控的详细步骤

《SpringBoot集成Druid实现数据源管理与监控的详细步骤》本文介绍如何在SpringBoot项目中集成Druid数据库连接池,包括环境搭建、Maven依赖配置、SpringBoot配置文件... 目录1. 引言1.1 环境准备1.2 Druid介绍2. 配置Druid连接池3. 查看Druid监控
阅读更多...
Java中读取YAML文件配置信息常见问题及解决方法

Java中读取YAML文件配置信息常见问题及解决方法

《Java中读取YAML文件配置信息常见问题及解决方法》：本文主要介绍Java中读取YAML文件配置信息常见问题及解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要... 目录1 使用Spring Boot的@ConfigurationProperties2. 使用@Valu
阅读更多...
创建Java keystore文件的完整指南及详细步骤

创建Java keystore文件的完整指南及详细步骤

《创建Javakeystore文件的完整指南及详细步骤》本文详解Java中keystore的创建与配置,涵盖私钥管理、自签名与CA证书生成、SSL/TLS应用,强调安全存储及验证机制,确保通信加密和... 目录1. 秘密键（私钥）的理解与管理私钥的定义与重要性私钥的管理策略私钥的生成与存储2. 证书的创建与
阅读更多...
浅析Spring如何控制Bean的加载顺序

浅析Spring如何控制Bean的加载顺序

《浅析Spring如何控制Bean的加载顺序》在大多数情况下,我们不需要手动控制Bean的加载顺序,因为Spring的IoC容器足够智能,但在某些特殊场景下,这种隐式的依赖关系可能不存在,下面我们就来... 目录核心原则：依赖驱动加载手动控制 Bean 加载顺序的方法方法 1：使用@DependsOn(最直
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2