Java 模型休眠映射问题

Question

注意：我使用 Spring Data Jpa 进行持久化。

问题：

我有两个模型：User 和 Badge

我有一个用户拥有的徽章列表作为 User 类中的数据成员。 我还有用户作为 徽章 类中的数据成员（即徽章的创建者）

我想在用户和徽章数据成员列表之间建立关系。 关系是 OneToMany 类型（即一个用户将拥有许多徽章），反之亦然。

我希望它以这种方式工作， 在代码中，

当我将颁发者（又名用户）设置为特定用户对象的徽章对象保存时，无需将其（徽章）添加到用户拥有的徽章列表中。

我已尝试创建关系，但它在 REST API 响应中返回用户拥有的徽章的空列表。

徽章模型

import javax.persistence.*;

@Entity
@Table(name = "badges")
public class Badge {
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    @Column(name = "badge_id")
    private int mId;
    @Column(name = "badge_name" , nullable = false , unique = true)
    private String mName;
    @Column(name = "badge_description")
    private String mDescription;
    @Lob
    @Column(name = "badge_logo" , nullable = false)
    private String mLogo;
    @ManyToOne
    @JoinColumn(name = "issuer_id")
    private User mIssuer;
}

用户模型

import javax.persistence.*;
import java.util.ArrayList;
import java.util.List;

@Entity
@Table(name = "users")
public class User {
    @Id@GeneratedValue(strategy = GenerationType.AUTO)
    @Column(name = "user_id")
    private long mId;
    @Column(name = "username" , nullable = false , unique = true)
    private String mUserName;
    @Column(name = "fullname",nullable = false)
    private String mFullName;
    @Column(name = "salt")
    private String mSalt;
    @OneToMany(mappedBy = "mIssuer",cascade = CascadeType.ALL)
    private List<Badge> mOwnedBadges;
    @OneToMany
    @JoinColumn(name = "received_badges_id")
    private List<Badge> mReceivedBadges;
}

CommandLineRunner

import com.badging.spinnerbadger.SpinnerBadger.Models.Badge;
import com.badging.spinnerbadger.SpinnerBadger.Models.User;
import com.badging.spinnerbadger.SpinnerBadger.Services.Intefaces.BadgeSerivce;
import com.badging.spinnerbadger.SpinnerBadger.Services.Intefaces.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

import java.util.Arrays;

@Component
public class StartupExecutor implements CommandLineRunner {
    @Autowired
    private BadgeSerivce mBadgeSerivce;
    @Autowired
    private UserService mUserService;

    @Override
    public void run(String... args) throws Exception {
        //TODO:: issuer cannot issue badge to itself
        final User user1 = new User();
        user1.setFullName("User1 FullName");
        user1.setSalt("salt1");
        user1.setUserName("User1 UserName");
        mUserService.save(user1);

        final User user2 = new User();
        user2.setFullName("User2 FullName");
        user2.setSalt("salt2");
        user2.setUserName("User2 UserName");
        mUserService.save(user2);


        Badge badge1 = new Badge();
        badge1.setDescription("Desc1");
        badge1.setLogo("Logo1");
        badge1.setName("Badge1");
        badge1.setIssuer(user1);
        mBadgeSerivce.save(badge1);

        Badge badge2 = new Badge();
        badge2.setDescription("Desc2");
        badge2.setLogo("Logo2");
        badge2.setName("Badge2");
        badge2.setIssuer(user2);
        mBadgeSerivce.save(badge2);

        Badge badge3 = new Badge();
        badge3.setDescription("Desc3");
        badge3.setLogo("Logo3");
        badge3.setName("Badge3");
        badge3.setIssuer(user1);
        mBadgeSerivce.save(badge3);


        user1.setReceivedBadges(Arrays.asList(badge2));

        user2.setReceivedBadges(Arrays.asList(badge1,badge3));
    }
}

注意：它也不会保存用户收到的徽章列表，如果你也能弄清楚，那我真的很感激你。

徽章回购

import com.badging.spinnerbadger.SpinnerBadger.Models.Badge;
import org.springframework.data.repository.PagingAndSortingRepository;
import org.springframework.stereotype.Repository;

