zoukankan html css js c++ java

Spring事务

实现购买股票案例：

一、引入JAR文件：

二、开始搭建分层架构---创建账户(Account)和股票(Stock)实体类

Account:

Stock：

三、创建Dao层，定义账户以及股票的接口，自定义新增和修改的方法，实现类实现该接口，重写方法　　

IAccountDao：

IStockDao：　　

AccountDaoImpl:实现类。继承自JdbcDaoSupport并实现IAccountDao接口，在这里需要用到JDBC模板的getJdbcTemplate()，通过该方法实现对SQL语句增删改查。

 public void updateAccount(int aid, int abalance,boolean isBuy) {
        String sql=null;
        if(isBuy){
            //购买股票
sql="update account set balance=balance-? where aid=?";
        }else{
            //出售股票
sql="update account set balance=balance+? where aid=?";
        }

        int update = this.getJdbcTemplate().update(sql,abalance,aid);
    }
}

StockDaoImpl：实现类同理

public class StockDAOImpl extends JdbcDaoSupport implements IStockDAO {
    public void updateStock(int sid, int scount,boolean isBuy) {
        String sql=null;
        if(isBuy){
            //购买股票
sql="update Stock set count=count+? where sid=?";
        }else{
            //出售股票
sql="update Stock set count=count-? where sid=?";
        }
        int update = this.getJdbcTemplate().update(sql,scount,sid);
    }
}

四、业务逻辑层：service　　

定义接口IStockService,并实现添加账户，股票，以及购买股票的方法.购买股票需要传入账户的id,股票的id。以及金额，股数

public interface IStockService {
       //添加账户
    public int addAccount(Account account);
    //添加股票
    public int addStock(Stock stock);
     
    //购买股票
    public void buyStock(int aid,int money,int sid,int num) throws StockException;
}

实现类：StockServiceImpl。重写方法。并植入Dao。以及自定义StockException异常，用于判定用户的余额小于0，抛出异常

   public void buyStock(int aid, int abalance, int sid, int scount) throws StockException {
        //购买股票 买入 和抛出

boolean isBuy=true;//   默认为购买股票

accountDAO.updateAccount(aid,abalance,isBuy);  //账户有关

       /* int result=5/0;*/
if (true) {
            throw new StockException();

        }
           stockDAO.updateStock(sid, scount, isBuy);       //股票有关


}
}

五、Spring配置文件。[重点]

方式一:通过事务代理工厂bean进行配置[XML方式]

①引入一系列的约束头文件以及标签

②配置C3P0数据源以及DAO、Service　　

③配置事务管理器以及事务代理工厂Bean。测试类getBean获取的是代理工厂id

方式二：注解。测试类getBean获取的id是原始对象service

<!-- 注解 -->
  <tx:annotation-driven transaction-manager="mytx"/>

方式三：Aspectj AOP配置事务。同理测试类getBean方法id获取的是原始对象

测试类：

@Test
public void test04(){
    ApplicationContext context=new ClassPathXmlApplicationContext("applicationContext22.xml");
    IStockService service= (IStockService) context.getBean("stockServiceProxy");

   /* service.buyStock(3,2000,35,20);*/

try {
        service.buyStock(3,2000,35,20);
    }catch (Exception ex) {
        ex.printStackTrace();
    }
}