Spring事务管理

 1  1 package org.dao;
 2  2 
 3  3 import org.springframework.jdbc.core.JdbcTemplate;
 4  4 
 5  5 
 6  6 public class Dao {
 7  7     private JdbcTemplate jdbcTemplate;
 8  8     
 9  9     public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
10 10         this.jdbcTemplate = jdbcTemplate;
11 11     }
12 12 
13 13     //小王转账给小马  金额2000
14 14     public void lessSalary() {
15 15         // TODO Auto-generated method stub
16 16         String sql="update acountmoney set salary=salary+? where name=?";
17 17         jdbcTemplate.update(sql,-2000,"小王");    
18 18     }
19 19 
20 20     public void moreSalary() {
21 21         // TODO Auto-generated method stub
22 22         String sql="update acountmoney set salary=salary+? where name=?";
23 23         jdbcTemplate.update(sql,2000,"小马");;
24 24     }
25 25 
26 26 }

 1 package org.service;
 2 
 3 import org.dao.Dao;
 4 
 5 public class Service {
 6     private Dao dao;
 7 
 8     public void setDao(Dao dao) {
 9         this.dao = dao;
10     }
11     public void changeSalary(){
12         System.out.println("开始转账。。。。。。。。");
13         this.dao.lessSalary();
14         this.dao.moreSalary();
15         System.out.println("转账成功。。。。。。。。。。。");
16     }
17 }

 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:aop="http://www.springframework.org/schema/aop"
 6     xmlns:tx="http://www.springframework.org/schema/tx"
 7     xsi:schemaLocation="http://www.springframework.org/schema/beans 
 8     http://www.springframework.org/schema/beans/spring-beans.xsd
 9     http://www.springframework.org/schema/context
10     http://www.springframework.org/schema/context/spring-context.xsd
11     http://www.springframework.org/schema/aop
12     http://www.springframework.org/schema/aop/spring-aop.xsd
13     http://www.springframework.org/schema/tx
14     http://www.springframework.org/schema/tx/spring-tx.xsd">
15     <!-- 配置c3p0连接池 -->
16     <bean id="c3p0" class="com.mchange.v2.c3p0.ComboPooledDataSource">
17         <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
18         <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/account"></property>
19         <property name="user" value="root"></property>
20         <property name="password" value="jay571018"></property>
21     </bean>
22     
23     <!-- 创建dao对象  注入jdbcTemplate-->
24     <bean id="dao" class="org.dao.Dao">
25         <property name="jdbcTemplate" ref="jdbcTemplate"></property>
26     </bean>
27     
28     <!-- 创建service对象  注入dao-->
29     <bean id="service" class="org.service.Service">
30         <property name="dao" ref="dao"></property>
31     </bean>
32     
33     <!-- 创建jdbcTemplate对象 注入数据库连接池-->
34     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
35         <property name="dataSource" ref="c3p0"></property>
36     </bean>
37     
38 </beans>

 1 package org.test;
 2 
 3 import org.junit.Test;
 4 import org.service.Service;
 5 import org.springframework.context.ApplicationContext;
 6 import org.springframework.context.support.ClassPathXmlApplicationContext;
 7 
 8 public class TestSalary {
 9     @Test
10     public void testsalary(){
11         ApplicationContext ac=new ClassPathXmlApplicationContext("applicationContext.xml");
12         Service s=(Service)ac.getBean("service");
13         s.changeSalary();
14     }
15 }