实现的效果是： 用户在购买股票的时候，钱减少！股票增加！
模拟出现的问题是！ 用户在购买股票的时候，钱减少！ 股票没有增加！
01.创建对应的数据库
02.创建对应实体类
public class Account { //银行账户
private Integer aid;
private double money;
private String aname;
public Integer getAid() {
return aid;
}
public void setAid(Integer aid) {
this.aid = aid;
}
public double getMoney() {
return money;
}
public void setMoney(double money) {
this.money = money;
}
public String getAname() {
return aname;
}
public void setAname(String aname) {
this.aname = aname;
}
public Account(Integer aid, double money, String aname) {
super();
this.aid = aid;
this.money = money;
this.aname = aname;
}
@Override
public String toString() {
return "Account [aid=" + aid + ", money=" + money + ", aname=" + aname
+ "]";
}
}
Account
public class Stock { //股票
private Integer sid;
private Integer amount;
private String sname;
public Integer getSid() {
return sid;
}
public void setSid(Integer sid) {
this.sid = sid;
}
public Integer getAmount() {
return amount;
}
public void setAmount(Integer amount) {
this.amount = amount;
}
public String getSname() {
return sname;
}
public void setSname(String sname) {
this.sname = sname;
}
public Stock(Integer sid, Integer amount, String sname) {
super();
this.sid = sid;
this.amount = amount;
this.sname = sname;
}
public Stock() {
super();
}
@Override
public String toString() {
return "Stock [sid=" + sid + ", amount=" + amount + ", sname=" + sname
+ "]";
}
}
Stock
03.创建对应的dao
public interface StockDao {
//股票开户
void openStock(String sName,Integer amount);
//增加股票
void updateStock(String sName,Integer amount);
}
public interface AccoutDao {
//银行开户
void openAccount(String aName,double money);
//购买股票
void updateAccount(String aName,double money);
}
04.创建对应的service和自定义的异常类
public interface StockService {
//股票开户
void openStock(String sName,Integer amount);
//银行开户
void openAccount(String aName,double money);
/**
* 谁花了多少钱 买了 多少股票？？
*/
void buyStock(String name,double money,Integer amount) throws BuyStockException;
}
/**
* @Transactional
* isolation：事务的隔离级别
* propagation：事务的传播行为
* rollbackFor :需要回滚的异常类！ 类型是Class
* readOnly:对数据库的操作 只读！ 默认false！
* timeout:设置与数据库连接的超时时间！ 单位是S！ 默认值 -1！
*/
public class StockServiceImpl implements StockService { private StockDao stockDao;
private AccoutDao accountDao; //股票开户
@Transactional(isolation=Isolation.DEFAULT,propagation=Propagation.REQUIRED)
@Override
public void openStock(String sName, Integer amount) {
stockDao.openStock(sName, amount);
} //银行开户
@Transactional(isolation=Isolation.DEFAULT,propagation=Propagation.REQUIRED)
@Override
public void openAccount(String aName, double money) {
accountDao.openAccount(aName, money);
} /**
* 谁花了多少钱 买了 多少股票？？
*
* 01.减钱
* 02.加股
* @throws BuyStockException
*/
@Transactional(rollbackFor=BuyStockException.class,isolation=Isolation.DEFAULT,propagation=Propagation.REQUIRED)
@Override
public void buyStock(String name, double money, Integer amount) throws BuyStockException {
//银行账户减钱
accountDao.updateAccount(name, money);
if(1==1){ //模拟异常
throw new BuyStockException("！！！购买股票失败.......");
}
stockDao.updateStock(name, amount);
} public StockDao getStockDao() {
return stockDao;
} public void setStockDao(StockDao stockDao) {
this.stockDao = stockDao;
} public AccoutDao getAccountDao() {
return accountDao;
} public void setAccountDao(AccoutDao accountDao) {
this.accountDao = accountDao;
} }
/**
* 自定义异常类
*/
public class BuyStockException extends Exception { public BuyStockException(String msg){
super(msg);
}
}
05.创建applicationContext.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:c="http://www.springframework.org/schema/c"
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/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd
"> <!-- 01.spring默认的数据源
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql:///spring"/>
<property name="username" value="t11"/>
<property name="password" value="t11"/>
</bean> --> <!-- 02.dbcp数据源
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql:///spring"/>
<property name="username" value="t11"/>
<property name="password" value="t11"/>
</bean>-->
<!-- 加载配置文件 数据库需要的4要素 -->
<context:property-placeholder location="classpath:jdbc.properties"/> <!-- 03.c3p0数据源 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverClass" value="${jdbc.driver}"/>
<property name="jdbcUrl" value="${jdbc.url}"/>
<property name="user" value="${jdbc.userName}"/>
<property name="password" value="${jdbc.password}"/>
</bean> <!-- 配置stockDao -->
<bean id="stockDao" class="cn.bdqn.dao.impl.StockDaoImpl" p:dataSource-ref="dataSource"/>
<!-- 配置accountDao -->
<bean id="accountDao" class="cn.bdqn.dao.impl.AccountDaoImpl" p:dataSource-ref="dataSource"/> <!-- 配置stockService -->
<bean id="stockService" class="cn.bdqn.service.impl.StockServiceImpl"
p:accountDao-ref="accountDao" p:stockDao-ref="stockDao"/> <!-- ==================================事务的配置=========================================-->
<!-- 配置事务管理器 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"></property>
</bean> <!-- 03.使用注解管理事务 -->
<tx:annotation-driven transaction-manager="transactionManager"/> <!-- 01.使用代理工厂管理事务 -->
<!-- <bean id="serviceProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
<property name="transactionManager" ref="transactionManager"/>绑定事务管理器
<property name="target" ref="stockService"/> 声明需要代理的bean
<property name="transactionAttributes">
<props>在指定的切入点上配置事务属性
<prop key="open*">ISOLATION_DEFAULT,PROPAGATION_REQUIRED</prop>
-：发生异常回滚 +：发生异常提交
<prop key="buyStock">ISOLATION_DEFAULT,PROPAGATION_REQUIRED,-BuyStockException</prop>
</props>
</property>
</bean> --> <!-- 02.使用AspectJ来管理事务
切入点的匹配表达式
public * addStock(Stock stock) : * 代表匹配所有的返回值类型
public void *(Stock stock) : * 代表匹配所有没有返回值的方法
public void addStock(..) : .. 匹配所有的参数以及类型
* cn.bdqn.service.*.*(..) : 匹配cn.bdqn.service包下所有类的所有方法
* cn.bdqn.service..*(..) : 匹配cn.bdqn.service包以及子包下所有类的所有方法
* *..service.*.*(..) : 匹配包名有service的包下所有类的所有方法 ！！常用！！
--> <!-- <tx:advice id="txAdvice" transaction-manager="transactionManager">绑定事务管理器
在连接点的方法上进行事务的属性配置
<tx:attributes>
<tx:method name="open*" isolation="DEFAULT" propagation="REQUIRED"/>
<tx:method name="buyStock" isolation="DEFAULT" propagation="REQUIRED" rollback-for="BuyStockException"/>
</tx:attributes>
</tx:advice> 指定切入点
<aop:config>
<aop:pointcut expression="execution(* *..service.*.*(..))" id="myPoint"/>
<aop:advisor advice-ref="txAdvice" pointcut-ref="myPoint"/>
</aop:config> --> </beans>
06.创建对应的测试类
public class StockTest {
public static void main(String[] args) throws BuyStockException {
ApplicationContext context =new ClassPathXmlApplicationContext("applicationContext.xml");
StockService service=(StockService) context.getBean("stockService");
//service.openAccount("小猪", 5000);service.openStock("小猪", 20);
service.buyStock("小猪", 250, 1);
}
// 01.使用代理工厂 管理事务
@Test
public void testProxy() throws BuyStockException{
ApplicationContext context =new ClassPathXmlApplicationContext("applicationContext.xml");
StockService service=(StockService) context.getBean("serviceProxy");
service.buyStock("小猪", 250, 1);
}
// 02.使用AspectJ 和注解
@Test
public void testAop() throws BuyStockException{
ApplicationContext context =new ClassPathXmlApplicationContext("applicationContext.xml");
StockService service=(StockService) context.getBean("stockService");
service.buyStock("小猪", 250, 1);
}
}
public class ReadeMe {
/**
* 事务：一个或者一组sql语句来完成一个功能！
* 事务具有的四个特性： ACID特性！
* 01.原子性：一个事物都是一个不可分割的单位！所有的操作 要么都执行，要么都不执行！
* 02.一致性：事务必须是数据库从一个一致性的状态到达另一个一致性的状态！
* 03.隔离性：一个事务的执行不会被其他的事务干扰！事务之间相互独立！
* 04.持久性：事务一旦被提交！这个操作对数据库来说是永久性的！
*
*
* Spring的事务管理：
* 事务本事是数据库中的概念！ 按理说应该在数据访问层（dao）！
*
* 绝大多数的情况下，我们是把事务 提升到 业务逻辑层！
* 01.使用spring的事务代理工厂 来 管理事务！
* 02.使用spring的注解 来 管理事务！ 常用
* 03.使用AspectJ的AOP配置 来 管理事务！ 常用
*
* 需要掌握的两个属性名：
*
* isolation：事务的隔离级别！
* 01.default：采用数据库默认的事务隔离级别
* 001.mysql ---》repeatable-read
* 002.oracle---》read_committed
* 02. repeatable-read:可重复读取！解决了脏读，不可重复读，没解决幻读！
* 03. read_committed：读已提交！ 解决了脏读，没解决不可重复读，幻读！
* 04. read_uncommitted：读未提交！什么都没有解决！
* 05. serializable：串行化！级别最高！效率最低！不存在并发的问题！
*
*
* propagation: 事务的传播行为：一共7中方式！
* 01.required：是spring默认的事务传播行为！
* 指定的方法必须在事务中执行！如果没有事务，则会自动创建一个事务！
* 02.supports:有事务就在事务环境下执行，没有事务就直接执行！
* 03.mandatory:
* 指定的方法必须在事务中执行！如果没有事务，则抛出异常！
* 04.requires_new:总是新创建一个事务！
* 如果当前方法存在事务，则把当前的事务挂起，直到新创建的事务执行完毕后执行！
* 05.not_supported:指定的方法不能在事务中执行！如果当前方法存在事务，则把当前的事务挂起！
* 06.never:指定的方法不能在事务中执行！如果当前方法存在事务，则抛出异常！
* 07.nested:指定的方法必须在事务内执行！
* 如果执行的方法没有事务，则会创建一个事务！
* 如果执行的方法没有事务，则会嵌套执行！
*
* timeout_default:定义了事务默认的超时时间！
*
*
* Spring事务管理的接口：PlatformTransactionManager
* 常用的两个实现类：
* 01.使用jdbc和MyBatis时 使用DataSourceTrancationManager
* 02.使用hibernate时 使用HibernateTrancationManager
*
* Spring事务回滚的方式：
* 默认的回滚方式--》发生运行时异常回滚！发送受查异常时提交！
* 受查异常肯定需要我们手动的设置回滚方式！
* 运行时异常严重！一旦发生，JVM中止执行！
*
* 实现自定义异常类！RuntimeException --> Exception ---> Throwable
*
*/
}