我对SpringDAO层支持的总结

jinnianshilongnian

浏览: 21513853 次
性别:

博主相关

博客

微博

相册

留言

关于我

博客专栏

: 跟我学spring3
浏览量：2420496

: Spring杂谈
浏览量：3010253

: 跟开涛学SpringMVC...
浏览量：5640605

: Servlet3.1规范翻...
浏览量：260219

: springmvc杂谈
浏览量：1597951

: hibernate杂谈
浏览量：250370

: 跟我学Shiro
浏览量：5860609

: 跟我学Nginx+Lua开...
浏览量：702885

: 亿级流量网站架构核心技术
浏览量：785756

文章分类

社区版块

我的资讯 ( 10)
我的论坛 ( 1112)
我的问答 ( 2428)

存档分类

博客分类：

spring杂谈

之前发过两篇关于Spring的总结帖子反响还不错，再把剩下的几篇发上来。共享给大家。

我对AOP的理解

1、问题

1、JDBC/ORM框架（如Hibernate）开发中编程模型有哪些缺点？如JDBC

2、解决方案（模板设计模式，本质：将可变的和不可变的分离）

模板方法模式：定义操作的步骤（固定的），将可变的步骤交给子类处理。

public interface JdbcOperations {
    //接口定义行为集
    public Object execute() throws SQLException ;
}

public abstract class AbstractJdbcOperations implements JdbcOperations {
    @Override
    public final Object execute() throws SQLException {
       Connection conn = DataSourceUtils.getConnection();
        try {
            Object retVal = doInConnection(conn);
            conn.commit();
            return retVal;
        }catch (Exception e) {   conn.rollback(); throw e;}
        finally {                          conn.close(); }
    }
    public abstract Object doInConnection(Connection conn) throws SQLException;
}

public class DataSourceUtils {
    public static Connection getConnection() {
        //返回数据库连接
        return null;
    }
}

  JdbcOperations select = new AbstractJdbcOperations() {
           @Override
            public Object doInConnection(Connection conn) throws SQLException {
                PreparedStatement pstmt = 
                    conn.prepareStatement("select * from tbl_user");
                ResultSet rs = pstmt.executeQuery();
                List result = null;
                //处理结果集
                return result;
            }
        };
        select.execute();

缺点：不够灵活

3、解决方案（模板设计模式+回调，本质：将可变的和不可变的分离，可变通过回调）

回调（命令）：由组件定义，但不由组件调用，而是由系统调用

一般用于：可变不可变分离，未知功能。

public interface JdbcOprations2 {
    //接口定义行为集
    public Object execute(ConnectionCallback callback) throws Exception ;

}

public interface ConnectionCallback {
    public Object doInConnection(Connection conn) throws SQLException;
}

public class JdbcTemplate implements JdbcOprations2 {
    @Override
    public Object execute(ConnectionCallback callback) throws Exception {
        Connection conn = DataSourceUtils.getConnection();
        try {
            Object retVal = callback.doInConnection(conn);
            conn.commit();
            return retVal;
        }
        catch (Exception e) {
            conn.rollback();
            throw e;
        }
        finally {
            conn.close();
        }
    }    
}

jdbcTemplate.execute(new ConnectionCallback() {
            
            @Override
            public Object doInConnection(Connection conn) throws SQLException {
                //可变操作
                return null;
            }
        });

public interface PreparedStatementCallback {
    public Object doInPreparedStatement(PreparedStatement pstmt) 
        throws  SQLException;
}

缺点：灵活但不通用

4、解决方案（Spring JDBC框架）

JdbcTemplate jdbcTemplate = new JdbcTemplate(ds);

5、异常问题

JDBC/ORM框架（如Hibernate）开发中异常处理有哪些缺点？不一致的异常类，如JDBC是SQLException 而hibernate是HibernateException，等。

缺点：不一致的异常体系，需要了解每个框架的异常含义，Spring的一致的异常体系（DataAccessException）

6、DAO访问问题

访问JDBC和访问Hibernate使用完全不同且根本不类似的API？

为了便于以一种一致的方式使用各种数据访问技术，如JDBC、JDO和Hibernate，

Spring提供了一套抽象DAO类供你扩展。

JdbcDaoSupport - JDBC数据访问对象的基类。

需要一个DataSource，同时为子类提供 JdbcTemplate。

HibernateDaoSupport - Hibernate数据访问对象的基类。

需要一个SessionFactory，同时为子类提供 HibernateTemplate。

JdoDaoSupport - JDO数据访问对象的基类。

