spring基于纯注解的声明式事务控制
生活随笔
收集整理的這篇文章主要介紹了
spring基于纯注解的声明式事务控制
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.learn</groupId><artifactId>day04_learn_07anno_tx_withoutxml</artifactId><version>1.0-SNAPSHOT</version><packaging>jar</packaging><dependencies><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>5.0.2.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-jdbc</artifactId><version>5.0.2.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-tx</artifactId><version>5.0.2.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-test</artifactId><version>5.0.2.RELEASE</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.45</version></dependency><dependency><groupId>org.aspectj</groupId><artifactId>aspectjweaver</artifactId><version>1.8.7</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version></dependency></dependencies></project>
package com.learn.dao;import com.learn.domain.Account;/*** 賬戶的持久層接口*/
public interface IAccountDao {/*** 根據Id查詢賬戶* @param accountId* @return*/Account findAccountById(Integer accountId);/*** 根據名稱查詢賬戶* @param accountName* @return*/Account findAccountByName(String accountName);/*** 更新賬戶* @param account*/void updateAccount(Account account);
}
package com.learn.dao.impl;import com.learn.dao.IAccountDao;
import com.learn.domain.Account;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;import java.util.List;/*** 賬戶的持久層實現類*/
@Repository("accountDao")
public class AccountDaoImpl implements IAccountDao {@Autowiredprivate JdbcTemplate jdbcTemplate;public Account findAccountById(Integer accountId) {List<Account> accounts = jdbcTemplate.query("select * from account where id = ?",new BeanPropertyRowMapper<Account>(Account.class),accountId);return accounts.isEmpty()?null:accounts.get(0);}public Account findAccountByName(String accountName) {List<Account> accounts = jdbcTemplate.query("select * from account where name = ?",new BeanPropertyRowMapper<Account>(Account.class),accountName);if(accounts.isEmpty()){return null;}if(accounts.size()>1){throw new RuntimeException("結果集不唯一");}return accounts.get(0);}public void updateAccount(Account account) {jdbcTemplate.update("update account set name=?,money=? where id=?",account.getName(),account.getMoney(),account.getId());}
}
package com.learn.domain;import java.io.Serializable;/*** 賬戶的實體類*/
public class Account implements Serializable {private Integer id;private String name;private Float money;public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public Float getMoney() {return money;}public void setMoney(Float money) {this.money = money;}@Overridepublic String toString() {return "Account{" +"id=" + id +", name='" + name + '\'' +", money=" + money +'}';}
}
package com.learn.service;import com.learn.domain.Account;/*** 賬戶的業務層接口*/
public interface IAccountService {/*** 根據id查詢賬戶信息* @param accountId* @return*/Account findAccountById(Integer accountId);/*** 轉賬* @param sourceName 轉成賬戶名稱* @param targetName 轉入賬戶名稱* @param money 轉賬金額*/void transfer(String sourceName, String targetName, Float money);
}
package com.learn.service.impl;import com.learn.dao.IAccountDao;
import com.learn.domain.Account;
import com.learn.service.IAccountService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;/*** 賬戶的業務層實現類** 事務控制應該都是在業務層*/
@Service("accountService")
@Transactional(propagation= Propagation.SUPPORTS,readOnly=true)//只讀型事務的配置
public class AccountServiceImpl implements IAccountService{@Autowiredprivate IAccountDao accountDao;public Account findAccountById(Integer accountId) {return accountDao.findAccountById(accountId);}//需要的是讀寫型事務配置@Transactional(propagation= Propagation.REQUIRED,readOnly=false)public void transfer(String sourceName, String targetName, Float money) {System.out.println("transfer....");//2.1根據名稱查詢轉出賬戶Account source = accountDao.findAccountByName(sourceName);//2.2根據名稱查詢轉入賬戶Account target = accountDao.findAccountByName(targetName);//2.3轉出賬戶減錢source.setMoney(source.getMoney()-money);//2.4轉入賬戶加錢target.setMoney(target.getMoney()+money);//2.5更新轉出賬戶accountDao.updateAccount(source);// int i=1/0;//2.6更新轉入賬戶accountDao.updateAccount(target);}
}
package config;import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
import org.springframework.context.annotation.PropertySource;
import org.springframework.transaction.annotation.EnableTransactionManagement;/*** spring的配置類，相當于bean.xml*/
@Configuration
@ComponentScan("com.learn")
@Import({JdbcConfig.class,TransactionConfig.class})
@PropertySource("jdbcConfig.properties")
@EnableTransactionManagement
public class SpringConfiguration {
}
package config;import org.springframework.context.annotation.Bean;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;import javax.sql.DataSource;/*** 和事務相關的配置類*/
public class TransactionConfig {/*** 用于創建事務管理器對象* @param dataSource* @return*/@Bean(name="transactionManager")public PlatformTransactionManager createTransactionManager(DataSource dataSource){return new DataSourceTransactionManager(dataSource);}
}
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/test
jdbc.username=root
jdbc.password=123456
package config;import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;import javax.sql.DataSource;/*** 和連接數據庫相關的配置類*/
public class JdbcConfig {@Value("${jdbc.driver}")private String driver;@Value("${jdbc.url}")private String url;@Value("${jdbc.username}")private String username;@Value("${jdbc.password}")private String password;/*** 創建JdbcTemplate* @param dataSource* @return*/@Bean(name="jdbcTemplate")public JdbcTemplate createJdbcTemplate(DataSource dataSource){return new JdbcTemplate(dataSource);}/*** 創建數據源對象* @return*/@Bean(name="dataSource")public DataSource createDataSource(){DriverManagerDataSource ds = new DriverManagerDataSource();ds.setDriverClassName(driver);ds.setUrl(url);ds.setUsername(username);ds.setPassword(password);return ds;}
}
?
總結
以上是生活随笔為你收集整理的spring基于纯注解的声明式事务控制的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： spring基于注解的声明式事务控制
- 下一篇： spring编程式事务控制