锐客网

  1. 首页 > 睿知 > it技术 > >

java中事务代码实例 java中事务是什么

事务IT技术

如何用java开启mysql事务，要求详细如何用java开启mysql事务，要求详细
看你是什么事务，jdbc事务 ， 还是分布式事务，还是容器事务
1，编程式事务管理（jdbc的事务是绑定在connection上的）
Connection conn = null;
try
{
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection("jdbc:oracle:thin:@host:1521:SID","username","password");
conn.setAutoCommit(false);//取消自动提交
PreparedStatement ps = conn.prepareCall("update something");
ResultSet rs = ps.executeQuery();
conn.commit();//手动提交
}
catch (Exception e)
{
conn.rollback();
e.printStackTrace();
}
finally
{
conn.close();
}
2，声明式事务
先在工程的application.xml配置文件中添加如下代码，开启事务
!-- 声明式事务控制配置 --
tx:annotation-driven transaction-manager="txManager"/
bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"
property name="datasource" ref="bassDataSource"/property
/bean
然后在你需要开启事务的接口前面添加注解
@Transactional(rollbackFor = IOException.class)
public void add(String name) throws IOException
{
System.out.println("可以再类里和方法里面添加事务注解0~0");
throw new IOException();
}
直接调用接口方法就好
分布式事务处理（mysql貌似在5.X之后才支持） 的话，
1.可以直接使用spring atomikos框架进行管理
参考：
就不贴测试代码了，自己看着配置吧
2 ， 使用JTA（Java Transaction API）进行分布式事务管理（测试代码如下）
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import javax.naming.InitialContext;
import javax.sql.DataSource;
import javax.transaction.SystemException;
import javax.transaction.UserTransaction;
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
//分布式事务处理
public class transferAccount
{
@SuppressWarnings("null")
publicvoid testTransferAccount()
{
UserTransaction userts = null;
Connection connA = null;
PreparedStatement psA = null;
InitialContext context = null;
Connection connB = null;
PreparedStatement psB = null;
try
{
//获得事务管理对象
userts = (UserTransaction) context.lookup("java:comp/UserTransaction");
//获取两个数据库
connA = getDataSourceA().getConnection();
connB = getDataSourceB().getConnection();
//开启事务
userts.begin();
//sql语句
psA = connA.prepareStatement("我加1");
psB = connB.prepareStatement("我减1");
//执行sql
psA.executeUpdate();
psB.executeUpdate();
//事务提交
userts.commit();
} catch (Exception e)
{
try
{
userts.rollback();
} catch (IllegalStateException | SecurityException
| SystemException e1)
{
e1.printStackTrace();
}
e.printStackTrace();
}
finally
{
try
{
psA.close();
psB.close();
connA.close();
connB.close();
} catch (SQLException e)
{
e.printStackTrace();
}
}
}
public DataSource getDataSourceA()
{
MysqlDataSource dataSource = new MysqlDataSource();
dataSource.setDatabaseName("mysql");
dataSource.setServerName("server");
dataSource.setPortNumber(1433);
dataSource.setUser("test");
dataSource.setPassword("test");
return dataSource;
}
public DataSource getDataSourceB()
{
【java中事务代码实例 java中事务是什么】MysqlDataSource dataSource = new MysqlDataSource();
dataSource.setDatabaseName("mysql");
dataSource.setServerName("server");
dataSource.setPortNumber(1435);
dataSource.setUser("test1");
dataSource.setPassword("test1");
return dataSource;
}
}
java 事务Java中的事务处理
一般情况下java中事务代码实例，J2EE应用服务器支持JDBC事务、JTA（Java Transaction API）事务、容器管理事务 。一般情况下java中事务代码实例，最好不要在程序中同时使用上述三种事务类型，比如在JTA事务中嵌套JDBC事务 。第二方面，事务要在尽可能短的时间内完成，不要在不同方法中实现事务的使用 。下面我们列举两种事务处理方式 。
1、JavaBean中使用JDBC方式进行事务处理
在JDBC中怎样将多个SQL语句组合成一个事务呢？在JDBC中 ， 打开一个连接对象Connection时，缺省是auto-commit模式，每个SQL语句都被当作一个事务，即每次执行一个语句，都会自动的得到事务确认 。为了能将多个SQL语句组合成一个事务，要将auto-commit模式屏蔽掉 。在auto-commit模式屏蔽掉之后，如果不调用commit()方法，SQL语句不会得到事务确认 。在最近一次commit()方法调用之后的所有SQL会在方法commit()调用时得到确认 。
public int delete(int sID) {
dbc = new DataBaseConnection();
Connection con = dbc.getConnection();
try {
con.setAutoCommit(false);// 更改JDBC事务的默认提交方式
dbc.executeUpdate("delete from bylaw where ID="sID);
dbc.executeUpdate("delete from bylaw _content where ID="sID);
dbc.executeUpdate("delete from bylaw _affix where bylawid="sID);
con.commit();//提交JDBC事务
con.setAutoCommit(true);// 恢复JDBC事务的默认提交方式
dbc.close();
return 1;
}
catch (Exception exc) {
con.rollBack();//回滚JDBC事务
exc.printStackTrace();
dbc.close();
return -1;
}
}
2、SessionBean中的JTA事务
JTA 是事务服务的 J2EE 解决方案 。本质上，它是描述事务接口（比如 UserTransaction 接口，开发人员直接使用该接口或者通过 J2EE 容器使用该接口来确保业务逻辑能够可靠地运行）的 J2EE 模型的一部分 。JTA 具有的三个主要的接口分别是 UserTransaction 接口、TransactionManager 接口和 Transaction 接口 。这些接口共享公共的事务操作 ， 例如 commit() 和 rollback()，但是也包含特殊的事务操作，例如 suspend()，resume() 和 enlist()，它们只出现在特定的接口上，以便在实现中允许一定程度的访问控制 。例如，UserTransaction 能够执行事务划分和基本的事务操作，而 TransactionManager 能够执行上下文管理 。
应用程序可以调用UserTransaction.begin()方法开始一个事务，该事务与应用程序正在其中运行的当前线程相关联 。底层的事务管理器实际处理线程与事务之间的关联 。UserTransaction.commit()方法终止与当前线程关联的事务 。UserTransaction.rollback()方法将放弃与当前线程关联的当前事务 。
public int delete(int sID) {
DataBaseConnection dbc = null;
dbc = new DataBaseConnection();
dbc.getConnection();
UserTransaction transaction = sessionContext.getUserTransaction();//获得JTA事务
try {
transaction.begin(); //开始JTA事务
dbc.executeUpdate("delete from bylaw where ID="sID);
dbc.executeUpdate("delete from bylaw _content where ID="sID);
dbc.executeUpdate("delete from bylaw _affix where bylawid="sID);
transaction.commit(); //提交JTA事务
dbc.close();
return 1;
}
catch (Exception exc) {
try {
transaction.rollback();//JTA事务回滚
}
catch (Exception ex) {
//JTA事务回滚出错处理
ex.printStackTrace();
}
exc.printStackTrace();
dbc.close();
return -1;
}
}
java事务处理如果对数据库进行多次操作,每一次的执行或步骤都是一个事务.如果数据库操作在某一步没有执行或出现异常而导致事务失败,这样有的事务被执行有的就没有被执行,从而就有了事务的回滚,取消先前的操作.....
JavaBean中使用JDBC方式进行事务处理
publicintdelete(intsID){
dbc=newDataBaseConnection();
Connectioncon=dbc.getConnection();
try{
con.setAutoCommit(false);//更改JDBC事务的默认提交方式
dbc.executeUpdate("deletefromxiaowhereID="sID);
dbc.executeUpdate("deletefromxiao_contentwhereID="sID);
dbc.executeUpdate("deletefromxiao_affixwherebylawid="sID);
con.commit();//提交JDBC事务
con.setAutoCommit(true);//恢复JDBC事务的默认提交方式
dbc.close();
return1;
}
catch(Exceptionexc){
con.rollBack();//回滚JDBC事务
exc.printStackTrace();
dbc.close();
return-1;
}
}
在数据库操作中java中事务代码实例，一项事务是指由一条或多条对数据库更新的sql语句所组成的一个不可分割的工作单元 。只有当事务中的所有操作都正常完成了java中事务代码实例，整个事务才能被提交到数据库 ， 如果有一项操作没有完成，就必须撤消整个事务 。
例如在银行的转帐事务中，假定张三从自己的帐号上把1000元转到李四的帐号上，相关的sql语句如下：
updateaccountsetmonery=monery-1000wherename='zhangsan'
updateaccountsetmonery=monery 1000wherename='lisi'
这个两条语句必须作为一个完成的事务来处理 。只有当两条都成功执行了，才能提交这个事务 。如果有一句失败，整个事务必须撤消 。
在connection类中提供了3个控制事务的方法：
（1）setAutoCommit(BooleanautoCommit):设置是否自动提交事务；
（2）commit();提交事务；
（3）rollback();撤消事务；
在jdbcapi中，默认的情况为自动提交事务，也就是说，每一条对数据库的更新的sql语句代表一项事务，操作成功后，系统自动调用commit（）来提交，否则将调用rollback（）来撤消事务 。
在jdbcapi中，可以通过调用setAutoCommit(false)来禁止自动提交事务 。然后就可以把多条更新数据库的sql语句做为一个事务，在所有操作完成之后，调用commit（）来进行整体提交 。倘若其中一项sql操作失败，就不会执行commit（）方法，而是产生相应的sqlexception，此时就可以捕获异常代码块中调用rollback（）方法撤消事务 。
java中的事务到底怎么理解举个实际的例子比如说你去银行转账 ， 将将 A 账户中的金额转到B账户 。
A 语句：update Table set amount = amount - 100 where id = 'A'"
B语句：update Tableset amount = amount100 where id = 'B'"
会有两条update语句，如果不用事务处理的话，在A语句执行完之后 ， 在执行B语句的时候出错，那么A账户的金额减少了，B账户的金额却没有增加，这就有问题了
所以要用到事务来控制，如果B语句出现错误，就将事务回滚，A账户的金额也不会减少 。
如果A 。B都执行成功，事务提交
简单来说就是所有在事务中的语句必须全部执行成功，事务才会提交，如果有一条执行失败，事务就会回滚 。
关于java中事务代码实例和java中事务是什么的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息 ， 记得收藏关注本站 。

    推荐阅读


    上一篇：熊本家分销商城小程序开发，熊本家销售模式

    下一篇：如何建立自己的JSON服务器？ json服务器怎么弄