以下程式碼通過了編譯，可以直接執行（需要更改包名）

目的： 通過Spring AOP實現對service的transfer(轉賬)操作增加事務處理。

• 增強類MyAdvice

package com.bamzhy.advice;

import com.bamzhy.utils.MyC3P0DataSouce;
import com.bamzhy.utils.TransactionManagement;
import org.aopalliance.intercept.MethodInterceptor;
import org.aopalliance.intercept.MethodInvocation
 
;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;

import java.sql.Connection;
import java.sql.SQLException;

@Aspect
@Component
public class MyAdvice  {

    //設定好增強點
    @Pointcut("execution (public boolean com.bamzhy.service.UserServiceImpl.transfer(..)) throws java.sql.SQLException )"
 
)
    private void myPointCut(){
    }

    //around方法
    @Around("myPointCut()")
    public Object around(ProceedingJoinPoint joinPoint) throws Throwable {
        Object proceed=null;
        boolean ret=false;
        Connection connection=null;
        try{
            connection= MyC3P0DataSouce.getConnection
 
();
            //開啟事務
            connection.setAutoCommit(false);
            //這裡是核心
            proceed=joinPoint.proceed();
            connection.commit();
            connection.close();
            ret=true;
            System.out.println("這裡是增強程式碼");
        }catch (Exception e){
            e.printStackTrace();
            if(connection!=null){
                try{
                    connection.rollback();
                }catch (SQLException e1){
                    e1.printStackTrace();
                }
            }
        }
        return proceed;
    }
}

• 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:aop="http://www.springframework.org/schema/aop"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <!--設定掃描的包名-->
    <context:component-scan base-package="com.bamzhy"/>
    <aop:aspectj-autoproxy />
</beans>

• service層

package com.bamzhy.service;

import com.bamzhy.bean.Account;
import com.bamzhy.dao.UserDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.sql.SQLException;

//service層，例項化時getBean呼叫這個id
@Service("service")
public class UserServiceImpl implements UserService {
    public void setUserDao(UserDao userDao) {
        this.userDao = userDao;
    }
    //自動去UserDao和其子類中(@Repository)尋找例項化物件並注入
    @Autowired
    private UserDao userDao;

    @Override
    public boolean transfer(String usernameFrom, String usernameTo, int money) throws SQLException {
        Account accountFrom = userDao.getAccount(usernameFrom);
        Account accountTo = userDao.getAccount(usernameTo);
        accountFrom.setMoney(accountFrom.getMoney()-money);
        accountTo.setMoney(accountTo.getMoney()+money);
        if (!userDao.updateAccount(accountFrom))
            return false;
        //int i = 1/0;
        if (!userDao.updateAccount(accountTo))
            return false;
        return true;
    }
}

• dao層

package com.bamzhy.dao;

import com.bamzhy.bean.Account;
import com.bamzhy.utils.TransactionManagement;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.springframework.stereotype.Repository;

import java.sql.SQLException;

//Dao層
@Repository
public class UserDaoImpl implements UserDao {
    @Override
    public boolean updateAccount(Account account) throws SQLException {
        QueryRunner queryRunner=new QueryRunner();
        String sql="update homework set money = ? where username = ?;";
        //public int update(Connection conn, String sql, Object... params)
        int update = queryRunner.update(TransactionManagement.getConnection(),sql,account.getMoney(), account.getUsername());
        return update==1?true:false;
    }

    @Override
    public Account getAccount(String username) throws SQLException {
        QueryRunner queryRunner=new QueryRunner();
        String sql="select * from homework where username = ?;";
        Account query = queryRunner.query(TransactionManagement.getConnection(), sql, new BeanHandler<Account>(Account.class), username);
        return query;
    }
}

• test檔案

package com.bamzhy.test;
import com.bamzhy.service.UserService;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.sql.SQLException;

public class test {
    @Test
    public void test1() throws SQLException {
        ApplicationContext applicationContext=new ClassPathXmlApplicationContext("applicationContext.xml");
        UserService service = (UserService) applicationContext.getBean("service");
        service.transfer("haha1","haha2",1000);
    }
}