ibatis事务控制案例资源-CSDN文库

共13个文件

xml：4个

java：2个

jar：2个

java

ibatis

事务

3星 · 超过75%的资源需积分: 9 37 浏览量 2009-07-17 15:44:03 上传评论收藏 549KB RAR 举报

在IT行业中，数据库操作是应用程序的核心部分，而事务控制则是保证数据一致性与完整性的关键机制。本案例聚焦于`ibatis`（MyBatis前身）的事务管理，它是一个轻量级的Java持久层框架，提供了灵活的SQL映射功能。在Java应用中，Ibatis与SQL Server、MySQL等数据库配合，可以实现高效的数据库访问和事务处理。 **1. 什么是事务** 事务是一组数据库操作，这些操作被视为一个整体，要么全部成功，要么全部回滚。在数据库管理系统中，事务有四个特性，通常称为ACID属性：原子性（Atomicity）、一致性（Consistency）、隔离性（Isolation）和持久性（Durability）。 **2. Ibatis中的事务控制** 在Ibatis中，事务管理可以通过编程式或声明式两种方式实现。编程式事务管理需要在代码中手动开启、提交和回滚事务，而声明式事务管理则依赖于Spring等框架进行配置。 **3. 编程式事务管理** 在Java中，你可以使用`java.sql.Connection`对象来管理事务。在业务逻辑代码中，你需要获取数据库连接，然后手动调用`setAutoCommit(false)`关闭自动提交，执行SQL操作后，根据业务结果决定调用`commit()`提交还是`rollback()`回滚事务。 **4. 声明式事务管理** 在Spring框架中，你可以通过配置XML或注解来管理事务。例如，使用`@Transactional`注解标记在方法上，Spring会自动管理事务的生命周期。如果方法抛出未检查异常（继承自`RuntimeException`的异常）或`Error`，Spring会自动回滚事务；其他情况下，事务会在方法正常结束时提交。 **5. Ibatis的SqlSession与事务** Ibatis中的`SqlSession`对象是执行SQL语句并管理事务的载体。每次打开`SqlSession`，都会默认启动一个新的事务。当调用`SqlSession.commit()`或`SqlSession.rollback()`时，事务会被提交或回滚。如果你需要在一个`SqlSession`中执行多个操作，记得在最后调用`commit()`。 **6. 示例代码** 以下是一个简单的Ibatis编程式事务管理示例： ```java Connection conn = dataSource.getConnection(); conn.setAutoCommit(false); // 关闭自动提交 try { SqlSession session = sqlSessionFactory.openSession(conn); YourMapper mapper = session.getMapper(YourMapper.class); // 执行SQL操作 mapper.someInsertOperation(); mapper.someUpdateOperation(); session.commit(); // 提交事务 } catch (Exception e) { conn.rollback(); // 如果发生异常，回滚事务 throw e; } finally { conn.close(); // 关闭连接 } ``` **7. 性能优化** 在大型系统中，为了提高事务处理性能，可能会采用事务传播行为和事务超时设置。例如，Spring支持PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW等不同的事务传播行为，以适应不同的业务场景。同时，可以设定事务的最大等待时间，避免因长时间等待导致资源浪费。 Ibatis的事务控制是确保数据一致性和系统稳定性的关键组件。理解和熟练掌握其事务管理机制，对于开发高效、可靠的Java应用程序至关重要。通过案例学习和实践，你可以进一步了解如何在实际项目中运用Ibatis进行事务控制。

资源推荐

资源详情

资源评论

收起资源包目录

ibatis事务控制.rar （13个子文件）

ibatis事务控制

.project 1020B

.mymetadata 319B

backup.sql 234B

WebRoot

WEB-INF

web.xml 284B

lib

sqljdbc.jar 227KB

ibatis-2.3.4.726.jar 375KB

classes

SqlMapConfig.xml 1KB

META-INF

MANIFEST.MF 39B

.myeclipse

src

com

test

voo

Product.xml 2KB

Product.java 960B

test

SimpleExample.java 4KB

SqlMapConfig.xml 1KB

.classpath 489B

package com.test.test; import com.ibatis.sqlmap.client.SqlMapClient; import com.ibatis.sqlmap.client.SqlMapClientBuilder; import com.ibatis.common.resources.Resources; import com.test.voo.*; import java.io.Reader; import java.io.IOException; import java.util.List; import java.sql.SQLException; /** * This is not a best practices class. It's just an example * to give you an idea of how iBATIS works. For a more complete * example, see JPetStore 5.0 at http://www.ibatis.com. */ public class SimpleExample { /** * SqlMapClient instances are thread safe, so you only need one. * In this case, we'll use a static singleton. So sue me. ;-) */ private static SqlMapClient sqlMapper; /** * It's not a good idea to put code that can fail in a class initializer, * but for sake of argument, here's how you configure an SQL Map. */ static { try { Reader reader = Resources.getResourceAsReader("SqlMapConfig.xml"); sqlMapper = SqlMapClientBuilder.buildSqlMapClient(reader); reader.close(); } catch (IOException e) { // Fail fast. throw new RuntimeException("Something bad happened while building the SqlMapClient instance." + e, e); } } public static List selectAllAccounts () throws SQLException { return sqlMapper.queryForList("selectAllProducts"); } public static Product selectProductById (int productid) throws SQLException { return (Product) sqlMapper.queryForObject("selectProductById", productid); } public static void insertProduct (Product Product) throws SQLException { sqlMapper.insert("insertProduct", Product); } public static void updateProduct (Product Product) throws SQLException { sqlMapper.update("updateProduct", Product); } public static void deleteProduct (int productid) throws SQLException { sqlMapper.delete("deleteProductById", productid); } public static void main(String []args) { //测试事务 try { Reader reader = Resources.getResourceAsReader("SqlMapConfig.xml"); sqlMapper = SqlMapClientBuilder.buildSqlMapClient(reader); reader.close(); //事务控制 sqlMapper.startTransaction(); //添加两个产品 Product p1=new Product(); p1.setProductname("苹果2"); p1.setPrice(22.35f); sqlMapper.insert("insertProduct", p1); Product p2=new Product();//品名为null ，出错 p2.setPrice(22); sqlMapper.insert("insertProduct", p2); sqlMapper.commitTransaction(); } catch (Exception e) { e.printStackTrace(); try { sqlMapper.endTransaction(); } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } } // try { // // //查询全部 // System.out.println("................查询全部..............."); // List all=SimpleExample.selectAllAccounts(); // for(int i=0;i<all.size();i++) // { // System.out.println((Product)all.get(i)); // } // // //查询单一 // System.out.println("................查询单一..............."); // Product p1=SimpleExample.selectProductById(4); // System.out.println(p1); // // //增加 // System.out.println("................增加..............."); // Product p2=new Product(); // p2.setProductname("苹果"); // p2.setPrice(22.35f); // SimpleExample.insertProduct(p2); // // //修改 // System.out.println("................修改..............."); // Product p3=new Product(); // p3.setProductid(2); // p3.setProductname("西瓜"); // p3.setPrice(222.35f); // SimpleExample.updateProduct(p3); // // //删除 // System.out.println("................删除..............."); // SimpleExample.deleteProduct(4); // // } catch (SQLException e) { // // TODO Auto-generated catch block // e.printStackTrace(); // } } }

评论收藏

内容反馈