JDBC——事务相关

JDBC中的事务提交机制

JDbC 事务机制：

JDBC中的事务是自动提交的，即JDBC中DML语句执行一次，事务自动提交一次，

这是JDBC默认的事务行为，但是在实际的业务开发中，通常都是N条DML语句共同联合才能完成的，

必须保证这些DML语句在同一个事务中同时成功或者同时失败

import java.sql.Connection;
  import java.sql.DriverManager;
  import java.sql.PreparedStatement;
  import java.sql.SQLException;
  ​
  /**
   * JDbC 事务机制：
   * 1、JDBC中的事务是自动提交的，即JDBC中DML语句执行一次，事务自动提交一次
   * 这是JDBC默认的事务行为，但是在实际的业务开发中，通常都是N条DML语句共同联合才能完成的
   * 必须保证这些DML语句在同一个事务中同时成功或者同时失败
   * 2、以下程序会先验证JDBC的事务是否是自动提交机制
   *测试结果：JDBC中只要执行任意一条SQL语句，事务就自动提交一次
   *
   */
  ​
  public class Demo05 {
      public static void main(String[] args) {
          Connection conn = null;
          PreparedStatement ps =null;
          try {
              //1.注册驱动
              Class.forName("com.mysql.jdbc.Driver");
              //2.获取连接
              // conn = DriverManager.getConnection("jdbc:mysql//localhost:3306/bjpowernode","root","333");注意URL的书写格式
              conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/bjpowernode","root","333");
              conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/bjpowernode","root","333");
  ​
              //3.获取数据库预编译对象，写SQL语句
              String sql ="update dept set dname = ? where deptno = ?";
              //4.执行第一个SQL语句
              ps =conn.prepareStatement(sql);
  ​
              ps.setString(1,"X部门");
              ps.setInt(2,30);
              int count = ps.executeUpdate();
              System.out.println(count);
  ​
              //第二次执行SQL语句
              ps.setString(1,"Y部门");
              ps.setInt(2,60);
              count = ps.executeUpdate();
              System.out.println(count);
  ​
              //5.遍历查询结果集
  ​
          } catch (Exception e) {
              e.printStackTrace();
          }finally {
              if (ps !=null){
                  try {
                      ps.close();
                  } catch (SQLException e) {
                      e.printStackTrace();
                  }
              }
          }if(conn !=null){
              try {
                  conn.close();
              } catch (SQLException e) {
                  e.printStackTrace();
              }
          }
  ​
  ​
      }
  }

JDBC 完成银行转账业务

  
  import java.sql.Connection;
  import java.sql.DriverManager;
  import java.sql.PreparedStatement;
  import java.sql.SQLException;
  ​
  /**
   *sql脚本
   * drop table if exists t_cat;
   * create table t_act(
   * actno int,
   * balance double(7,2)//注意7表示有效数字的个数，2表示小数位的个数。
   * )；
   * insert into t_act(actno,balance) values (111,20000);
   * insert into t_act(actno,balance) values (222,0);
   * commit;
   * selece *from t_act;
   *
   *
   * 
   */
  public class Demo06 {
         public static void main(String[] args) {
             Connection conn = null;
             PreparedStatement ps =null;
             try {
                 //1.注册驱动
                 Class.forName("com.mysql.jdbc.Driver");
                 //2.获取连接
                 conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/bjpowernode","root","333");
  ​
                 //将自动提交机制修改为手动提交机制
                 conn.setAutoCommit(false);//开启事务
  ​
                 //3.获取数据库预编译对象，写SQL语句
                 //4.执行SQL语句
  ​
                 String sql ="update t_act  set balance = ? where actno = ?";
                 ps = conn.prepareStatement(sql);
  ​
                 //传值
                 ps.setDouble(1,10000);
                 ps.setInt(2,111);
                 int count = ps.executeUpdate();
  ​
                 /**手动生成异常
                  String s = null;
                  s.toString();
                   */
  ​
  ​
  ​
                 //第二次传值
                 ps.setDouble(1,10000);
                 ps.setInt(2,222);
                 count +=ps.executeUpdate();
  ​
                 System.out.println(count == 2 ? "转账成功":"转账失败");
                 //执行到此说明程序没出现异常，此时可以提交事务
                 conn.commit();//手动提交事务
  ​
                 //5.遍历查询结果集
  ​
             } catch (Exception e) {
                 //回滚事务
                 if (conn !=null ){
                     try {
                         conn.rollback();
                     } catch (SQLException ex) {
                         e.printStackTrace();
                     }
                 }
             }finally {
                 if (ps !=null){
                     try {
                         ps.close();
                     } catch (SQLException e) {
                         e.printStackTrace();
                     }
                 }
             }if(conn !=null){
                 try {
                     conn.close();
                 } catch (SQLException e) {
                     e.printStackTrace();
                 }
             }
  ​
      }
  }
  ​

