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.mzph.cn/bicheng/7637.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

2024.1.1 IntelliJ IDEA 使用记录

2024.1.1 IntelliJ IDEA 使用记录

2024.1.1 IntelliJ IDEA 使用记录 下载设置文件编码maven 配置 插件可以中文语言包安装lombok 插件Smart Tomcat ( 根据需要安装)Smart Tomcat 配置 项目导入java 设置maven 配置 项目运行SpringBoot 项目运行tomcat 运行 (根据需要)相关依赖添加运行配置 下载 IntelliJ IDEA …
阅读更多...
0基础学PHP有多难？

0基础学PHP有多难？

php作为web端最佳的开发语言，没有华而不实，而是经受住了时间考验，是一门非常值得学习的编程语言。 目前市场上各种网站、管理系统、小程序、APP等，基本都是使用PHP开发的，也侧面反映了PHP的需求以及学习的必要性&…
阅读更多...
【Python小练】随机验证码

【Python小练】随机验证码

题目 提示输出含数字、字母的四位随机数，输入提示的验证码进行验证，验证码正确结束程序，验证码错误继续输入。 分析 我们可以通过random模块生成0到9的随机数，也可以通过生成65到90的随机数，将65到90的随机ASCLL码转换…
阅读更多...
从浏览器输入url到页面加载（十）接收到网卡数据的处理

从浏览器输入url到页面加载（十）接收到网卡数据的处理

上一节我们说到数据经过漫长的旅程，从客户端，到达了服务端。然后服务端的等待连接程序被开启，与客户端建立了连接，这一节我们继续说。 目录 1 接收到的数据是什么样的？ 2 网卡驱动被激活 3 达到协议栈
阅读更多...
Nginx+uwsgi+Django实现本地服务器部署发布

Nginx+uwsgi+Django实现本地服务器部署发布

目录 安装相关软件包安装python3.9Nginx安装 环境准备部署uwsgiWSGI是什么？步骤 遇到的问题 安装相关软件包 安装python3.9 安装依赖包 yum install libffi-devel -y yum install zlib-devel bzip2-devel openssl-devel ncurses-devel sqlite-devel readline-dev…
阅读更多...
前端传递list（数组）类型参数，后端接收失败

前端传递list（数组）类型参数，后端接收失败

一顿报错,我之前遇到的list都是Long类型 貌似用GET也是可以的,但是很奇怪一直报错 就是不可以 后来去百度 查询到可以用两种方法解决这个问题 1、拆开 传 以GET方式，后端GetMappingRequestParam接收。 2、以Post方式传，后端创建dto PostMappingReques…
阅读更多...
React 之 Effect与事件（event）（八）

React 之 Effect与事件（event）（八）

Effect（useEffect Hook） 在React中，Effect（或者更具体地说，useEffect Hook）是一个特殊的函数，它允许你在函数组件中执行副作用操作。这些副作用操作可能包括数据获取、手动更改DOM、订阅或取消订…
阅读更多...
Open AI API 参数解释

Open AI API 参数解释

在使用 OpenAI 的 API 发送请求时，temperature、top_p 和 stream 这几个参数具有特定的含义和作用： temperature： 用途：这个参数用于控制模型输出的随机性或多样性。temperature 的值可以从 0 到 1 范围内调整。行为：当…
阅读更多...
55. 【Android教程】位图：Bitmap

55. 【Android教程】位图：Bitmap

在上一节学习 Drawable 图像资源的时候我们在很多地方用到了 bitmap，bitmap 其实就是真实图片在 Android 中最直接的表现形式，这一节我们来仔细学习一下 Bitmap 的使用。 1. 什么是 Bitmap Bitmap 在 Android 中对应一张图片文件，它是一个二…
阅读更多...
普通人可以做什么兼职副业？推荐7 种卖情怀的生意，小众高利润

普通人可以做什么兼职副业？推荐7 种卖情怀的生意，小众高利润

一瓶茅台，尽管成本仅为70元，但其建议零售价却高达1499元，而在市场上的流通价格更是突破了2600元大关。同样的一款手提包，在网络上仅售几百元，但一旦贴上了LV的标志，其售价便瞬间飙升至一万多元。这究竟是为…
阅读更多...
【超好用的前端表单辅助功能】

【超好用的前端表单辅助功能】