需要设置一个PersistenceManagerFactory，同时为子类提供JdoTemplate。

JpaDaoSupport - JPA数据访问对象的基类。

需要一个EntityManagerFactory，同时为子类提供JpaTemplate。

一致的DAO抽象

Callback：定义可变行为，即不可预知行为(命令设计模式)

Template：提供模板支持，简化开发Support：提供对Template的支持，提供一组简便方法，并提供获取Template的方法

【第七章】对JDBC的支持之 7.1 概述 ——跟我学spring3

【第七章】对JDBC的支持之 7.2 JDBC模板类 ——跟我学spring3

【第七章】对JDBC的支持之 7.3 关系数据库操作对象化 ——跟我学spring3

【第七章】对JDBC的支持之 7.4 Spring提供的其它帮助 ——跟我学spring3【私塾在线原创】

【第七章】对JDBC的支持之 7.5 集成Spring JDBC及最佳实践 ——跟我学spring3

【第八章】对ORM的支持之 8.1 概述 ——跟我学spring3

【第八章】对ORM的支持之 8.2 集成Hibernate3 ——跟我学spring3

【第八章】对ORM的支持之 8.3 集成iBATIS ——跟我学spring3

【第八章】对ORM的支持之 8.4 集成JPA ——跟我学spring3

13
顶

4
踩

分享到：

我对Spring 容器管理事务支持的总结 | SpringMVC3强大的请求映射规则详解第六 ...

2012-09-26 17:32
浏览 24967
评论(10)
分类:企业架构
查看更多

10 楼 jinnianshilongnian 2012-12-06

http://jinnianshilongnian.iteye.com/blog/1487235你看下这个

9 楼 yangpeihai 2012-12-06

yangpeihai 写道

jinnianshilongnian 写道

yangpeihai 写道

哥们，请教个问题，为什么spring使用cglib动态代理没法拦截被代理类的所有非private方法，而我自己写的由cglib生成的代理类却可以拦截到被代理类的所有非private方法呢？，先道声谢谢，下面贴代码：

1. 注解类，用来注解哪些方法需要写日志

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface MyLog {

}

2. 工厂类,由cglib生成被代理对象

public class ProxyFactory {
	private final static Callback DEFAULT_CALLBACK = new DefaultCallback();
	private final static Log log = LogFactory.getLog(ProxyFactory.class);
	public static <T> T newInstance(Class<T> clazz) {
		return newInstance(clazz, DEFAULT_CALLBACK);
	}

	@SuppressWarnings("unchecked")
	public static <T> T newInstance(Class<T> clazz, Callback callback) {
		Enhancer enhancer = new Enhancer(); 
		enhancer.setSuperclass(clazz); 
		enhancer.setCallback(callback); 
		return (T) enhancer.create();
	}

	private static class DefaultCallback implements MethodInterceptor {
		@Override
		public Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable {
			Object result = null;
			
			//只有标志了MyLog的方法才写日志
			boolean flag = method.isAnnotationPresent(MyLog.class);
			if(flag){
				log.debug("Method: " + method.toGenericString());
				log.debug("params: " + JSON.toJSONString(args)); 
			}
			
			// 调用方法
			result = proxy.invokeSuper(obj, args);
			
			if(flag){ 
				log.debug("result：" + JSON.toJSONString(result));
			}
			return result;
		}

	}

}

3.被代理的类

public class Student {

	public Student() { 
	}

	public static Student newProxyInstance() { 
		return ProxyFactory.newInstance(Student.class); 
	}

	@MyLog
	public String doWork1(String name, int age) {  
		return doWork2(name,age); 
	} 

	@MyLog
	String doWork2(String name, int age) {  
		return doWork3(name,age); 
	} 

	@MyLog
	protected String doWork3(String name, int age) {  
		  return doWork4(name,age); 
	}

	@MyLog
	private String doWork4(String name, int age) {  
		return "姓名: " + name + ", 年龄: " + age; 
	} 
}

4.测试类

public class Test { 
	public static void main(String[] args) {
		Student stu = Student.newProxyInstance();
		stu.doWork1("Xiao Zhang", 22);
	}

}

5.结果输出：

