重新配置hibernate：

在config包下建立HibernateConfiguration類如下：

程式碼：

package com.config;

import org.hibernate.SessionFactory;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.

Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.orm.hibernate5.HibernateTransactionManager;

import org.springframework.orm.hibernate5.LocalSessionFactoryBean;

import javax.sql.DataSource;

import java.util.Properties;

/**

* Created by onion on 2017-03-30 15:18.

*/

@Configuration

public class HibernateConfiguration {

//配置sessionFactory

@Bean

public LocalSessionFactoryBean sessionFactory(@Qualifier("dataSource") DataSource dataSource,

@Value("${spring.hibernate.packageScan}") String packageScan,

@Value("${spring.jpa.properties.hibernate.dialect}"

) String dialect,

@Value("${spring.jpa.show-sql}") String showSql,

@Value("${spring.jpa.properties.hibernate.format_sql}") String formatSql,

@Value("${spring.jpa.properties.hibernate.use_sql_comments}") String useSqlComments,

@Value("${spring.jpa.hibernate.ddl-auto}") String ddlAuto) {

      LocalSessionFactoryBean localSessionFactoryBean = new LocalSessionFactoryBean();

      localSessionFactoryBean.setDataSource(dataSource);

      localSessionFactoryBean.setPackagesToScan(packageScan);

      Properties properties = new Properties();

      properties.setProperty("hibernate.dialect", dialect);

      properties.setProperty("hibernate.show_sql", showSql);

      properties.setProperty("hibernate.format_sql", formatSql);

      properties.setProperty("hibernate.use_sql_comments", useSqlComments);

      properties.setProperty("hibernate.hbm2ddl.auto", ddlAuto);

      localSessionFactoryBean.setHibernateProperties(properties);

return localSessionFactoryBean;

  }

//配置hibernate事務處理

@Bean

public HibernateTransactionManager transactionManager(SessionFactory sessionFactory) {

      HibernateTransactionManager transactionManager = new HibernateTransactionManager();

      transactionManager.setSessionFactory(sessionFactory);

return transactionManager;

  }

}

然後在application.properties新增以下程式碼：

spring.jta.transaction-manager-id=transactionManager

spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5Dialect

spring.hibernate.packageScan=com.tgb.model

將UserService程式碼修改為：

package com.tgb.service;

import com.tgb.dao.UserDao;

import com.tgb.model.User;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**

* Created by onion on 2017-03-28 09:11.

*/

@Service

@Transactional(rollbackFor = Exception.class)

public class UserService {

@Autowired

private UserDao userDao;

public User addUser(User user) {

      User user1 = new User();

      user1.setName("測試資料");

      user1.setAge(2);

userDao.save(user1);

int i = 10/0;

return userDao.save(user);

  }

@Transactional(readOnly = true)

public List<User> getAll() {

return userDao.findAll();

  }

}

上面的Transactional（rollbackFor = Exception.class）註解是設定事務處理。

在addUser方法中我們int i = 10/0 會出現異常。當出現異常資訊時候我們實現了資料回滾。

在dao包下新建impl包，如下：

在dao包下新建GenericDao類，如下：

其中程式碼：

package com.tgb.dao;

import java.util.List;

/**

* Created by onion on 2017-03-30 15:57.

*/

public interface GenericDao<T, PK> {

void save(T entity);

void delete(T entity);

void deleteAll(List<T> entities);

void saveOrUpdate(T entity);

T findById(PK id);

void update(T entity);

  List<T> findAll(Object... args);

  Object getUniqueObject(String hql, Object... params);

  List<T> findAllbyhql(String hql);

void deletebyhql(String hql);

  List<T> queryPage(T entity, int page, int rows);

}

在dao.impl下建立類GenericDaoImpl，如下：

程式碼：

package com.tgb.dao.impl;

import com.tgb.dao.GenericDao;

import org.hibernate.HibernateException;

import org.hibernate.Query;

import org.hibernate.Session;

import org.hibernate.SessionFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.orm.hibernate5.HibernateCallback;

import org.springframework.orm.hibernate5.support.HibernateDaoSupport;

import java.io.Serializable;

import java.lang.reflect.ParameterizedType;

import java.util.List;

/**

* Created by onion on 2017-03-30 15:59.

*/

public class GenericDaoImpl <T, PK extends Serializable> extends HibernateDaoSupport implements GenericDao<T, PK> {

@Autowired

public void InitSession(SessionFactory sessionFactory) {

      setSessionFactory(sessionFactory);

  }

private Class<T> clazz;

public GenericDaoImpl() {

clazz = (Class<T>) ((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0];

  }

@Override

public void save(T entity) {

      getHibernateTemplate().save(entity);

  }

@Override

public T findById(PK id) {

return getHibernateTemplate().get(clazz, id);

  }

@Override

public void update(T entity) {

      getHibernateTemplate().update(entity);

  }

@Override

public void saveOrUpdate(T entity) {

      getHibernateTemplate().saveOrUpdate(entity);

  }

@Override

public void delete(T entity) {

      getHibernateTemplate().delete(entity);

  }

@Override

public void deleteAll(List<T> entities) {

      getHibernateTemplate().deleteAll(entities);

  }

@Override

public List<T> findAll(Object... args) {

return (List<T>) getHibernateTemplate().find("from " + clazz.getName(), args);

相關推薦