hibernate session.get не загружает постоянный объект при переходе с hibernate 4.3.11 на 5.2.10 и использует EntityManager вместо SessionFactory - PullRequest
0 голосов
/ 23 мая 2018

В течение многих лет в проекте я использовал от hibernate 4.3.11.Final и spring 4.3.1.RELEASE для манипулирования и сохранения объектов.Недавно я мигрировал в спящий режим 5.2.10.Final и столкнулся с проблемой, которая его описывает.У меня есть два класса домена, как вы можете видеть ниже:

public class Post extends BaseEntity<Long> {
    private String title;
    private Set<PostComment> comments = new HashSet<>(0);

    // getters and setters removed for brevity
}

public class PostComment extends BaseEntity<Long> {
    private Post post;
    private String descripton;

    // getters and setters removed for brevity
}

public abstract class BaseEntity<T> implements Serializable {
    private T id;
}

, и это файлы отображения гибернации:

<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping>
    <class name="" table="tbl_post">
        <id name="id" type="long" >
            <column name="ID"  />
            <generator class="sequence" >
                <param name="sequence">RGH.SEQ_POST</param>
            </generator>
        </id>

        <property name="title" column="title" type="string" not-null="true" />

        <set name="comments" inverse="true" cascade="save-update,merge">
            <key>
                <column name="post_id" not-null="true" />
            </key>
            <one-to-many class="com.rgh.PostComment" />
        </set>
    </class>
</hibernate-mapping>

<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping>
    <class name="" table="tbl_post_comment">
        <id name="id" type="long" >
            <column name="ID"  />
            <generator class="sequence" >
                <param name="sequence">RGH.SEQ_POST_COMMENT</param>
            </generator>
        </id>

        <property name="descripton" column="descripton" type="string" not-null="true" />

        <many-to-one name="post" column="post_id" entity-name="com.rgh.Post" not-null="true" />
    </class>
</hibernate-mapping>

В классе PostService существует два метода, один из которых сохраняется в теме.Post сущность и ее PostComment, а другая сохраняет сущность Post и количество журналов ее PostCommment.

@Service
public class PostService {
    @Autowired
    private PostRepository repo;

    @Autowired
    private PostCommentRepository commentRepo;

    @Transactional
    public Long save() {
        Post post = new Post();
        post.setTitle("sample post");
        repo.save(post);

        Set<PostComment> postComments = new HashSet<>();
        for (int i = 0 ; i < 3 ; i++) {
            PostComment postComment = new PostComment();
            postComment.setPost(post);
            postComment.setDescription("description " + i);
            commentRepo.save(postComment);
        }

        return post.getId();
    }

    @Transactional
    public int saveAndGetDetailsCount(Post entity) {
        entity.setTitle(entity.getTitle() + " updated!");
        repo.save(entity);

        Post post = repo.loadById(entity.getId());
        System.out.println(post.Comments().size());
        return post.Comments().size();
    }
}

Оба из PostRepository и PostCommentRepository расширеныиз GenericRepository, который вы можете увидеть ниже:

@Repository
public class PostRepository extends GenericRepository<Post, Long> {
    @Override
    protected Class<Post> getDomainClass() {
        return Post.class;
    }
}

@Repository
public class PostCommentRepository extends GenericRepository<PostComment, Long> {
    @Override
    protected Class<PostComment> getDomainClass() {
        return PostComment.class;
    }
}

@Repository
public abstract class GenericRepository<T extends BaseEntity,PK extends Serializable> {

    protected Class<T> domainClass = getDomainClass();

    @Autowired
    private SessionFactory sessionFactory;

    public Session getSession() {
        try {
            return sessionFactory.getCurrentSession();
        } catch (Exception e) {
        }
        return sessionFactory.openSession();
    }

    public PK save(T Entity) {
        Session session = getSession();
        if(entity.getId() == null) {
            session.save(entity);
        }
        else {
            entity = (T)session.merge(entity);
            session.update(entity);
        }
        return entity.getId();
    }

    public T loadByEntityId(PK entityId) {
        Session session = getSession();
        return  (T) session.get(domainClass.getName(), entityId);
    }
}