JDBC 的工具类


  package utils;
  /*
  * JDBC 工具类
  * */
  ​
  import java.sql.*;
  ​
  public class DBUtil {
      /*
      * 工具类中的构造方法都是私有的。
      * 因为工具类中的方法都是静态的，不需要new对象，直接采用类名调用
      * */
      private DBUtil(){}
  ​
      static {
          try {
              Class.forName("com.mysql.jdbc.Driver");
          } catch (ClassNotFoundException e) {
              e.printStackTrace();
          }
      }
      /**
       * 获取数据库连接对象
       * @return连接对象
       * @throws SQLException
       */
      public static Connection getConnection() throws SQLException{
  ​
          return  DriverManager.getConnection("jdbc:mysql://localhost:3306/bjpowernode","root","333");
  ​
  ​
  ​
      }
  ​
      /**
       * 关闭资源
       * @param conn  数据库连接对象
       * @param ps    数据库操作对象
       * @param rs    结果集
       */
      public static void close(Connection conn, Statement ps, ResultSet rs){
          if (rs!= null){
              try {
                  rs.close();
              } catch (SQLException e) {
                  e.printStackTrace();
              }
          }
          if (ps!= null){
              try {
                  ps.close();
              } catch (SQLException e) {
                  e.printStackTrace();
              }
          }
          if (conn!= null){
              try {
                  conn.close();
              } catch (SQLException e) {
                  e.printStackTrace();
              }
          }
  ​
  ​
      }
  ​
  ​
       }
  
  ​

JDBC 完成模糊查询


  package DemoCode;
  ​
  /*
  *两个任务：
  * 第一、测试util工具类是否可用
  * 第二、JDBC进行模糊查询
  *
  * */
  ​
  import utils.DBUtil;
  ​
  import java.sql.Connection;
  import java.sql.PreparedStatement;
  import java.sql.ResultSet;
  import java.sql.SQLException;
  ​
  public class Demo07 {
      public static void main(String[] args) {
  ​
          Connection conn =null;
          PreparedStatement ps = null;
          ResultSet rs = null;
          try {
              conn = DBUtil.getConnection();
  ​
              //获取预编译的数据库操作对象
              //错误的写法
  //            String sql = "select ename from emp where ename like '_?%'";
  //            ps = conn.prepareStatement(sql);
  //            ps.setString(1,"A");
  ​
              String sql = "select ename from emp where ename like ?";
              ps = conn.prepareStatement(sql);
              ps.setString(1,"_A%");
  ​
              rs = ps.executeQuery();
              while (rs.next()){
                  System.out.println(rs.getString("ename"));
              }
          } catch (Exception e) {
              e.printStackTrace();
          }finally {
              DBUtil.close(conn,ps,rs);
          }
      }
  ​
  ​
  ​
  }
  
  ​

乐观锁与悲观锁简介

行级锁：select enamel，job,sal from emp where job='manager' for update;