@Repository
public interface BadgeRepo extends PagingAndSortingRepository<Badge,Long> {
}

用户回购

import com.badging.spinnerbadger.SpinnerBadger.Models.User;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;

@Repository
public interface UserRepo extends JpaRepository<User,Long> {
}

BadgeServiceImpl

package com.badging.spinnerbadger.SpinnerBadger.Services.Implentations;

import com.badging.spinnerbadger.SpinnerBadger.Repository.BadgeRepo;
import com.badging.spinnerbadger.SpinnerBadger.Models.Badge;
import com.badging.spinnerbadger.SpinnerBadger.Services.Intefaces.BadgeSerivce;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;

@Service
public class BadgeServiceImpl implements BadgeSerivce {
    @Autowired
    private BadgeRepo mBadgeRepo;
    @Override
    public List<Badge> getAllBadges(int pageNumber , int sizeOfPage) {
        if (sizeOfPage > 20) {
            sizeOfPage = 20;
        }
        final Page<Badge> allPages = mBadgeRepo.findAll(PageRequest.of(pageNumber,
                sizeOfPage));
        if (allPages.getTotalElements() > 0) {
            return allPages.toList();
        } else{
            return new ArrayList<Badge>();
        }
    }

    @Override
    public void save(Badge badge) {
        mBadgeRepo.save(badge);
    }
}

UserServiceImpl

import com.badging.spinnerbadger.SpinnerBadger.Models.Badge;
import com.badging.spinnerbadger.SpinnerBadger.Models.User;
import com.badging.spinnerbadger.SpinnerBadger.Repository.UserRepo;
import com.badging.spinnerbadger.SpinnerBadger.Services.Intefaces.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;
import java.util.Optional;

@Service
public class UserServiceImpl implements UserService {
    @Autowired
    private UserRepo mUserRepo;
    @Override
    public void save(User user) {
        mUserRepo.save(user);
    }

    @Override
    public List<Badge> getUsersReceivedBadgeList(long userId) {
        final Optional<User> byId = mUserRepo.findById(userId);
        return byId.orElse(new User()).getReceivedBadges();
    }

    @Override
    public List<Badge> getUserOwnedBadgeList(long userId) {
        final Optional<User> byId = mUserRepo.findById(userId);
        return byId.orElse(new User()).getReceivedBadges();
    }
}

由 Hibernate 生成的 SQL -> 用户模型第 1 名，徽章模型第 2 名

Hibernate: insert into users (fullname, salt, username, user_id) values (?, ?, ?, ?)

Hibernate: insert into badges (badge_description, issuer_id, badge_logo, badge_name, badge_id) values (?, ?, ?, ?, ?)

Answer 1

我在这里看到了一些可能出错的地方。

1. 您似乎没有指定交易。将@Transactional 添加到那些应该参与事务的bean 或方法中。至少应该包括修改（最终）数据库的所有内容，即修改托管实体的任何语句，包括从数据库加载它的语句和save 语句。我预计这是您所看到问题的实际原因。

2. 您似乎没有同步双向关系双方的代码。所以，当你打电话 badge1.setIssuer(user1), user1 没有更新，所以如果你打电话给user1.getOwnedBadges() 它仍然会返回未更改的（空）值。

   我怀疑在这种情况下这是一个问题，但它会导致 在单个交易中看起来不同的关系， 取决于你从哪一边看。和变化 非拥有方（在您的情况下为User）不会被持久化。所以这应该是固定的 无论如何。另见https://vladmihalcea.com/jpa-hibernate-synchronize-bidirectional-entity-associations/

3. 保存实体时，应使用save 方法返回的实例，而不是作为参数传递给save 的实例。通常它们是相同的，但是当它们不修改传递给 save 的那个时，可能不会导致状态持久化到数据库中。

如果这些问题得到解决并且问题仍然存在，我建议您通过以下方式收集有关正在发生的事情的更多信息：

1. 激活logging of SQL statements including parameters 以查看实际保留的内容（以及何时保留）。

2. 创建一个 JUnit 测试来测试您的服务。这使得实际执行的内容更加清晰，并允许创建变体进行比较。