jdbc dao 工具类mysql_Java基于JDBC实现事务,银行转账及货物进出库功能示例
本文实例讲述了Java基于JDBC实现事务,银行转账及货物进出库功能。分享给大家供大家参考,具体如下:
1. 转账业务
转账必须执行2个sql语句(update更新)都成功的情况下,提交事务,如果有一个失败,则2个都回滚事务
2. 事务应该具有4个属性:原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。
① 原子性(atomicity)。一个事务是一个不可分割的工作单位,事务中包括的诸操作要么都做,要么都不做。
②一致性(consistency)。事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。
③隔离性(isolation)。一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的,并发执行的各个事务之间不能互相干扰。
④持久性(durability)。持久性也称永久性(permanence),指一个事务一旦提交,它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。
3. 这里以转账操作为案例进行演示说明,其注意点如下:
(1)一个sql语句操作不需要手动提交事务
(2)查询操作也不需要手动提交事务,
(3)但是更新,插入,删除都需要手动提交事务
(4)余额为负的可以先查询出结果再进行判断,然后再操作
(5)con.setAutoCommit(false);手动开启事务;con.commit();手动提交事务;con.rollback();事务回滚操作
4. 首先创建一个数据表或者两个数据表,这里为了演示清楚创建两个数据表
5. 创建好数据库和数据表,然后进行工具类的书写BaseDao.java
package com.bie.utils;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
/**
* @author BieHongLi
* @version 创建时间:2017年2月27日 上午10:09:00
* 连接数据库的工具类
*/
public class BaseDao {
private static String driver="com.mysql.jdbc.Driver";
private static String url="jdbc:mysql:///test";
private static String user="root";
private static String password="123456";
/***
* 连接数据库的方法
* @return
* @throws ClassNotFoundException
* @throws SQLException
*/
public static Connection getCon() throws ClassNotFoundException, SQLException{
Class.forName(driver);//加载数据库驱动
System.out.println("测试加载数据库成功");
Connection con=DriverManager.getConnection(url, user, password);
System.out.println("测试数据库链接成功");
return con;
}
/***
* 关闭数据库的方法
* @param con
* @param ps
* @param rs
*/
public static void close(Connection con,PreparedStatement ps,ResultSet rs){
if(rs!=null){//关闭资源,避免出现异常
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(ps!=null){
try {
ps.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(con!=null){
try {
con.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
/***
* 同意增删改的方法
* @param sql
* @param arr
* @return
*/
public static boolean addUpdateDelete(String sql,Object[] arr){
Connection con=null;
PreparedStatement ps=null;
try {
con=BaseDao.getCon();//第一步 :连接数据库的操作
ps=con.prepareStatement(sql);//第二步:预编译
//第三步:设置值
if(arr!=null && arr.length!=0){
for(int i=0;i
ps.setObject(i+1, arr[i]);
}
}
int count=ps.executeUpdate();//第四步:执行sql语句
if(count>0){
return true;
}else{
return false;
}
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return false;
}
/*public static void main(String[] args) {
try {
BaseDao.getCon();
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}*/
}
6. 这里直接在主方法里面进行了测试,所以写了UserDao进行测试,看效果即可。
package com.bie.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import com.bie.utils.BaseDao;
/**
* @author BieHongLi
* @version 创建时间:2017年2月27日 下午3:19:49
*
*/
public class UserDao {
/***
* 注意点:
* (1)一个sql语句操作不需要手动提交事务
* (2)查询操作也不需要手动提交事务,
* (3)但是更新,插入,删除都需要手动提交事务
* (4)余额为负的可以先查询出结果再进行判断,然后再操作
* @param args
*/
public static void main(String[] args) {
Connection con=null;
PreparedStatement ps1=null;
PreparedStatement ps2=null;
try {
//第一步:连接数据库的操作
con=BaseDao.getCon();
//默认自动提交事务,所以默认是true,现在将true改为false,禁止默认自动提交事务
//con.setAutoCommit(true);
//事务1:如果设置为false,则需要手动提交事务
con.setAutoCommit(false);
//第二步:更新的sql语句
String sql="update bank_a set usera_rmb=usera_rmb-500 where usera_id=1 ";
String sql2="update bank_b set userb_rmb=userb_rmb+500 where userb_id=1 ";
//第三步:预编译sql
ps1=con.prepareStatement(sql);
//第四步:执行sql语句,虽然执行了sql,但是还没持久化更新到数据库
ps1.executeUpdate();
//第三步:预编译sql2
ps2=con.prepareStatement(sql2);
//第四步:执行sql2,虽然执行了sql2,但是还没持久化更新到数据库
ps2.executeUpdate();
System.out.println("转账成功...");
//事务2:手动提交事务,如果两个都执行成功了,那么提交事务
con.commit();
} catch (ClassNotFoundException e) {
e.printStackTrace();
try {
//事务3:如果抛出异常,那么回滚事务
con.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
} catch (SQLException e) {
e.printStackTrace();
}finally {
//关闭资源,避免出现异常
BaseDao.close(con, ps1, null);
BaseDao.close(null, ps2, null);
}
}
}
演示效果如下所示:
希望本文所述对大家java程序设计有所帮助。
jdbc dao 工具类mysql_Java基于JDBC实现事务,银行转账及货物进出库功能示例相关推荐
- JDBC工具类,基于C3P0的数据库连接池,提供获取连接池、获取连接对象、释放资源和封装事务操作的方法...
/** * * JDBC工具类,基于C3P0数据库连接池的实现 * * @author 周瑜 * @2018年5月7日 下午2:13:20 */ public final class JD ...
- 原生JDBC和工具类的基本实现
工具: IDEA MySQL8.0或之前版本 文章目录 JDBC原理 JDBC入门案例 JDBC的API详解 JDBC增删改查操作 JDBC工具类 JDBC是Java访问数据库的标准规范,可以为不同的 ...
- java回顾:JDBC、工具类、事务、SQL注入
目录 1.概念 2.JDBC核心API的介绍 2.1 JDBC四个核心对象 2.2 JDBC访问数据库的步骤 3.JDBC注册驱动 3.1 jdbc测试 3.2 注册驱动 4.获取连接 4.1 AP ...
- java jdbc 工具_实现JDBC的工具类
package mysql; /* * 实现JDBC的工具类 * 定义方法,直接返回数据库的连接对象 */ import java.sql.Connection; import java.sql.Dr ...
- 数据库MySQL基础---JDBC开发步骤--JDBC封装工具类--PreparedStatement实现CRUD操作
JDBC简介 1.JDBC定义Java数据库连接(Java Database Connectivity,简称JDBC):是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口,提供了诸如查询 ...
- 2021开年巨作!JDBC连接数据库工具类!
JDBC连接数据库工具类! 去年十一月二十号更新完之后就一直没有更新,因为被派出差天天九九六的日子让我毫无心思在上面写博客. 唉,马上就要过年了,小伙伴们是不是还在熬夜加班加点赶项目呢?同是天涯沦落人 ...
- JDBC基础工具类的实现
文章目录 JDBC的工具类简单实现 一般实现步骤 基本代码 各种操作及运行结果 查找 代码 运行结果 更新(增删改) 代码 运行结果 总结 JDBC的工具类简单实现 一般实现步骤 实现之前,我们创建一 ...
- JDBC实例--工具类升级,使用Apache DBCP连接池重构DBUtility,让连接数据库更有效,更安全...
直接使用JDBC访问数据库时,需要避免以下隐患: 1. 每一次数据操作请求都需要建立数据库连接.打开连接.存取数据和关闭连接等步骤.而建立和打开数据库连接是一件既耗资源又费时的过程,如果频繁发生这种数 ...
- jdbc封装工具类代码_JDBC的使用-JDBC(3)
光有理论,没有实践是不行的,本篇文章就是介绍JDBC如何使用. 本文知识点分布如下: 下载数据库驱动 创建项目添加驱动 通过 Statement 向表中插入数据 通过 Statement 对象修改表中 ...
最新文章
- Linux下用 lsof 命令查找指定端口被哪个进程占用
- DOM中的onbeforeunload函数
- android 自定义模板下载,android studio 自定义模板
- Python+selenium 自动化-chrome驱动的下载安装
- pycharm中安装可以贴图片的Markdown插件
- 运筹学上机实验 - 单纯形方法的两阶段法
- 计算机数学基础模拟试题,计算机数学基础》模拟考试试题.doc
- top,parent,opener,iframe
- pulsar 容量_[Apache Pulsar] 企业级分布式消息系统-Pulsar入门基础
- 网络编程学习记录-1
- 4键电子手表说明书_数字S1系统4.3寸门口主机操作说明书
- Android中Bitmap和Drawable 总结
- Python List pop()方法
- javascript视频教程之《ECMA5核心+设计模式》
- 计算机软件专业搞腾讯地图,腾讯地图电脑离线版
- 【数学和算法】矩阵运算的相关公式
- mysql下载安装安装包_mysql下载安装包及安装步骤
- 使用memcpy函数的耗时测试(拷贝不同大小数据量耗时不同)
- 办公软件excel表格_国产表格神器:超脱excel,画表只是基本功能,做软件才是真本事...
- 配置测试,你了解吗?
热门文章
- 云漫圈 | AR VR傻傻分不清楚。。。
- linux服务器查看mysql服务名称_Linux服务器查看MySQL信息
- nginx python cgi_Python的CGIHTTPServer交互实现详解
- hp服务器硬盘ultra320,惠普/hp 300GB 1.5万转 3.5寸 SAS服务器硬盘 P/N:431944-B21
- redio中插入php脚本,Jquery操作radio的简单实例
- 企业实战_15_MySql主从复制到MyCat总结
- Sublime Text设置快捷键让html文件在浏览器打开
- 第七篇:Spring Boot 整合_Thymeleaf 入门试炼 QuickStart
- Java-Scanner进阶使用
- 苹果手机数据线充不了电_手机充电器充不了电?其实4招就能解决