测试Spring定时任务时在Dao层报空指针异常

痛定思痛。 2022-06-12 09:19 513阅读 0赞

断点调试代码走到Dao后报空指针异常，在Dao层的代码比较简单就在方法里一句：  
return this.findListBySqlId("findSqlByMap", paraMap);  
然后把框架封装的代码提取出来  
public List findListBySqlId(String sqlId, Map<?, ?> paraMap)  
    /\*     \*/   \{  
    /\* 195 \*/     List list = null;  
    System.out.println(getSession());  
    /\*     \*/     try \{  
    /\* 197 \*/       String hql = getSqlStatementById(sqlId, paraMap);  
    /\* 198 \*/       if (StringUtils.isNotBlank(hql)) \{  
    /\* 199 \*/         Query query = getSession().createSQLQuery(hql);  
    /\* 200 \*/         query.setCacheable(SysPropertiesUtil.getBoolean("use\_query\_cache", false));  
    /\* 201 \*/         setQueryParameters(query, paraMap);  
    /\* 202 \*/         list = query.list();  
    /\*     \*/       \} else \{  
    /\* 204 \*/         throw new BasalException(BasalException.ERROR, "未在 SqlMap配置文件中配置, ID为" + sqlId +   
    /\* 205 \*/           "hql 语句");  
    /\*     \*/       \}  
    /\*     \*/     \} catch (Exception e) \{  
    /\* 208 \*/       throw new BasalException(BasalException.ERROR, e.getCause().getMessage(), e.getCause());  
    /\*     \*/     \}  
    /\* 210 \*/     return list;  
    \}  
  
  
代码走到Query query = getSession().createSQLQuery(hql);后就被捕获异常，报NullPointException。  
怀疑是getSession()没有获取到session，所以报空指针，在这行代码前面加入System.out.println(getSession());再次测试。  
果然控制台报：  
org.hibernate.HibernateException: No Session found for current thread  
at org.springframework.orm.hibernate4.SpringSessionContext.currentSession(SpringSessionContext.java:106)  
at org.hibernate.internal.SessionFactoryImpl.getCurrentSession(SessionFactoryImpl.java:1014)  
at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)  
at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:711)  
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)  
at org.springframework.aop.aspectj.AspectJAfterThrowingAdvice.invoke(AspectJAfterThrowingAdvice.java:58)  
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)  
at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:85)  
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)  
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)  
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)  
at java.lang.reflect.Method.invoke(Method.java:606)  
at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:621)  
at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:610)  
at org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:68)  
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)  
at org.springframework.aop.framework.adapter.AfterReturningAdviceInterceptor.invoke(AfterReturningAdviceInterceptor.java:52)  
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)  
at org.springframework.aop.framework.adapter.MethodBeforeAdviceInterceptor.invoke(MethodBeforeAdviceInterceptor.java:52)  
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)  
at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)  
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)  
at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:644)  
at org.springframework.scheduling.quartz.QuartzJobBean.execute(QuartzJobBean.java:111)  
at org.quartz.core.JobRunShell.run(JobRunShell.java:202)  
at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:534)  
这样问题就比较清晰了，是由于Hibernate中无法获取到spring管理的session对象。  
一般可以通过注解和非注解的方式进行事务配置。  
Spring整合Hibernate配置  
  
<bean id="sessionFactory"  
class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">  
<property name="dataSource">  
<ref bean="dataSource" />  
</property>  
<property name="entityInterceptor">  
<ref local="hibernateInterceptor" />  
</property>   
<property name="hibernateProperties">  
<props>  
<prop key="hibernate.dialect">  
$\{db.Dialect.prefix\}.$\{db.Dialect.suffix\}  
</prop>  
<prop key="hibernate.query.substitutions">  
true '1', false '0'  
</prop>  
<prop key="hibernate.validator.apply\_to\_ddl">false</prop>   
                <prop key="hibernate.validator.autoregister\_listeners">false</prop>  
<prop key="hibernate.show\_sql">true</prop>  
<prop key="hibernate.use\_sql\_comments">true</prop>  
<prop key="hibernate.format\_sql">true</prop>  
<prop key="hibernate.hbm2ddl.auto">update</prop>  
<prop key="hibernate.cglib.use\_reflection\_optimizer">  
true  
</prop>  
<prop key="hibernate.current\_session\_context\_class">  
org.springframework.orm.hibernate4.SpringSessionContext  
</prop>  
<prop key="jdbc.use\_scrollable\_resultset">false</prop>  
<prop key="hibernate.cache.use\_query\_cache">true</prop>  
<prop key="hibernate.cache.use\_second\_level\_cache">  
true  
</prop>  
<prop key="hibernate.cache.region.factory\_class">  
org.hibernate.cache.ehcache.SingletonEhCacheRegionFactory  
</prop>  
<prop key="hibernate.cache.provider\_class">  
org.hibernate.cache.EhCacheProvider  
</prop>  
<prop  
key="hibernate.cache.provider\_configuration\_file\_resource\_path">  
classpath\*:/ehcache-hibernate.xml  
</prop>  
</props>  
</property>  
<property name="mappingJarLocations">  
<list>  
</list>  
</property>  
<property name="packagesToScan">  
<list>  
<value>com.test.\*.ntity</value>  
</list>  
</property>  
</bean>  
  
  
  
<bean id="transactionManager"  
class="org.springframework.orm.hibernate4.HibernateTransactionManager">  
<property name="sessionFactory" ref="sessionFactory" />  
<property name="nestedTransactionAllowed" value="true"></property>  
</bean>  
  
  
  
<tx:annotation-driven transaction-manager="transactionManager" />  
  
  
<bean id="txProxyTemplate" abstract="true" lazy-init="true"  
class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">  
<property name="transactionManager">  
<ref bean="transactionManager" />  
</property>  
<property name="transactionAttributes">  
<props>  
<prop key="\*">PROPAGATION\_REQUIRED</prop>  
</props>  
</property>  
</bean>  
  
  
然后在Service中的方法上添加@Transactional注解