减少休眠会话中的代码重复

Question

我正在使用 Jersey 和 Hibernate 以及 Postgres 作为后端开发 REST Web 服务。我有 3 个用于模型、资源和服务的包。对于服务中的每种方法，我都在复制代码：

SessionFactory sessionFactory = HibernateUtil.getSessionFactory();
Session session = sessionFactory.openSession();
Transaction transaction = null;
try {
    transaction = session.beginTransaction();
    ***SOME UNIQUE OBJECT***  = (***SOME UNIQUE OBJECT TYPE***) session.save(***SOME UNIQUE OBJECT***);
    session.getTransaction().commit();
} catch (HibernateException e) {
    if (transaction != null) {
        transaction.rollback();
    }
} finally {
    session.close();
}
return ***SOME UNIQUE OBJECT***;

有人可以建议我如何在不复制此代码的情况下做到这一点。我正在考虑为实体模型类编写一个接口。然后将该接口传递给上面的代码。不确定这是否是最好的方法。

Answer 1

在任何设计模式中，都非常鼓励和提倡使用接口。它将让您在未来添加不同的实现/功能减少依赖，这不过是抽象。

一个例子：

public interface StudentDao {
   public void save(Student student);
}

我们有一个实现类

@Repository
public interface StudentDaoImpl implements StudentDao {

   @Autowired  
   SessionFactory sessionFactory; 

   public void save(Student student){
      Session currentSession = sessionFactory.getCurrentSession();  
      currentSession.save(student);    
      currentSession.close();
   }
}

以服务类为例：

@Service
public class StudentService {

  @Autowired
  StudentDao studentDao; 

  @Transactional  
  public void save(Student student){
      studentDao.save(student);
  }


}

完整的解释将取决于您的项目和要求。不过，我为您解释了一个基于注释的简单示例。

Answer 2

您可以使用spring-data-jpa 模块并创建extends the CrudRepository interface for your repository 的存储库接口。

默认情况下，它将具有所有标准 CRUD 方法，例如 save。大多数情况下，您不必定义实现 - Spring 将为接口提供实现。对于非常复杂的存储库代码，您可以混合使用自己的 java 实现方法。

它还允许您在界面中定义许多查询，而无需编写一行代码。

CrudRepository 提供的功能：

public interface CrudRepository<T, ID extends Serializable>
    extends Repository<T, ID> {
                                                                                                                       (1)
    <S extends T> S save(S entity);
                                                                                                                       (2)
    T findOne(ID primaryKey);
                                                                                                                       (3)
    Iterable<T> findAll();

    Long count();
                                                                                                                       (4)
    void delete(T entity);
                                                                                                                       (5)
    boolean exists(ID primaryKey);
                                                                                                                       (6)
    // … more functionality omitted.
}

Answer 3

通过结合Rahul Raj's answer on DAO pattern 和有关泛型类型的各种建议，我设法实现了我想要的，如下所示。

创建了实体类EntityA、EntityB 和EntityC。创建了一个名为Object 的接口，如下所示：

public interface Object<T> {
    public T addObject(Class<T> entityClass, T newObject);
} 

并用

实现它

public class ObjectImpl<T> implements Object<T> {
    @Override 
    public T getObject(Class<T> entityClass, long objectId) {
        SessionFactory sessionFactory = HibernateUtil.getSessionFactory();
        Session session = sessionFactory.openSession();
        Transaction transaction = null;
        T entity = null;
        try {
            transaction = session.beginTransaction();
            entity = session.get(entityClass, objectId);
            session.getTransaction().commit();
        } catch (HibernateException e) {
            if (transaction != null) {
                transaction.rollback();
            }
        } finally {
            session.close();
        }
        return entity;
    }
}

现在我可以使用 addObject 方法插入不同实体的对象，例如

public class EntityAService {

    public EntityAService() {
    }
    public EntityA addRedemption(EntityA entityA) {
        Object<EntityA> newEntityA = new ObjectImpl<EntityA>();
        return newEntityA.addObject(EntityA.class, newEntityA);
    }
}

HibernateUtil 提供单例 SessionFactory 对象。这样，我可以添加任意数量的不同实体并将它们的实例保存到数据库中，而无需过多的代码重复。如果有人有更好的建议/cmets，请告诉我。感谢大家的想法！

Answer 4

使用泛型，您可以执行以下操作：

public static <T>T addObject(Object object, Class<T> type) {
    Session session = HibernateUtil.getSessionFactory().openSession();
    org.hibernate.Transaction tx = null;

    try{
        tx = session.beginTransaction();
        session.save(object);
        tx.commit();
    }catch (HibernateException e) {
        if (tx!=null) tx.rollback();
        e.printStackTrace();
    }
    session.close();
    return type.cast(object);
}