在整合完最新版的ssh后我测试用hibernate的getCurrentSession()取得Session后的save(),update()和delete()时,我发现页面上虽然能查出更新后的结果,但数据库里却未进行更新,而且后台未打印出sql语句,三个方法只有save()发出了insert语句,我原本以为是缓存问题,但清空缓存后还是一样,delete()和update()无法发出sql语句,这是为什么,我很奇怪,另外,我在更新和删除前先调用了load()把根据id把数据从数据库中查了出来,但只发出了select语句,随后执行update()和delete()却像没有作用一样,我把load()换成了get()也是一样的效果,求高人指点这到底是神马原因,为何发不出sql语句,万分感谢!
   另外,我的事务配置也做了,包括设置了aop:config和aop:advice,事务加在了service,但就是不能删除和修改数据库中的数据,也就是不能发出sql语句,但是select和insert却可以。求解释。
这是spring里关于事务的配置:
        <!-- 配置事务管理器 -->
        <bean id="txManager"
                class="org.springframework.orm.hibernate4.HibernateTransactionManager">
                <property name="sessionFactory" ref="sessionFactory"/>
        </bean>
                
        <tx:advice id="transactionAdvice" transaction-manager="txManager">
                <tx:attributes>
                        <tx:method name="save*" propagation="REQUIRED"/>
                        <tx:method name="update*" propagation="REQUIRED"/>
                        <tx:method name="delete*" propagation="REQUIRED" />
            <tx:method name="find*" propagation="SUPPORTS" />
            <tx:method name="*" propagation="REQUIRED" />
       </tx:attributes>        
    </tx:advice>
        <aop:config proxy-target-class="true">
                        <aop:advisor pointcut="execution(* com.tarena.service..*Impl.* (..))" advice-ref="transactionAdvice" />
        </aop:config>        