前端表单辅助功能 1. 根据模块自动生成目录锚点定位2. 描点定位动态组件3. 隔离组件，组件内部实现校验逻辑，交给提交按钮统一处理4. 选择不同的类型需要重组不同的模块展示，并整合数据传给后端 最近做了一个复杂的表单，涉及到的技…
阅读更多...
AI实景自动无人直播软件：引领直播行业智能化革命；提升直播效果，无人直播软件助力智能讲解

AI实景自动无人直播软件：引领直播行业智能化革命；提升直播效果，无人直播软件助力智能讲解

随着科技的快速发展，AI实景自动无人直播软件正在引领直播行业迈向智能化革命。它通过智能讲解、一键开播和智能回复等功能，为商家提供了更高效、便捷的直播体验。此外，软件还支持手机拍摄真实场景或搭建虚拟场景，使直播画面更好看…
阅读更多...
43.WEB渗透测试-信息收集-域名、指纹收集（5）

43.WEB渗透测试-信息收集-域名、指纹收集（5）

免责声明：内容仅供学习参考，请合法利用知识，禁止进行违法犯罪活动！ 内容参考于： 易锦网校会员专享课 上一个内容：42.WEB渗透测试-信息收集-域名、指纹收集（4） web-架构资产收集&a…
阅读更多...
蓝桥杯备赛（填空题）【Python B组】

蓝桥杯备赛（填空题）【Python B组】

一、弹珠堆放 问题描述 小蓝有 20230610 颗磁力弹珠，他对金字塔形状尤其感兴趣，如下图所示： （图是盗来的啊，侵权请联系删除） 问题分析 找规律，第一层1个，第二层3个，第…
阅读更多...
UE5 audio capture 回声问题 ||在安卓上有爆鸣声

UE5 audio capture 回声问题 ||在安卓上有爆鸣声

参考视频 0.基本步骤 【UE4_蓝图】录制麦克风声音/系统声音并输出保存WAV文件_ue4录音-CSDN博客 1.步骤 1.创建Sound Submix A 2. 右键新建Sound Submix B 3.把B的两个参数调为-96 4.audio capture的Base Submix，把前面提到的A赋值进去 5.开始录制输出和完成录制…
阅读更多...
PXE远程部署CentOS系统

PXE远程部署CentOS系统

文章目录 在局域网内搭建PXE服务器PXE 启动组件PXE的优点实验一、搭建PXE服务器，实现远程部署CentOS系统环境准备server关闭防火墙安装组件准备 Linux 内核、初始化镜像文件及PXE引导文件配置启用TFTP 服务配置启动DHCP服务准备CentOS 7 安装源配置启动菜单文件 Cli…
阅读更多...
突然断电，瀚高数据库启动失败

突然断电，瀚高数据库启动失败

服务器临时断电后，数据库启动不起来 ps -ef|grep postgres 进到数据库的data目录下看下ls 看下 查看临时文件： ls -la /tmp 把这两个5866的文件改个名字张老师 加个bak就行 改完了pg_ctl start起一下
阅读更多...
暗区突围联机不了联机失败无法联机的极速解决方法

暗区突围联机不了联机失败无法联机的极速解决方法

暗区突围联机不了/联机失败/无法联机的极速解决方法 《暗区突围》是由腾讯魔方工作室群开发的第一人称射击类手游，于2021年8月17日进行先锋测试，并在2022年7月13日正式公测。《暗区突围》提供了双模式玩法，包括战术行动和伪装潜入&#…
阅读更多...
猫咪没精神不吃饭？这招主食冻干喂养教你让猫咪恢复食欲

猫咪没精神不吃饭？这招主食冻干喂养教你让猫咪恢复食欲

猫突然不吃东西没精神是生病了吗？当猫咪不吃东西、精神不振时，可能的原因有健康问题、环境因素或食物原因。首先应进行身体检查，观察是否有其他并发症，如无则可排除健康问题。还要给猫咪提供一个舒适的环境，多给它们一…
阅读更多...
Cloudera简介和安装部署

Cloudera简介和安装部署

ChatGPT Cloudera 是一个基于 Apache Hadoop 的数据管理和分析平台。它是由 Hadoop 的几位创始人及早期贡献者于 2008 年创立的公司，并随着公司的不断发展，Cloudera 开始提供企业级的解决方案，帮助企业更好地利用 Hadoop 生态系统进行大数据…
阅读更多...
最新文章

Copyright @ 2022~2023