其中加入的‘for update’称为行级锁，即其他语句在该事务结束之前无法对岗位为‘manager’这一行记录进行改动。又被称为悲观锁

悲观锁：事务必须排队执行。数据锁住了，不允许并发。

乐观锁：支持并发，事务也不需要排队，但是需要一个版本号。


  package DemoCode;
  /*
  Demo08、09进行演示乐观锁与悲观锁
  这个程序开启一个事务，这个事务专门进行查询，并且使用行级锁/悲观锁，锁住相关的记录
  * */
  ​
  import utils.DBUtil;
  ​
  import java.sql.Connection;
  import java.sql.PreparedStatement;
  import java.sql.ResultSet;
  import java.sql.SQLException;
  ​
  public class Demo08 {
      public static void main(String[] args)  {
          Connection conn = null;
          PreparedStatement ps =null;
          ResultSet rs = null;
  ​
          try {
              conn = DBUtil.getConnection();
              //开启事务
              conn.setAutoCommit(false);
  ​
              String sql = "select ename,job,sal from emp where job = ? for update";
              ps = conn.prepareStatement(sql);
              ps.setString(1,"MANAGER");
              rs = ps.executeQuery();
              while (rs.next()){
                  System.out.println(rs.getString("ename")+","+rs.getString("job")+","+rs.getInt("sal"));
              }
  ​
              //提交事务（事务结束）
              conn.commit();
  ​
          } catch (SQLException e) {
             if (conn != null){
                 try {
                     conn.rollback();//回滚事务（事务结束）
                 } catch (SQLException ex) {
                     e.printStackTrace();
                 }
             }
          }finally {
              DBUtil.close(conn,ps,rs);
          }
      }
  }
  
​
  
  package DemoCode;
  /*
  Demo08、09进行演示乐观锁与悲观锁
  这个程序开启一个事务，这个事务进行修改锁定的记录
  * */
  ​
  import utils.DBUtil;
  ​
  import java.awt.dnd.DnDConstants;
  import java.sql.Connection;
  import java.sql.PreparedStatement;
  import java.sql.SQLException;
  ​
  public class Demo09 {
      public static void main(String[] args) {
          Connection conn = null;
          PreparedStatement ps =null;
  ​
          try {
              conn = DBUtil.getConnection();
              conn.setAutoCommit(false);
  ​
              String sql = "update emp set sal =sal*1.1 where job = ?";
              ps = conn.prepareStatement(sql);
              ps.setString(1,"MANAGER");
              int count = ps.executeUpdate();
              System.out.println(count);
  ​
  ​
              conn.commit();
          } catch (SQLException e) {
              if (conn !=null){
                  try {
                      conn.rollback();
                  } catch (SQLException ex) {
                      e.printStackTrace();
                  }
              }
          }finally {
              DBUtil.close(conn,ps,null);
          }
  ​
      }
  }
  
  ​

JDBC到此可告一段落！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mfbz.cn/a/598651.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

AI编码时代到来？实现编程梦想的利器—Baidu Comate测评

AI编码时代到来？实现编程梦想的利器—Baidu Comate测评

文章目录 Comate智能编码是什么？Comate支持的环境 Comate应用安装实际操作对话式生成代码生成代码注释智能单测项目测试调优功能 总结 Comate智能编码是什么？ 在如今这个拥抱AI的时代，市面上已经产出了很多Ai代码助手，如果你还没…
阅读更多...
Java clone

Java clone

Java clone 原型模式用一个已经创建的实例作为原型，通过复制（clone）该原型对象来创建一个和原型对象相同的新对象。Java中对象克隆需要重写Object.clone()方法，并实现Cloneable接口。 浅克隆 浅克隆仅仅克隆本对象，…
阅读更多...
关于Oracle 23ai 你要知道的几件事情

关于Oracle 23ai 你要知道的几件事情