[12/06 14:47:52] [DEBUG] ProxyFactory: Method: public java.lang.String test.log.Student.doWork1(java.lang.String,int)
[12/06 14:47:52] [DEBUG] ProxyFactory: params: ["Xiao Zhang",22]
[12/06 14:47:52] [DEBUG] ProxyFactory: Method: java.lang.String test.log.Student.doWork2(java.lang.String,int)
[12/06 14:47:52] [DEBUG] ProxyFactory: params: ["Xiao Zhang",22]
[12/06 14:47:52] [DEBUG] ProxyFactory: Method: protected java.lang.String test.log.Student.doWork3(java.lang.String,int)
[12/06 14:47:52] [DEBUG] ProxyFactory: params: ["Xiao Zhang",22]
[12/06 14:47:52] [DEBUG] ProxyFactory: result："姓名: Xiao Zhang, 年龄: 22"
[12/06 14:47:52] [DEBUG] ProxyFactory: result："姓名: Xiao Zhang, 年龄: 22"
[12/06 14:47:52] [DEBUG] ProxyFactory: result："姓名: Xiao Zhang, 年龄: 22"

如果把被代理类放到spring里面，则只能拦截到方法doWork1，其他方法拦截不到，为什么会有这种差异？

spring内部实现的问题
可以看看我之前回复的
http://www.iteye.com/topic/1125911#2368327

回答神速啊，拜读啦。。。
里面有个问题，他那个setSelf(ServiceA self)是怎么注入的

    public void setSelf(ServiceA self) {  
        this.self = self;  
    }

我在我自己的Service直接用@Autowired报错，代码片段如下

public class UserService extends BaseService{

	private UserService self;
	 
	@Autowired
	public void setSelf(UserService self) {
		this.self = self;
	}

没找到匹配类型！错误信息：

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'studentController': Injection of autowired dependencies failed; nested exception is org.springframework.beans.factory.BeanCreationException: Could not autowire field: private com.oy.service.UserService com.oy.controller.StudentController.userService; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'userService': Injection of autowired dependencies failed; nested exception is org.springframework.beans.factory.BeanCreationException: Could not autowire method: public void com.oy.service.UserService.setSelf(com.oy.service.UserService); nested exception is org.springframework.beans.factory.NoSuchBeanDefinitionException: No matching bean of type [com.oy.service.UserService] found for dependency: expected at least 1 bean which qualifies as autowire candidate for this dependency. Dependency annotations: {}
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessPropertyValues(AutowiredAnnotationBeanPostProcessor.java:285)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1074)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:517)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456)

其实我要说的意思是这里的setSelf是类，而不是接口，这样可以吗？我尝试了，如果是类会报错，接口没问题。

8 楼 yangpeihai 2012-12-06

jinnianshilongnian 写道

yangpeihai 写道

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface MyLog {

}

2. 工厂类,由cglib生成被代理对象

public class ProxyFactory {
	private final static Callback DEFAULT_CALLBACK = new DefaultCallback();
	private final static Log log = LogFactory.getLog(ProxyFactory.class);
	public static <T> T newInstance(Class<T> clazz) {
		return newInstance(clazz, DEFAULT_CALLBACK);
	}

	@SuppressWarnings("unchecked")
	public static <T> T newInstance(Class<T> clazz, Callback callback) {
		Enhancer enhancer = new Enhancer(); 
		enhancer.setSuperclass(clazz); 
		enhancer.setCallback(callback); 
		return (T) enhancer.create();
	}

	private static class DefaultCallback implements MethodInterceptor {
		@Override
		public Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable {
			Object result = null;
			
			//只有标志了MyLog的方法才写日志
			boolean flag = method.isAnnotationPresent(MyLog.class);
			if(flag){
				log.debug("Method: " + method.toGenericString());
				log.debug("params: " + JSON.toJSONString(args)); 
			}
			
			// 调用方法
			result = proxy.invokeSuper(obj, args);
			
			if(flag){ 
				log.debug("result：" + JSON.toJSONString(result));
			}
			return result;
		}

	}

}

3.被代理的类

public class Student {

	public Student() { 
	}

	public static Student newProxyInstance() { 
		return ProxyFactory.newInstance(Student.class); 
	}

	@MyLog
	public String doWork1(String name, int age) {  
		return doWork2(name,age); 
	} 

	@MyLog
	String doWork2(String name, int age) {  
		return doWork3(name,age); 
	} 

	@MyLog
	protected String doWork3(String name, int age) {  
		  return doWork4(name,age); 
	}

	@MyLog
	private String doWork4(String name, int age) {  
		return "姓名: " + name + ", 年龄: " + age; 
	} 
}

4.测试类

public class Test { 
	public static void main(String[] args) {
		Student stu = Student.newProxyInstance();
		stu.doWork1("Xiao Zhang", 22);
	}

}

spring内部实现的问题
可以看看我之前回复的
http://www.iteye.com/topic/1125911#2368327

