声明事务
声明事务-实现方式
声明式事务管理的配置类型
- 5种类型:独立代理、共享代理、拦截器、tx拦截器、全注解(前三种Spring官方团队以及不推荐使用了)
tx拦截器具体实现
说明:
所需jar包
1.Spring(基础jar包) beans、core、context、expression 2.测试jar包 junit、spring-test 3.Spring集成 Jdbc spring-jdbc、mysql-connector-java(驱动) 4.Spring-tx事务 spring-tx 5.连接池 commons-dbcp2、commons-pool 6.AOP spring-aop、aopalliance 7.aspectJ相关jar包 spring-aspects、aspectjweaver
本地数据库配置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/books
username=root
password=root
XML配置
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
<!--扫描包-->
<context:component-scan base-package="cn.akwangl.service"/>
<!--引入本地数据库配置-->
<context:property-placeholder location="classpath:jdbc.properties" />
<!--添加数据源-->
<bean id="dataSource" class="org.apache.commons.dbcp2.BasicDataSource"
p:driverClassName="${driverClassName}" p:url="${url}" p:username="${username}" p:password="${password}"/>
<!--jdbcTemplate-->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate" p:dataSource-ref="dataSource"/>
<!--事务管理器-->
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
<!-- 注释模式事务：启动使用注解实现声明式事务管理的支持 -->
<!--<tx:annotation-driven transaction-manager="txManager" />-->
<!--配置tx事务拦截器-->
<tx:advice id="txAdvice" transaction-manager="txManager">
<tx:attributes>
<!--所有以find开头查询方法只有读的权限-->
<tx:method name="find*" read-only="true"/>
<!--其它方法使用默认值-->
<tx:method name="*" read-only="true"/>
</tx:attributes>
</tx:advice>
<!-- 配置切面 -->
<aop:config>
<!--配置切点-->
<aop:pointcut id="bookService" expression="execution(* cn.akwangl.service.impl.BooksServiceImpl.*(..))"/>
<!--配置通知-->
<aop:advisor advice-ref="txAdvice" pointcut-ref="bookService"/>
</aop:config>
</beans>
Model
/**
* 书籍实体类
* @author 阿坤
*/
public class Books {
private Long id;
//ISBN号
private String isbn;
//书名
private String name;
//价格
private Double price;
//发布日期
private Date pubdate;
//set、get方法...
}
Dao
@Service
public class BooksServiceImpl implements BooksService {
@Resource(name = "jdbcTemplate")
private JdbcTemplate jdbcTemplate;
@Override
public void save(Books books) {
String sql="insert into books(isbn,name,price,pubdate) values(?,?,?,?)";
jdbcTemplate.update(sql, books.getIsbn(),books.getName(),books.getPrice(),books.getPubdate());
}
@Override
public void updata(Books books) {
String sql="update books set(isbn=?,name=?,price=?,pubdate=?)";
jdbcTemplate.update(sql, books.getIsbn(),books.getName(),books.getPrice(),books.getPubdate());
}
@Override
public void delete(Long id) {
String sql="delete * from books where id = ?";
jdbcTemplate.update(sql, id);
}
@Override
public Books findOne(Long id) {
String sql = "select * from books where id =?";
Books books = jdbcTemplate.queryForObject(sql, new BooksRowMapper(), id);
return books;
}
@Override
public List<Books> findAll() {
String sql="select * from books";
List<Books> booksList = jdbcTemplate.query(sql, new BooksRowMapper());
return booksList;
}
private class BooksRowMapper implements RowMapper<Books>{
@Override
public Books mapRow(ResultSet resultSet, int i) throws SQLException {
Books books = new Books();
books.setId(resultSet.getLong("id"));
books.setIsbn(resultSet.getString("isbn"));
books.setName(resultSet.getString("name"));
books.setPrice(resultSet.getDouble("price"));
books.setPubdate(resultSet.getDate("pubdate"));
return books;
}
}
}
Test类
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:Spring-tx2.xml")
public class Books_Test {
@Autowired
private BooksService booksService;
/**
* 说明:
* 在XML文件中已经配置了只读属性
* TransientDataAccessResourceException: PreparedStatementCallback; SQL [insert into books(isbn,name,price,pubdate) values(?,?,?,?)];
* Connection is read-only. Queries leading to data modification are not allowed;
* 报这个错是正常的，你只要在XML中将read-only改为false即可，不写默认为(false)
*/
@Test
public void save(){
booksService.save(new Books(null,"123-166-891-China","小白成神之路",99.00,new Date()));
}
}
全注解非常简单
只需将@Transactional注解加入到要开启事务的类或者方法上
前提: XMl文件中要开启事务的支持
<!--启动使用注解实现声明式事务管理的支持-->
<tx:annotation-driven transaction-manager="txManager" />
<!--配置tx事务拦截器-->
<tx:advice id="txAdvice" transaction-manager="txManager">
<tx:attributes>
<!--所有以find开头查询方法只有读的权限-->
<tx:method name="find*" read-only="true"/>
<!--其它方法使用默认值-->
<tx:method name="*" read-only="true"/>
</tx:attributes>
</tx:advice>
Demo
@Transactional
public class XbeanServiceImpl implements XbeanService{
@Override
public Xbean getXbean(int id) {
Xbean xb = new Xbean() ;
xb.setName("业务Bean的ID="+id);
xb.setName("Bean默认名称");
return xb ;
}
@Override
public void insertXbean(Xbean xb) {
throw new UnsupportedOperationException();
}
}
