封装 JDBCUtils和事务-天翼云

封装 JDBCUtils和事务

2023-06-13 08:32:34 阅读次数：450

1. JDBC 的相关 API 小结 832

封装 JDBCUtils和事务

2. 封装 JDBCUtils 【关闭连接, 得到连接】 833

2.1 说明

在jdbc操作中，获取连接和释放资源是经常使用到可以将其封装JDBC连接的具类JDBCUtils

2.2 代码实现

实际使用使用工具类 JDBCUtils

代码在com.stulzl.utils.

JDBCUtils 833

package com.stulzl.utils;

import java.io.FileInputStream;
import java.io.IOException;
import java.sql.*;
import java.util.Properties;

//这是一个工具类，完成 mysql 的连接和关闭资源   833
public class JDBCUtils {
    //定义相关的属性(4 个), 因为只需要一份，因此，我们做出 static
    private static String user; //用户名
    private static String password; //密码
    private static String url; //url
    private static String driver; //驱动名

    //再static代码块中去初始化
    static{
        try {
            Properties properties = new Properties();
            properties.load(new FileInputStream("src\\mysql.properties"));
            //读取相关的属性数据
            user = properties.getProperty("user");
            password = properties.getProperty("password");
            url = properties.getProperty("url");
            driver = properties.getProperty("driver");
        } catch (IOException e) {
            //在实际开发中，我们可以这样处理
            //1. 将编译异常转成 运行异常
            //2. 调用者，可以选择捕获该异常，也可以选择默认处理该异常，比较方便.
            throw new RuntimeException(e);
        }
    }

    //连接数据库，返回Connection
    public static Connection getConnection(){
        try {
            return DriverManager.getConnection(url,user,password);
        } catch (SQLException e) {
            //1. 将编译异常转成 运行异常
            //2. 调用者，可以选择捕获该异常，也可以选择默认处理该异常，比较方便.
            throw new RuntimeException(e);
        }
    }

    //关闭相关资源
    //分析可能要关闭的资源
    /*
        1. ResultSet 结果集
        2. Statement 或者 PreparedStatement
        3. Connection
        4. 如果需要关闭资源，就传入对象，否则传入 null
    */
    public static void close(ResultSet set, Statement statement,Connection connection){
        try {
            //判断是否为null
            if(set!=null){
                set.close();
            }
            if(statement!=null){
                statement.close();
            }
            if(connection!=null){
                connection.close();
            }
        } catch (SQLException e) {
            //1. 将编译异常转成 运行异常
            //2. 调用者，可以选择捕获该异常，也可以选择默认处理该异常，比较方便.
            throw new RuntimeException(e);
        }
    }

}

测试类JDBCUtils_Use 834

package com.stulzl.utils;

import org.junit.jupiter.api.Test;

import javax.annotation.processing.SupportedAnnotationTypes;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

//该类演示如何使用JDBCUtils工具类，完成dml和select  834
public class JDBCUtils_Use {
    public static void main(String[] args) {

    }
    @Test
    public void testDML(){
        //1.得到连接
        Connection connection = null;
        //2.组织一个sql语句
        String sql = "update actor set name=? where id = ?";
        PreparedStatement preparedStatement=null;
        try {
            connection = JDBCUtils.getConnection();
            //3.创建preparedStatement对象
            preparedStatement = connection.prepareStatement(sql);

            //4. 给占位符赋值
            preparedStatement.setString(1,"周星驰");
            preparedStatement.setInt(2,2);

            //执行
            preparedStatement.executeUpdate();

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //关闭资源
            JDBCUtils.close(null,preparedStatement,connection);
        }
    }
}

配置文件再src下面 mysql.properties

user=root
password=lzl
url=jdbc:mysql://localhost:3306/hsp_db02
driver=com.mysql.jdbc.Driver

2.2.1 JDBCUtils的select使用 835

testSelect()方法

//JDBCUtils的select使用  835
    @Test
    public void testSelect(){
        //1.得到连接
        Connection connection = null;
        //2.组织一个sql语句
        String sql = "select * from actor where id=?";
        PreparedStatement preparedStatement=null;
        ResultSet set = null;
        try {
            connection = JDBCUtils.getConnection();
            //3.创建preparedStatement对象
            preparedStatement = connection.prepareStatement(sql);

            //4. 给占位符赋值
            preparedStatement.setInt(1,2);

            //执行,得到结果集
            set = preparedStatement.executeQuery();

            //遍历该结果集
            while(set.next()){
                int id = set.getInt("id");//这里提示("id")可以直接写，也可以写数字(按对应顺序)
                String name = set.getString("name");
                String sex = set.getString("sex");
                Date borndate = set.getDate("borndate");
                String phone = set.getString("phone");
                System.out.println(id + "\t" + name + "\t" + sex
                        + "\t" + borndate + "\t" + phone);
            }

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //关闭资源
            JDBCUtils.close(set,preparedStatement,connection);
        }
    }
}

3. 事务 836

3.1 基本介绍 836

1. JDBC程序中当一个Connection对象创建时，默认情况下是自动提交事务:每次执行一个SQL语句时，如果执行成功，就会向数据库自动提交，而不能回滚。

2. JDBC程序中为了让多个 SQL语句作为一个整体执行，需要使用事务

3.调用Connection的setAutoCommit(false)可以取消自动提交事务

4.在所有的SQL语询都成功执行后，调用Connection的commit();方法提交事务

5.在其中某个操作失败或出现异常时，调用Connection的rollback();方法回滚事务

3.2 应用实例 837

模拟经典的转账业务

封装 JDBCUtils和事务

3.3 不使用事务可能出现的问题模拟-模拟经典的转账业务 837

