JDBC与MySQL事务基础

1.事务的引入

2.db.properties 配置文件

3.ThreadLocal 使用

1.1 环境搭建: jdbc连接工具 account(id,name,money)数据库
1.2 DBUtils 工具类
db.properties(放src 下)
1.3 AccountDao AccountService
1.4 AccountDemo

一.db.properties

# 配置驱动名称,可不配置,会自动读取
# 如果配置的话，mysql8.0+，com.mysql.cj.jdbc.Driver
# mysql8.0 之前，com.mysql.jdbc.Driver
driverClassName = com.mysql.jdbc.Driver
# url
url=jdbc:mysql:///day09db?serverTimezone=Asia/Shanghai
#
username=root
password=root
#连接池中初始化的连接数
initialSize=100
#最大连接数
maxActive=200
#最小空闲数
minIdle=10
#最大等待时间
maxWait=60000

二.DBUtils

public class DBUtils {
private static DataSource ds = null;
//properties 配置文件配置 DataSource
private static final Properties PROPERTIES = new Properties();
/**
* @description: ThreadLocal 特点: 在哪个线程中存储的数据,就在哪个线程中读取,其他线程读取不到
*
ThreadLocal 中只能保存一个对象
*
方法: set() :存一个对象到 ThreadLocal 中
*
get(): 读取一个对象
*
remove(): 移除对象
* @date 2022/3/29
* @return
*/
private static final ThreadLocal<Connection> THREAD_LOCAL = new ThreadLocal<>();
static {
try {
// 加载 db.properties 配置文件,将数据读取到 properties 对象中
//注意，读取文件时，不能省略 /，/ 表示去 classpath 的根目录下查找，classpath 就是 src
//这个操作，类似于手动向 properties 中 put 了 7 条数据，put 完成后，可以通过如下方式读取 properties.get("password")
//把数据存入 properties 中，将来如果要修改，可以只改配置文件即可，不用重新编译 java 代码
PROPERTIES.load(DBUtils.class.getResourceAsStream("/db.properties"));
//根据 properties 文件,创建一个 DataSource 数据源
ds = DruidDataSourceFactory.createDataSource(PROPERTIES);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
*
同一个线程中,拿到的始终是同一个 Connection
*
*/
public static Connection getConnection(){
/**
*
首先从 ThreadLocal 中获取一个 Connection:
*
拿到说明 已经有方法来 获取过 Connection
*
拿到 null 说明 在当前线程中是第一次来拿 Connection
*/
Connection connection = THREAD_LOCAL.get();
if (connection == null) {
//拿到 null 说明 在当前线程中是第一次来拿 Connection
Connection con = null;
try {
// 从线程池中拿一个 Connection,存入 ThreadLocal,并返回
con = ds.getConnection();
THREAD_LOCAL.set(con);
return con;
} catch (SQLException e) {
e.printStackTrace();
}
}
// 有 直接返回 connection,确保同一个线程中拿到的是同一个
return connection;
}
//无ThreadLocal 连接
//
private static final Properties PROPERTIES = new Properties();
//
static {
//
try {
//
PROPERTIES.load(DBUtils.class.getResourceAsStream("/db.properties"));
//
ds = DruidDataSourceFactory.createDataSource(PROPERTIES);
//
} catch (Exception e) {
//
e.printStackTrace();
//
}
//
}
//
public static Connection getConnection(){
//
try {
//
return ds.getConnection();
//
} catch (SQLException e) {
//
e.printStackTrace();
//
}
//
return null;
//
}
public static void close(Connection con){
if (con!=null){
try {
con.close();
/**
*
当将连接放回连接池时,需要从 ThreadLocal 中移除该连接,则，由于 threadlocal 只有当前线程能够操作它，当前请求结束的时候，当前线程的使命就完成了，下个请求来又是一个新线程，此时就没人能够将这个 threadlocal 中的数据移除了
*
*/
THREAD_LOCAL.remove();
} catch (SQLException e) {
e.printStackTrace();
}
}
}public static void close(PreparedStatement ps){
if (ps!=null){
try {
ps.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}public static void close(ResultSet rs){
if (rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}

三.AccountDao

public class AccountDao {
/**
* dao 层的异常不要自己捕获,有异常直接抛出给 service 层,这样方便 service 层去处理事务
*
*/
public Integer addMoney(String name, Double money) throws SQLException {
Connection con = null;
PreparedStatement ps = null;
con = DBUtils.getConnection();
ps = con.prepareStatement("update account set money =money+? where name = ?");
ps.setDouble(1, money);
ps.setString(2, name);
int i = ps.executeUpdate();
DBUtils.close(ps);
return i;
}
public Integer minMoney(String name,Double money) throws SQLException {
Connection con = null;
PreparedStatement ps = null;
con = DBUtils.getConnection();
ps = con.prepareStatement("update account set money=money-? where name = ?");
ps.setDouble(1, money);
ps.setString(2, name);
int i = ps.executeUpdate();
DBUtils.close(ps);
return i;
}
}

四.AccountService

public class AccountService {
AccountDao accountDao = new AccountDao();
/**
*
JDBC 中,默认是有事务的,事务会自动提交或回滚
*
所以 在 JDBC 中,所谓的开启事务,其实就是关闭 JDBC 默认的事务
*/
public void transferMoney(String from,String to,Double money){
Connection con = DBUtils.getConnection();
try {
/**
*
由于事务是在
Connection 上开启的,所以需要确保当前事务中的所有 JDBC 连接都是同一个 Connection,
*
只有是同一个 Connection ,才能确保所有的数据库操作同事提交或同时回滚
*/
con.setAutoCommit(false);
accountDao.addMoney(from, money );
int i = 1 / 0;
accountDao.minMoney(to, money);
con.commit();
} catch (SQLException e) {
e.printStackTrace();
try {
con.rollback();
} catch (SQLException ex) {
ex.printStackTrace();
}
}finally {
DBUtils.close(con);
}
}
}

五. main

public static void main(String[] args) {
AccountService accountService = new AccountService();
accountService.transferMoney("lisi", "zhangsan", 100.0);
}

最后

以上就是飘逸龙猫为你收集整理的JDBC与MySQL事务基础的全部内容，希望文章能够帮你解决JDBC与MySQL事务基础所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。