1.版本生命周期 23ai发布后的Oracle版本生命周期图，可以看到23ai是长期支持版本可以到2032年。 引申 Oracle版本分为两类 Innovation Release--创新版本，一般提供至少两年技术支持 Long Term Release --长期支持版本，一般提供5年premier和…
阅读更多...
MacOS快速安装FFmpeg，并使用FFmpeg转换视频

MacOS快速安装FFmpeg，并使用FFmpeg转换视频

前言：目前正在接入flv视频流，但是没有一个合适的flv视频流地址。网上提供的flv也都不是H264AAC（一种视频和音频编解码器组合），所以想通过fmpeg来将flv文件转换为H264AAC。 一、MacOS环境 博主的MacOS环境（…
阅读更多...
DAPP开发：揭秘DAPP软件开发的秘密

DAPP开发：揭秘DAPP软件开发的秘密

随着区块链技术的飞速发展，DAPP（去中心化应用）的开发逐渐成为了一个热门话题。在本文中，我们将探讨如何从零开始开发DAPP软件，并深入思考DAPP开发中的关键问题。 一、了解DAPP开发的基础知识 在开始开发DAPP之前&…
阅读更多...
大数据API技术分享：使用API接口采集淘宝数据（商品详情丨关键词搜索丨店铺所有商品）

大数据API技术分享：使用API接口采集淘宝数据（商品详情丨关键词搜索丨店铺所有商品）

使用API接口采集淘宝数据（商品详情、关键词搜索、店铺所有商品）是大数据领域常见的应用场景。以下是一些关于如何使用API接口进行这些操作的技术分享： 1. 获取API权限 首先，你需要在淘宝开放平台注册成为开发者，并创建…
阅读更多...
【最大公约数 并集查找 调和级数】1998. 数组的最大公因数排序

【最大公约数 并集查找 调和级数】1998. 数组的最大公因数排序