Все работает нормально, когда я вызываю save метод и затем вызываю saveAndGetDetailsCount, он обновляет сущность и затем выполняет select... запрос для загрузкиPost сущность, а затем регистрирует 3 и публикует комментарии.

Но после того, как я перешел в спящий режим 5.2.10.Final и применил эти изменения:

@Entity
@Table(schema = "RGH", name = "TBL_POST")
@SequenceGenerator(name = "sequence_db", sequenceName = "RGH.SEQ_POST", allocationSize = 1)
public class Post extends BaseEntity<Long> {

    @Column
    private String title;

    @OneToMany(mappedBy = "post", fetch = FetchType.LAZY)
    @Cascade(value = { CascadeType.SAVE_UPDATE, CascadeType.MERGE })
    private Set<PostComment> comments = new HashSet<>(0);

    // getters and setters removed for brevity
}

@Entity
@Table(schema = "RGH", name = "TBL_POST_COMMENT")
@SequenceGenerator(name = "sequence_db", sequenceName = "RGH.SEQ_POST_COMMENT", allocationSize = 1)
public class PostComment extends BaseEntity<Long> {

    @ManyToOne(fetch = FetchType.LAZY)
    @JoinColumn(name = "POST_ID", nullable = false)
    private Post post;

    @Column
    private String descripton;

    // getters and setters removed for brevity
}

public abstract class BaseEntity<T> implements Serializable {

    @Id
    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "sequence_db")
    private T id;
}

, а затем GenericRepository я использовал EntityManager, чтобы получить Session класс, как вы можете видеть ниже:

@Repository
public abstract class GenericRepository<T extends BaseEntity,PK extends Serializable> {

    protected Class<T> domainClass = getDomainClass();

    /* changed */
    @PersistenceContext
    private EntityManager em;

    public Session getSession() {
        /* changed */
        return  em.unwrap(Session.class);
    }

    public PK save(T Entity) {
        Session session = getSession();
        if(entity.getId() == null) {
            session.save(entity);
        }
        else {
            entity = (T)session.merge(entity);
            session.update(entity);
        }
        return entity.getId();
    }

    public T loadByEntityId(PK entityId) {
        Session session = getSession();
        return  (T) session.get(domainClass.getName(), entityId);
    }
}

Теперь проблема в том, что, когда я запускаю предыдущие вызовы методовв saveAndGetDetailsCount hibernate не выполняет select... запрос и регистрирует 0 как количество комментариев.

Я удивился, почему этослучилось.

ОБНОВЛЕНИЕ

Может быть, вы спросите, почему я не использовал с EntityManager вместо Session, у меня есть некоторые ограничения на использование EntityManager.

ОБНОВЛЕНИЕ

Когда я вызываю saveAndGetDetailsCount, параметр entity содержит только id и title и в следующих строках, как вы можете видеть, яхочу загрузить comments поле и получить его размер.

Ответы [ 2 ]

0 голосов
/ 23 июня 2018

Ваша проблема не в переходе в спящий режим 5. Я думаю, что ваша проблема в транзакции. При сохранении или слиянии вызова в той же транзакции, loadById не выполняется до возврата метода. Вы можете сбросить после сохранения, чтобы слияние работало правильно и ваш объектзагрузить.

изменить код на этот

@Repository
public abstract class GenericRepository<T extends BaseEntity,PK extends Serializable> {

    protected Class<T> domainClass = getDomainClass();

    /* changed */
    @PersistenceContext
    private EntityManager em;

    public Session getSession() {
        /* changed */
        return  em.unwrap(Session.class);
    }

    public PK save(T Entity) {
        Session session = getSession();
        if(entity.getId() == null) {
            em.persist(entity);
        }
        else {
            em.merge(entity);
            em.flush();
        }
        return entity.getId();
    }

    public T loadByEntityId(PK entityId) {
        Session session = getSession();
        return  (T) session.get(domainClass.getName(), entityId);
    }
}
0 голосов
/ 23 мая 2018

Зачем генерировать запрос, если объект уже подключен к текущему сеансу?

Кроме того, почему вы вызываете слияние и обновление?Вы должны использовать один или другой.Но не оба.

...