回答神速啊，拜读啦。。。
里面有个问题，他那个setSelf(ServiceA self)是怎么注入的

    public void setSelf(ServiceA self) {  
        this.self = self;  
    }

我在我自己的Service直接用@Autowired报错，代码片段如下

public class UserService extends BaseService{

	private UserService self;
	 
	@Autowired
	public void setSelf(UserService self) {
		this.self = self;
	}

7 楼 jinnianshilongnian 2012-12-06

yangpeihai 写道

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface MyLog {

}

2. 工厂类,由cglib生成被代理对象

public class ProxyFactory {
	private final static Callback DEFAULT_CALLBACK = new DefaultCallback();
	private final static Log log = LogFactory.getLog(ProxyFactory.class);
	public static <T> T newInstance(Class<T> clazz) {
		return newInstance(clazz, DEFAULT_CALLBACK);
	}

	@SuppressWarnings("unchecked")
	public static <T> T newInstance(Class<T> clazz, Callback callback) {
		Enhancer enhancer = new Enhancer(); 
		enhancer.setSuperclass(clazz); 
		enhancer.setCallback(callback); 
		return (T) enhancer.create();
	}

	private static class DefaultCallback implements MethodInterceptor {
		@Override
		public Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable {
			Object result = null;
			
			//只有标志了MyLog的方法才写日志
			boolean flag = method.isAnnotationPresent(MyLog.class);
			if(flag){
				log.debug("Method: " + method.toGenericString());
				log.debug("params: " + JSON.toJSONString(args)); 
			}
			
			// 调用方法
			result = proxy.invokeSuper(obj, args);
			
			if(flag){ 
				log.debug("result：" + JSON.toJSONString(result));
			}
			return result;
		}

	}

}

3.被代理的类

public class Student {

	public Student() { 
	}

	public static Student newProxyInstance() { 
		return ProxyFactory.newInstance(Student.class); 
	}

	@MyLog
	public String doWork1(String name, int age) {  
		return doWork2(name,age); 
	} 

	@MyLog
	String doWork2(String name, int age) {  
		return doWork3(name,age); 
	} 

	@MyLog
	protected String doWork3(String name, int age) {  
		  return doWork4(name,age); 
	}

	@MyLog
	private String doWork4(String name, int age) {  
		return "姓名: " + name + ", 年龄: " + age; 
	} 
}

4.测试类

public class Test { 
	public static void main(String[] args) {
		Student stu = Student.newProxyInstance();
		stu.doWork1("Xiao Zhang", 22);
	}

}

spring内部实现的问题
可以看看我之前回复的
http://www.iteye.com/topic/1125911#2368327

6 楼 yangpeihai 2012-12-06

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface MyLog {

}

2. 工厂类,由cglib生成被代理对象

public class ProxyFactory {
	private final static Callback DEFAULT_CALLBACK = new DefaultCallback();
	private final static Log log = LogFactory.getLog(ProxyFactory.class);
	public static <T> T newInstance(Class<T> clazz) {
		return newInstance(clazz, DEFAULT_CALLBACK);
	}

	@SuppressWarnings("unchecked")
	public static <T> T newInstance(Class<T> clazz, Callback callback) {
		Enhancer enhancer = new Enhancer(); 
		enhancer.setSuperclass(clazz); 
		enhancer.setCallback(callback); 
		return (T) enhancer.create();
	}

	private static class DefaultCallback implements MethodInterceptor {
		@Override
		public Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable {
			Object result = null;
			
			//只有标志了MyLog的方法才写日志
			boolean flag = method.isAnnotationPresent(MyLog.class);
			if(flag){
				log.debug("Method: " + method.toGenericString());
				log.debug("params: " + JSON.toJSONString(args)); 
			}
			
			// 调用方法
			result = proxy.invokeSuper(obj, args);
			
			if(flag){ 
				log.debug("result：" + JSON.toJSONString(result));
			}
			return result;
		}

	}

}

3.被代理的类

public class Student {

	public Student() { 
	}

	public static Student newProxyInstance() { 
		return ProxyFactory.newInstance(Student.class); 
	}

	@MyLog
	public String doWork1(String name, int age) {  
		return doWork2(name,age); 
	} 

	@MyLog
	String doWork2(String name, int age) {  
		return doWork3(name,age); 
	} 

	@MyLog
	protected String doWork3(String name, int age) {  
		  return doWork4(name,age); 
	}