本文涉及知识点 最大公约数 并集查找 调和级数 LeetCode1998. 数组的最大公因数排序 给你一个整数数组 nums ，你可以在 nums 上执行下述操作 任意次 ： 如果 gcd(nums[i], nums[j]) > 1 ，交换 nums[i] 和 nums[j] 的位置。其中 gcd(nums…
阅读更多...
免备案香港主机会影响网站收录？

免备案香港主机会影响网站收录？

免备案香港主机会影响网站收录?前几天遇到一个做电子商务的朋友说到这个使用免备案香港主机的完整会不会影响网站的收录问题，这个问题也是站长关注较多的问题之一。小编查阅了百度官方规则说明，应该属于比较全面的。下面小编给大家介绍一下使用免备案香…
阅读更多...
OpenAI的搜索引擎要来了！

OpenAI的搜索引擎要来了！

最近的报道和业界泄露信息显示，OpenAI正秘密研发一款新的搜索引擎，可能叫SearchGPT或Sonic，目标是挑战Google的搜索霸权。预计这款搜索引擎可能在5月9日即将到来的活动中正式亮相。 SearchGPT的蛛丝马迹 尽管OpenAI对SearchGPT尚未表态&…
阅读更多...
语音识别技术初级应用

语音识别技术初级应用

⚠申明： 未经许可，禁止以任何形式转载，若要引用，请标注链接地址。 全文共计3077字，阅读大概需要3分钟 🌈更多学习内容， 欢迎👏关注👀【文末】我的个人微信公众号&#xf…
阅读更多...
纹理映射技术在AI去衣应用中的关键作用

纹理映射技术在AI去衣应用中的关键作用

引言： 随着人工智能技术的飞速发展，其在图像处理领域中的应用也日益广泛。AI去衣，作为一种颇具争议的技术应用，指的是利用深度学习算法自动移除或替换图片中的衣物。在这一过程中，纹理映射技术扮演了不可或缺的角色。本…
阅读更多...
《我的医养信息化之路》之三十二：中医馆

《我的医养信息化之路》之三十二：中医馆

今年五一节的气候有点冷，走到小区又湿又暗的、寂静的小道上，树上的雨水滴到头上，不免感到孤独而寒冷。还好路很短，很快就回到办公室，开了电灯和电脑，刚刚的冷意已经消失了，我开始审核今天中医馆…
阅读更多...
Go 语言基础之面向对象编程

Go 语言基础之面向对象编程

1、OOP 首先，Go 语言并不是面向对象的语言，只是可以通过一些方法来模拟面向对象。 1.1、封装 Go 语言是通过结构体（struct）来实现封装的。 1.2、继承 继承主要由下面这三种方式实现： 1.2.1、嵌套匿名字段 //Add…
阅读更多...
Pascal Content数据集

Pascal Content数据集

如果您想使用Pascal Context数据集，请安装Detail，然后运行以下命令将注释转换为正确的格式。 1.安装Detail 进入项目终端 #即 这是在我自己的项目下直接进行克隆操作： git clone https://github.com/zhanghang1989/detail-api.git $PASCAL…
阅读更多...
Enterprise Architect(EA) 时序图

Enterprise Architect(EA) 时序图

EA 中时序图中Fragment无法调整 这个地方显示的是锁的状态，单击变成下面的样子，就可以在时序图上调整了
阅读更多...
使用Flink SQL实时入湖Hudi/Hive

使用Flink SQL实时入湖Hudi/Hive

文章目录 1 Hudi 简介2 COW和MOR3 接入COW模式Hudi表4 使用Flink SQL查看新接表5 使用Hive查看新接表6 总结 1 Hudi 简介 Hudi是一个流式数据湖平台，使用Hudi可以直接打通数据库与数据仓库，连通大数据平台，支持对数据增删改查。Hudi还支持同…
阅读更多...
支持向量机：抽象难懂？看这里就明白了！

支持向量机：抽象难懂？看这里就明白了！

今天给大家分享的知识是关于支持向量机的内容，支持向量机算法是目前学习到的机器学习算法中最抽象、最难以理解的内容，不过支持向量机算法在实际使用过程中还是比较常见，无论是在医学研究还是经济研究中都能看到身影，所有&#xf…
阅读更多...
4.4网安学习第四阶段第四周回顾(个人学习记录使用)

4.4网安学习第四阶段第四周回顾(个人学习记录使用)

本周重点 ①Linux系统提权 ②Linux权限维持 ③Windows 提权 ④Windows权限维持 ⑤SSRF利用 ⑥内网环境 ⑦内网扫描 ⑧漏洞利用 ⑨内网代理 ⑩获取主机控制权其他方案 ⑩①vuln靶场 ⑩②CS代理与ICMP隧道 本周主要内容 ①Linux系统提权 系统提权是成功入侵系统之…
阅读更多...
[数据概念|方案实操]清华数据大讲堂1-海南数据基础设施建设思考与实践

[数据概念|方案实操]清华数据大讲堂1-海南数据基础设施建设思考与实践

“ 全国最大自贸区在数据要素市场改革中都做了什么？” 如鼹鼠哥上一篇文章所介绍，4月17日，在清华公管学院，由杭州数据局局长 徐青山 给大家做了题为《数据要素市场化配置改革杭州实践与思考》的报告，鼹鼠哥自己的一点感…
阅读更多...
暗区突围pc端资格发放了吗 暗区突围pc测试资格怎么获取

暗区突围pc端资格发放了吗 暗区突围pc测试资格怎么获取

暗区突围pc端资格发放了吗 暗区突围pc测试资格怎么获取 暗区突围是一款很火爆的第一人称射击网游，现在终于要上线PC端啦！小伙伴们是不是已经迫不及待想要体验电脑上的硬核射击快感了？暗区突围pc端资格已经陆续发放，想要参与PC端…
阅读更多...
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站