</beans>
这是我的DAO层相关代码:
@Repository("dao")
public class DaoImpl <T, PK extends Serializable>
implements DaoI<T,PK>{        private SessionFactory sessionFactory;
        
        @Autowired
        public void setSessionFactory(SessionFactory sessionFactory) {
                this.sessionFactory = sessionFactory;
        }        private Session getCurrentSession() {
                return this.sessionFactory.getCurrentSession();
        }
        
        @Override
        public void save(T entity) {
                this.getCurrentSession().save(entity);
        }        @Override
        public void update(T entity) {
                this.getCurrentSession().flush();
       this.getCurrentSession().update(entity);                
        }        @SuppressWarnings("unchecked")
        @Override
        public List<T> findAll(Class<T> entityClass) {
                String hql = "from " + entityClass.getName();
                return this.getCurrentSession().createQuery(hql).list();
        }        @Override
        public void delete(Class<T> entityClass, PK... pks) {
                for(PK pk:pks){
            this.getCurrentSession().flush();
                        this.getCurrentSession().delete(findEntity(entityClass,pk));
                }
        }        @Override
        public Pager<T> findByPage(Class<T> entityClass, String xql, int pageNo, int pageSize) {
                return findByPage(entityClass, xql, null, pageNo, pageSize);
        }        @Override
        public Pager<T> findByPage(Class<T> entityClass, String xql, Object key, int pageNo, int pageSize) {
                return findByPage(entityClass, xql, new Object[] { key }, pageNo,
                                pageSize);
        }        @SuppressWarnings("unchecked")
        @Override
        public Pager<T> findByPage(Class<T> entityClass, String xql, Object[] keys, int pageNo, int pageSize) {
                Pager<T> pager = new Pager<T>();
                Query query = getCurrentSession().createQuery(xql);
                if (keys != null && keys.length > 0) {
                        for (int i = 0; i < keys.length; i++) {
                                query.setParameter(i, keys);
                        }
                }
                query.setFirstResult(pageNo).setMaxResults(pageSize);
                List<T> pageList = query.list();
                int totalCount = getTotalNum(xql, keys);
                pager.setPageList(pageList);
                pager.setTotalCount(totalCount);
                return pager;
        }        private int getTotalNum(String xql, Object[] keys) {
                int totalNum = 0;
                int index = xql.indexOf("from");
                String from = xql.substring(index).trim();
                String hql = "select count(*) " + from;
                Query query = getCurrentSession().createQuery(hql);
                if (keys != null && keys.length > 0) {
                        for (int i = 0; i < keys.length; i++) {
                                query.setParameter(i, keys);
                        }
                }
                totalNum = ((Long) query.uniqueResult()).intValue();
                return totalNum;
        }        @SuppressWarnings("unchecked")
        @Override
        public T findEntity(Class<T> entityClass, PK pk) {
                return (T)this.getCurrentSession().load(entityClass, pk);
        }        @SuppressWarnings("unchecked")
        public T findEntity(String hql,PK pk){
                 return (T)this.getCurrentSession().createQuery(hql)
                .setParameter(0, pk).uniqueResult();
        }
}
中间我加了一个base层:
public abstract class AbstractBaseDao <T, PK extends Serializable> implements
BaseDao<T, PK>{        private DaoI<T,PK> dao;        @Resource(name="dao")
        public void setDao(DaoI<T,PK> dao) {
                this.dao = dao;
        }        @SuppressWarnings("unchecked")
        private Class<T> entityClass = GetEntityClassUtil
                        .getEntityClass(getClass());
        
        @Override
        public void save(T entity) {
                dao.save(entity);
        }        @Override
        public void update(T entity) {
       dao.update(entity);                
        }        @Override
        public List<T> findAll() {
                return dao.findAll(entityClass);
        }        @Override
        public void delete(PK... pks) {
                dao.delete(entityClass, pks);
        }        @Override
        public Pager<T> findByPage(String xql, int pageNo, int pageSize) {
                return dao.findByPage(entityClass, xql, pageNo, pageSize);
        }        @Override
        public Pager<T> findByPage(String xql, Object key, int pageNo, int pageSize) {
                return dao.findByPage(entityClass, xql, key, pageNo, pageSize);
        }        @Override
        public Pager<T> findByPage(String xql, Object[] keys, int pageNo, int pageSize) {
                return dao.findByPage(entityClass, xql, keys, pageNo, pageSize);
        }
                @Override
        public T findEntity(PK pk) {
                return dao.findEntity(entityClass, pk);
        }        @Override
        public T findEntity(String hql, PK pk) {
                return dao.findEntity(hql, pk);
        }
}base层使用到得工具类:
public class GetEntityClassUtil {
        @SuppressWarnings("rawtypes")
        public static Class getEntityClass(Class c) {
                Type type = c.getGenericSuperclass();
                if (type instanceof ParameterizedType) {
                        Type[] param = ((ParameterizedType) type).getActualTypeArguments();
                        return (Class) param[0];
                } else {
                        return Object.class;
                }
        }
}这是我的service层相关代码:@Service("userService")
public class UserServiceImpl extends AbstractBaseDao<User,Integer> implements UserServiceI {}我的action类里相关代码这样写:
@ParentPackage("user_module")
@Namespace("/user")
@Action(results={@Result(name="findAll",location="/index.jsp"),
                         @Result(name="success",location="/user/success.jsp"),
                         @Result(name="findByPage",location="/user/findAll.jsp"),
                         @Result(name="showUpdate",location="/user/showUpdate.jsp")},value="userAction")
public class UserAction extends BaseAction{        private static final long serialVersionUID = -6145564175757598422L;        private UserServiceI userService;        private User user;
        
        public User getUser() {
                return user;
        }        public void setUser(User user) {
                this.user = user;
        }        @Resource(name="userService")
        public void setUserService(UserServiceI userService) {
                this.userService = userService;
        }
        
        public String showUsers(){
                List<User> users = userService.findAll();
                HttpServletRequest request = ServletActionContext.getRequest();
                request.setAttribute("users", users);
                return "findAll";
        }
        
        public String deleteUser() {
                userService.delete(new Integer[]{ id });
                return "success";
        }
        
        
        public String addUser(){
                userService.save(user);
            return ActionSupport.SUCCESS;
        }
        
        public String showUpdate(){
                user = userService.findEntity("from User u where u.id=?", id);
                return "showUpdate";
        }
        
        public String updateUser(){
                user.setId(id);
                userService.update(user);
                return "success";
        }
        
        public String findByPage() {
                int pageNo = 0;
                String str_pageNo = getParameter("pager.offset");
                if (str_pageNo != null) {
                        pageNo = Integer.parseInt(str_pageNo);
                }
                Pager<User> pager = userService.findByPage("from User", pageNo, 3);
                setAttribute("pager", pager);
                return "findByPage";
        }}
但就是update和delete方法发出不了sql语句,这是为什么ssh整合hibernate4