public interface UserService {  public String getName(int id);  public Integer getAge(int id);
}

public class UserServiceImpl implements UserService {  @Override  public String getName(int id) {  System.out.println("------getName------");  return "Tom";  }  @Override  public Integer getAge(int id) {  System.out.println("------getAge------");  return 10;  }
}

               if (object.getClass().getPackage().getName().equals("")) {ConnectionDynamicProxy connectionDynamicProxy = new ConnectionDynamicProxy();connectionDynamicProxy.setTarget(object);//daili objectObject proxyObject = Proxy.newProxyInstance(object.getClass().getClassLoader(),object.getClass().getInterfaces(), connectionDynamicProxy);return proxyObject;}

public class ConnectionDynamicProxy implements InvocationHandler{private Object target;public void setTarget(Object target) {this.target = target;}@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {Object result = null;boolean needMyClose = false;Connection   conn = (Connection) AppContext.getAppContext().getObject("APP_REQUEST_THREAD_CONNECTION");if (conn == null) {conn = DBUtil.getConnection();needMyClose = true;AppContext.getAppContext().addObject("APP_REQUEST_THREAD_CONNECTION",conn);}try {result = method.invoke(target, args);} finally {if (needMyClose) {conn = (Connection) AppContext.getAppContext().getObject("APP_REQUEST_THREAD_CONNECTION");DBUtil.close(conn, null, null);AppContext.getAppContext().removeObject("APP_REQUEST_THREAD_CONNECTION");conn = null;}}return result;}}

代理对象

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.sql.Connection;import com.augmentum.oes.util.DBUtil;public class ConnectionDynamicProxy implements InvocationHandler{private Object target;public void setTarget(Object target) {this.target = target;}@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {Object result = null;boolean needMyClose = false;boolean isCommitOrRollbackTran =  false;ConnectionHolder   connectionHolder = (ConnectionHolder) AppContext.getAppContext().getObject("APP_REQUEST_THREAD_CONNECTION");if (connectionHolder == null) {connectionHolder = new ConnectionHolder();Connection conn = DBUtil.getConnection();connectionHolder.setConn(conn);if (method.getName().equals("add")) {DBUtil.setAutoCommit(conn, false);connectionHolder.setStartTran(true);isCommitOrRollbackTran = true;}AppContext.getAppContext().addObject("APP_REQUEST_THREAD_CONNECTION",connectionHolder);needMyClose = true;} else {if (method.getName().equals("add")) {if(!connectionHolder.isStartTran()) {connectionHolder.setStartTran(true);DBUtil.setAutoCommit(connectionHolder.getConn() , false);isCommitOrRollbackTran = true;}}}try {result = method.invoke(target, args);if (method.getName().equals("add")) {if (isCommitOrRollbackTran) {DBUtil.commit(connectionHolder.getConn());}}} catch (Throwable throwable) {if (method.getName().equals("add")) {if (isCommitOrRollbackTran) {DBUtil.rollback(connectionHolder.getConn());}}throw throwable;} finally {if (needMyClose) {connectionHolder = (ConnectionHolder) AppContext.getAppContext().getObject("APP_REQUEST_THREAD_CONNECTION");DBUtil.close(connectionHolder.getConn(), null, null);AppContext.getAppContext().removeObject("APP_REQUEST_THREAD_CONNECTION");connectionHolder.setConn(null);connectionHolder = null;}}return result;}}

package com.augmentum.oes.common;import java.sql.Connection;public class ConnectionHolder {private Connection conn;private boolean isStartTran = false;public Connection getConn() {return conn;}public void setConn(Connection conn) {this.conn = conn;}public boolean isStartTran() {return isStartTran;}public void setStartTran(boolean isStartTran) {this.isStartTran = isStartTran;}}

ConnectionHolder

public class SayHello {  public void say(){  System.out.println("hello everyone");  }
}

public class CglibProxy implements MethodInterceptor{  private Enhancer enhancer = new Enhancer();  public Object getProxy(Class clazz){  //设置需要创建子类的类  enhancer.setSuperclass(clazz);  enhancer.setCallback(this);  //通过字节码技术动态创建子类实例  return enhancer.create();  }  //实现MethodInterceptor接口方法  public Object intercept(Object obj, Method method, Object[] args,  MethodProxy proxy) throws Throwable {  System.out.println("前置代理");  //通过代理类调用父类中的方法  Object result = proxy.invokeSuper(obj, args);  System.out.println("后置代理");  return result;  }
}

public class DoCGLib {  public static void main(String[] args) {  CglibProxy proxy = new CglibProxy();  //通过生成子类的方式创建代理类  SayHello proxyImp = (SayHello)proxy.getProxy(SayHello.class);  proxyImp.say();  }
}

前置代理
hello everyone
后置代理

关闭事务自动提交   public static void setAutoCommit(Connection conn, boolean autoCommit) {try {conn.setAutoCommit(autoCommit);} catch (SQLException e) {e.printStackTrace();throw new DBException();}}

同一事务代码块

提交事务  commit
catch  调用public void rollback(Connection conn) {try {conn.rollback();} catch (SQLException e) {e.printStackTrace();throw  new DBException();}}

    <!-- add Transation Manger --><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"></property><!-- start  Transation annoation -->  加入这个时可以直接使用注解@Transctional<tx:annotation-driven transaction-manager="transactionManager"/></bean><tx:advice id="txAdvice" transaction-manager="transactionManager"><tx:attributes><tx:method name="update" propagation="REQUIRED" read-only="false"/><tx:method name="deleteById" propagation="REQUIRED" read-only="false"/><tx:method name="getNextId" propagation="REQUIRED" read-only="false"/><tx:method name="addUpdate" propagation="REQUIRED" read-only="false"/><tx:method name="*" propagation="SUPPORTS" read-only="true"/></tx:attributes></tx:advice><aop:config><aop:pointcut expression="execution(* com.augmentum.oes.service..*.*(..))" id="pc"/><aop:advisor pointcut-ref="pc" advice-ref="txAdvice" order="1"/></aop:config>