3.4 使用事务解决上述问题-模拟经典的转账业务 837

3.3和3.4代码在 com.stulzl.transaction_

Transaction_

package com.stulzl.transaction_;

import com.stulzl.utils.JDBCUtils;
import org.junit.jupiter.api.Test;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

//演示JDBC中如何使用事务   837
public class Transaction_ {

    //不使用事务
    @Test
    public void noTransaction(){
        //1.得到连接
        Connection connection = null;
        //2.组织一个sql语句
        String sql = "update account1 set balance=balance-100 where id = 1";
        String sql2 = "update account1 set balance=balance+100 where id = 2";
        PreparedStatement preparedStatement=null;
        try {
            connection = JDBCUtils.getConnection();// 在默认情况下，connection 是默认自动提交
            //3.创建preparedStatement对象
            //这里就是给马云扣100
            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.executeUpdate();//执行第一条sql

            //这里抛出异常,我们的目的是为了让马云转账出去，但是马化腾接收不到(因为执行遇到异常后
            // 面的代码将不再运行) 让我们更加直观的感受接下来事务操作
            int i = 1/0;

            //这里就是给马化腾加100
            preparedStatement = connection.prepareStatement(sql2);
            preparedStatement.executeUpdate();//执行第二条sql2

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //关闭资源
            JDBCUtils.close(null,preparedStatement,connection);
        }
    }


    //使用事务来解决
    @Test
    public void useTransaction(){
        //1.得到连接
        Connection connection = null;
        //2.组织一个sql语句
        String sql = "update account1 set balance=balance-100 where id = 1";
        String sql2 = "update account1 set balance=balance+100 where id = 2";
        PreparedStatement preparedStatement=null;
        try {
            connection = JDBCUtils.getConnection();// 在默认情况下，connection 是默认自动提交
            //将connection设置为不自动提交
            connection.setAutoCommit(false);//相当于开启了事务
            //3.创建preparedStatement对象
            //这里就是给马云扣100
            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.executeUpdate();//执行第一条sql

            //int i = 1/0;//这里抛出异常

            //这里就是给马化腾加100
            preparedStatement = connection.prepareStatement(sql2);
            preparedStatement.executeUpdate();//执行第二条sql2

            //这里提交事务
            connection.commit();

        } catch (SQLException e) {
            //这里我们可以进行回滚，即撤销执行的 SQL
            //默认回滚到事务开始的状态
            System.out.println("执行发生了异常，撤销执行的 sql");
            try {
                connection.rollback();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            //关闭资源
            JDBCUtils.close(null,preparedStatement,connection);
        }
    }
}

代码在E:\java学习\初级\course170\db_

java_transaction

-- 创建表   837
CREATE TABLE account1(
	id INT PRIMARY KEY AUTO_INCREMENT,
	NAME VARCHAR(32) NOT NULL DEFAULT'',
	balance DOUBLE NOT NULL DEFAULT 0) CHARACTER SET utf8;
-- 添加数据
INSERT INTO account1 VALUES(NULL, '马云',3000);

INSERT INTO account1 VALUES(NULL, '马化腾',10000);

SELECT * FROM account1

活动

智算服务

应用商城

合作伙伴

开发者

支持与服务

了解天翼云

封装 JDBCUtils和事务

封装 JDBCUtils和事务

1. JDBC 的相关 API 小结 832

2. 封装 JDBCUtils 【关闭连接, 得到连接】 833

2.1 说明

2.2 代码实现

代码在com.stulzl.utils.

JDBCUtils 833

测试类JDBCUtils_Use 834

配置文件再src下面 mysql.properties

2.2.1 JDBCUtils的select使用 835

testSelect()方法

3. 事务 836

3.1 基本介绍 836

3.2 应用实例 837

3.3 不使用事务可能出现的问题模拟-模拟经典的转账业务 837

3.4 使用事务解决上述问题-模拟经典的转账业务 837

3.3和3.4代码在 com.stulzl.transaction_

Transaction_

代码在E:\java学习\初级\course170\db_

java_transaction

相关文章

【Mybatis】-动态SQL

SQL Server 事务日志体系结构1--基本术语

oracle 10.2.0.4安装ogg执行ddl_setup.sql时，报警“ORA-20783：RECYCLEBIN must be turned off”

sql*plus中文乱码

查找正在执行的select以及dml语句的相关信息

JDBC事务管理、四大特征（ACID）、事务提交与回滚、MySQL事务管理

springboot系列教程（十二）：基于转账案例,演示事务管理操作

Spring多线程事务 能否保证事务的一致性（同时提交、同时回滚）？

61. Spring事务传播行为实现原理

【Redis】浅析 Redis 事务

作者介绍

最新文章

【Mybatis】-动态SQL

sql*plus中文乱码

thinkphp3.2 多表事务的实例

什么是Redis事务？原理是什么？

第四天：Redis事务和Lua脚本

MGR相关的几张表

热门文章

Apache-DBUtils

MyBatis-Plus 批量插入

ES7-SQL操作

单表的CRUD操作改造

第十八章《JDBC》第3节：事务处理

SQL SERVER 2005 DBCC IND命令说明

热门标签

相关产品

弹性云主机

天翼云电脑（公众版）

对象存储

云硬盘

随机文章

Mybatis工具SqlHelper - 获取Mybatis方法的Sql

thinkphp3.2 多表事务的实例

[spring学习]12、JdbcTemplate常见增删改查操作

[spring学习]13、声明式事务(@Transaction)

dremio create table 几个特殊的能力

Cause: java.sql.SQLException: Access denied for user 'root1'@'localhost' (using password: YES)

Spring多线程事务能否保证事务的一致性（同时提交、同时回滚）？