设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

spring连接jdbc-事务

2016-8-29 13:17| 发布者: zhangjf| 查看: 674| 评论: 0

摘要: 1、新建项目，名为transactionExample2、导入jar包导入了spring中的所有jar包和另外两个jar包：3、applicationContext.xml?xml version=1.0 encoding=UTF-8?beans xmlns=http://www.springframework.org/schema/bean ...

1、新建项目，名为transactionExample
2、导入jar包
导入了spring中的所有jar包和另外两个jar包：

3、applicationContext.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:context="http://www.springframework.org/schema/context"
  5. xmlns:util="http://www.springframework.org/schema/util"
  6. xmlns:tx="http://www.springframework.org/schema/tx"
  7. xmlns:aop="http://www.springframework.org/schema/aop"
  8. xsi:schemaLocation="
  9. http://www.springframework.org/schema/beans
  10. http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
  11. http://www.springframework.org/schema/context
  12. http://www.springframework.org/schema/context/spring-context-3.0.xsd
  13. http://www.springframework.org/schema/util
  14. http://www.springframework.org/schema/util/spring-util-3.0.xsd
  15. http://www.springframework.org/schema/tx
  16. http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
  17. http://www.springframework.org/schema/aop
  18. http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
  19. ">
  22. <!-- 使用jdbc作为持久方案,仅仅是得到连接 -->
  23. <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
  24. <property name="driverClassName" value="com.mysql.jdbc.Driver" />
  25. <property name="url" value="jdbc:mysql://localhost:3306/book" />
  26. <property name="username" value="root" />
  27. <property name="password" value="sll" />
  28. </bean>
  30. <bean id="jdbcDaoSupport" class="dao.JdbcDaoSupport" abstract="true">
  31. <property name="dataSource" ref="dataSource"></property>
  32. </bean>
  34. <!-- 定义jdbcTemplateDao的bean -->
  35. <bean id="jdbcTemplateDao" class="dao.JdbcTemplateDao" parent="jdbcDaoSupport">
  36. </bean>
  38. <!-- 定义jdbcTemplateService的bean -->
  39. <bean id="jdbcTemplateService" class="service.JdbcTemplateService">
  40. <property name="jdbcTemplateDao">
  41. <ref bean="jdbcTemplateDao"/>
  42. </property>
  43. </bean>
  46. <!-- 配置jdbc事务管理器 -->
  47. <bean id="jdbcTxManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  48. <property name="dataSource" ref="dataSource" />
  49. </bean>
  51. <!-- 对domain这个方法实现事务 -->
  52. <tx:advice id="txAdvice" transaction-manager="jdbcTxManager">
  53. <tx:attributes>
  54. <tx:method name="*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>
  55. </tx:attributes>
  56. </tx:advice>
  58. <!-- 事务控制位置 -->
  59. <aop:config expose-proxy="true">
  60. <aop:pointcut id="serviceOperation"
  61. expression="execution(* service.*.service.*(..))" />
  62. <aop:advisor advice-ref="txAdvice" pointcut-ref="serviceOperation" />
  63. </aop:config>
  65. </beans>
复制代码

4、JdbcTemplateService.java
service方法中含有save、update的delete三个方法。在save方法之后，程序出错，所以事务会回滚，之前的save操作会失效，不会保存到数据库中。

  1. public class JdbcTemplateService {
  3. private JdbcTemplateDao jdbcTemplateDao;
  5. public void domain(){
  6. jdbcTemplateDao.save();
  7. int i = 2/0;//这里出错了，事务会回滚，之前的save无效
  8. jdbcTemplateDao.update();
  9. jdbcTemplateDao.delete();
  10. }
  12. public JdbcTemplateDao getJdbcTemplateDao() {
  13. return jdbcTemplateDao;
  14. }
  16. public void setJdbcTemplateDao(JdbcTemplateDao jdbcTemplateDao) {
  17. this.jdbcTemplateDao = jdbcTemplateDao;
  18. }
  19. }
复制代码

5.JdbcTemplateDao.java
在这里需要注意的是，jdbc默认是一个语句一个事务，所以，当要实现spring配置的事务的时候，需要加上conn.setAutoCommit(false);否则回滚操作会失效。

  1. public class JdbcTemplateDao extends JdbcDaoSupport{
  3. private PreparedStatement pre = null;
  4. private Connection conn;
  6. //异常向上层抛出
  7. public void save() {
  8. String insertSql = "insert into user values(?,?)";
  9. try {
  10. conn = getDataSource().getConnection();
  11. conn.setAutoCommit(false);
  12. pre = conn.prepareStatement(insertSql);
  13. pre.setString(1, "hahaha");
  14. pre.setString(2, "happy");
  15. pre.executeUpdate();
  16. } catch (SQLException e) {
  17. e.printStackTrace();
  18. }
  19. }
  20. public void delete(){
  21. ...
  22. }
  23. public void update(){
  24. ...
  25. }
  26. }
复制代码

6、JdbcDaoSupport.java
本来JdbcDaoSupport 这个类应该是本来就存在的，但是当我在JdbcTemplateDao.java中继承了JdbcDaoSupport.java这个类之后，得到的DataSource总是为空，所以我另写了一个JdbcDaoSupport.java，里面有set和get方法，这样就能正确地得到DataSource的值。

  1. public class JdbcDaoSupport {
  3. private DriverManagerDataSource driverManagerDataSource;
  5. public DriverManagerDataSource getDataSource() {
  6. return driverManagerDataSource;
  7. }
  9. public void setDataSource(DriverManagerDataSource driverManagerDataSource) {
  10. this.driverManagerDataSource = driverManagerDataSource;
  11. }
  12. }
复制代码

7、测试类

  1. /**
  2. * 用于测试的main函数
  3. * @author Administrator
  4. *
  5. */
  6. public class test {
  8. /**
  9. * @param args
  10. * @throws SQLException
  11. * @throws SQLException
  12. */
  13. public static void main(String[] args){
  14. String[] configLocations = new String[] {"applicationContext.xml"};
  15. //应该引入spring的jar包
  16. ApplicationContext ctx = new ClassPathXmlApplicationContext(configLocations);
  17. JdbcTemplateService j = ctx.getBean(JdbcTemplateService.class);
  18. j.domain();
  19. }
  21. }
复制代码
收藏 邀请
上一篇：几种常见排序算法下一篇：Android单元测试（五）：依赖注入，将mock方便的用起来

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-7-6 19:54

Copyright 2015-2025 djqfx

返回顶部