一、处理方式不同
创新互联专业为企业提供铜梁网站建设、铜梁做网站、铜梁网站设计、铜梁网站制作等企业网站建设、网页设计与制作、铜梁企业网站模板建站服务,10年铜梁做网站经验,不只是建网站,更提供有价值的思路和整体网络服务。
1、手动提交:用显式的方式定义其开始和结束的事务,当使用start transaction和 commit语句时则表示发生显式事务。
2、自动提交:指每一条数据操作语句都自动地成为一个事务,事务的开始是隐式的,事务的结束有明确的标记。
二、特点不同
1、手动提交:逻辑相关的操作分成了一个组,在数据永久改变前,可以预览数据变化。
2、自动提交:能够保证数据的读一致性。
三、处理结果不同
1、手动提交:务被提交给了DBMS(数据库管理系统),则DBMS(数据库管理系统)需要确保该事务中的所有操作都成功完成且其结果被永久保存在数据库中。
2、自动提交:事务中有的操作没有成功完成,则事务中的所有操作都需要被回滚,回到事务执行前的状态;同时,该事务对数据库或者其他事务的执行无影响,所有的事务都好像在独立的运行。
参考资料来源:百度百科-数据库事务
参考资料来源:百度百科-SQL数据库
事务 指作为单个逻辑工作单元执行的一系列操作。 事务处理可以确保除非事务性单元内的所有操作都成功完成,否则不会永久更新面向数据的资源。通过将一组相关操作组合为一个要么全部成功要么全部失败的单元,可以简化错误恢复并使应用程序更加可靠。一个逻辑工作单元要成为事务,必须满足所谓的ACID(原子性、一致性、隔离性和持久性)属性;
在java中你要手工执行事务,如果是jdbc连接数据库,那么就设置提交的时候手动提交
conn.setAutoCommit(false);//conn 是connection对象
当结束后
conn.commit();
希望对你有帮助
如何用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")
public void 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()
{
MysqlDataSource dataSource = new MysqlDataSource();
dataSource.setDatabaseName("mysql");
dataSource.setServerName("server");
dataSource.setPortNumber(1435);
dataSource.setUser("test1");
dataSource.setPassword("test1");
return dataSource;
}
}
启动事务 conn.setAutoCommit();
这个不是启动事务,而是设置事务是否自动提交,默认是自动提交,如果要手动控的话,写成conn.setAutoCommit(false);
if(rs.next){
...执行更新
conn.commit();
}
这个也不对,RS不可能执更新操作。只能是查询。
如果你进行了锁表操作,那么如果没有commit()或rollbak()方法,是不会进行解锁操作的。
下面给你些代码段以做参考。
public class SQLCondition{
public ResultSet execuQuery(Connection conn) throws SQLException{
检索操作.......
}
public int execuUpdate(Connection conn) throws SQLException{
更新操作.......
}
}
public class DBAccess(){
public void execute(){
SQLCondition condition = .....;
Connection conn = .....;
try{
conn.setAutoCommit(false); //设成非自动提交
condition.execuQuery(conn);
condition.execuUpdate(conn);
//如果操作成功会走到这一步,进行提交,可以解锁
conn.commit();
}catch(SQLException){
//出现任何的SQL异常都可以捕捉到,进行事务回滚,也可以解锁。
conn.rollbak();
}
}
}
自动默认是回滚事务?
默认的话,是执行一条就进行提交,如果错了会回滚。
很简单,直接将autoCommit设置为false,就可以自己控制事务的提交和回滚!
大概是:conn.setAutoCommit(false);这个方法,然后开启事务是:conn.beginTrainsaction();方法如有不准确,希望海涵!
请把这个方法的代码贴上 Connection conn=DBUtil.getConnection();
可能 service层 和 Dao层 拿到的不是同一个connection .
service产生connection后 应该 以参数方式传给Dao层。 Dao层操作完后 再在sercice层提交事务和关闭connection.