Spring 手动达成aop管理事务

发布时间：2021-11-23 13:59:18 所属栏目：PHP教程来源：互联网

导读：1.事务的使用：每次对数据库操作我们都要beginTransaction，显然是不行的. (比如一个业务中多次操作数据库，但是当某个方法出错或是..我们需要回滚，但是每次操作我们都提交了;整体回滚不了，所以我们有些只能把它们绑定使用一个事务) 2.手动实现aop管理事

1.事务的使用：

每次对数据库操作我们都要beginTransaction，显然是不行的.

(比如一个业务中多次操作数据库，但是当某个方法出错或是..我们需要回滚，但是每次操作我们都提交了;整体回滚不了，

所以我们有些只能把它们绑定使用一个事务)

2.手动实现aop管理事务：

利用aop around环绕拦截。拦截方法(service中的一个业务方法)之前开启事务，之后再关闭；

package org.ymm.aops;

import org.aspectj.lang.ProceedingJoinPoint;
import org.hibernate.SessionFactory;
import org.ymm.entity.Users;

public class LoginAdvice {

    public SessionFactory sf;

    public SessionFactory getSf() {
        return sf;
    }

    public void setSf(SessionFactory sf) {
        this.sf = sf;
    }

    public Object around1(ProceedingJoinPoint pjp) throws Throwable{
        this.sf.getCurrentSession().beginTransaction();
        Object o = pjp.proceed();
        this.sf.getCurrentSession().getTransaction().commit();
        return o;
    }
}
sf 是spring接管hibernate的SessionFactory

<bean id="L_a" class="org.ymm.aops.LoginAdvice" >
        <property name="sf" ref="sFactory"></property>
     </bean>

    <aop:config>
        <aop:pointcut expression="execution(* org.ymm.services.LoginService.Login(..))" id="lg"/>

        <aop:aspect ref="L_a" id="my_la">
            <aop:around method="around1" pointcut-ref="lg"/>
        </aop:aspect>
    </aop:config>
services中被切的方法

package org.ymm.services;

import org.ymm.dao.IUsersDao;
import org.ymm.entity.Users;

public class LoginService implements ILoginService{

    public IUsersDao ud;

    public IUsersDao getUd() {
        return ud;
    }

    public void setUd(IUsersDao ud) {
        this.ud = ud;
    }

    public Users Login(String uname){
        ud.getAllUsers();//aop切面管理事务只是为了测试两个查询都用同一个事务
        return ud.findUserByUname(uname);
    }
}
方法中我们就不需开启事务

public Users findUserByUname(String uname) {
        // TODO Auto-generated method stub
        Session session= sf.getCurrentSession();
        /*session.beginTransaction();*/
        List<Users> list= session.createSQLQuery("select u.*,1 from users u where u.uname='"+uname+"'")
                .addEntity(Users.class).list();
        Users user=(Users)(list.get(0));
        return user;
    }
linux

（编辑：云计算网_泰州站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!

php批量命名文件技巧	php读取文件内容几种正
php中读取大文件实现方	php打开远程文件的方法