	@MyLog
	private String doWork4(String name, int age) {  
		return "姓名: " + name + ", 年龄: " + age; 
	} 
}

4.测试类

public class Test { 
	public static void main(String[] args) {
		Student stu = Student.newProxyInstance();
		stu.doWork1("Xiao Zhang", 22);
	}

}

5 楼 jinnianshilongnian 2012-12-05

yangpeihai 写道

哥们，请教个aop问题，如果使用cglib动态代理目标对象，是否可以拦截到目标对象的所有非private方法？请看下面：

下面是我的service代码片段

	
	[color=red]//公开的接口方法[/color]
	@AutoWriteLog
	public List findAll() {
		return test1("杨培海");
	}
 
	[color=red]//自己测试用的方法test1[/color]
	@AutoWriteLog
	public List test1(String arg){
		return test2(arg);
	}

	[color=red]//自己测试用的方法test2[/color]
	@AutoWriteLog
	List test2(String arg){
		return userDao.findAll();
	}

下面是我的application*.xml配置：

	<aop:aspectj-autoproxy proxy-target-class="true"/>
	<!-- 配置哪些类的方法需要进行事务管理 -->
	<aop:config proxy-target-class="true">
		 <aop:pointcut id="allManagerMethod" expression="execution(* com.oy.service.*.*(..))" />
		 <aop:advisor advice-ref="txAdvice" pointcut-ref="allManagerMethod" /> 
				
		<!-- 配置aspect切面类 -->
		<aop:aspect ref="aspect">
			<!-- 配置advice,即Aspect类中的logging()方法，这里采用在业务方法执行前进行拦截 --> 
			<!-- 	<aop:before method="logging" pointcut-ref="allManagerMethod" />
				<aop:after method="loggout" pointcut-ref="allManagerMethod" /> -->
				
			 	<aop:around pointcut-ref="allManagerMethod"  method="myPointCutTest"/> 
		</aop:aspect> 
	</aop:config>

调试时，被代理的类又出现CGLIB字样，说明是CGLIB动态代理生成的类

org.springframework.aop.framework.[color=red]Cglib[/color]2AopProxy$DynamicAdvisedInterceptor@ec596

现在问题是：接口方法findAll()访问时可以被拦截到，但是两个非接口测试方法调用时没有被拦截到，是不是我哪里配置少啦，指点下，多谢！

@AutoWriteLog
public List test1(String arg){
return test2(arg);
}
这样调用不行

原因见
http://jinnianshilongnian.iteye.com/blog/1487235

4 楼 yangpeihai 2012-12-05

哥们，请教个aop问题，如果使用cglib动态代理目标对象，是否可以拦截到目标对象的所有非private方法？请看下面：

下面是我的service代码片段

	
	[color=red]//公开的接口方法[/color]
	@AutoWriteLog
	public List findAll() {
		return test1("杨培海");
	}
 
	[color=red]//自己测试用的方法test1[/color]
	@AutoWriteLog
	public List test1(String arg){
		return test2(arg);
	}

	[color=red]//自己测试用的方法test2[/color]
	@AutoWriteLog
	List test2(String arg){
		return userDao.findAll();
	}

下面是我的application*.xml配置：

	<aop:aspectj-autoproxy proxy-target-class="true"/>
	<!-- 配置哪些类的方法需要进行事务管理 -->
	<aop:config proxy-target-class="true">
		 <aop:pointcut id="allManagerMethod" expression="execution(* com.oy.service.*.*(..))" />
		 <aop:advisor advice-ref="txAdvice" pointcut-ref="allManagerMethod" /> 
				
		<!-- 配置aspect切面类 -->
		<aop:aspect ref="aspect">
			<!-- 配置advice,即Aspect类中的logging()方法，这里采用在业务方法执行前进行拦截 --> 
			<!-- 	<aop:before method="logging" pointcut-ref="allManagerMethod" />
				<aop:after method="loggout" pointcut-ref="allManagerMethod" /> -->
				
			 	<aop:around pointcut-ref="allManagerMethod"  method="myPointCutTest"/> 
		</aop:aspect> 
	</aop:config>

调试时，被代理的类又出现CGLIB字样，说明是CGLIB动态代理生成的类

org.springframework.aop.framework.[color=red]Cglib[/color]2AopProxy$DynamicAdvisedInterceptor@ec596

现在问题是：接口方法findAll()访问时可以被拦截到，但是两个非接口测试方法调用时没有被拦截到，是不是我哪里配置少啦，指点下，多谢！

3 楼 gaiqiliang 2012-09-27

2 楼 jinnianshilongnian 2012-09-26

fatmonkey64 写道

跟进开涛哥

1 楼 fatmonkey64 2012-09-26

跟进开涛哥

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

博客专栏

文章分类

社区版块

存档分类

最新评论