如何用同一Java实体映射Spring Data JPA的用户表与用户历史表？

要复用User实体类同时操作user和user_history表，并建立一对多关联，可以通过以下步骤实现：

1. 完善数据库表约束 #

确保user_history表的外键关联正确，建表语句如下：

CREATE TABLE user_history (
    ID INT AUTO_INCREMENT PRIMARY KEY,
    ID_USER INT NOT NULL,
    salary DOUBLE,
    status VARCHAR(50),
    FOREIGN KEY (ID_USER) REFERENCES user(ID)
);

2. 修改User实体类，添加一对多关联 #

在原有User实体中添加关联历史记录的集合，关联字段为user_history表的ID_USER：

@Entity
@Table(name = "user")
public class User {
    
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;

    private Double salary;

    private String status;

    // 关联当前用户的所有历史记录，默认懒加载
    @OneToMany(fetch = FetchType.LAZY)
    @JoinColumn(name = "ID_USER", referencedColumnName = "id")
    private List<User> historyRecords = new ArrayList<>();
    
    // Getter、Setter、无参/全参构造方法
}

3. 复用User实体保存到user_history表 #

方式一：原生SQL插入（简单直接） #

在UserRepository中自定义插入方法，直接操作user_history表：

public interface UserRepository extends JpaRepository<User, Integer> {

    @Modifying
    @Transactional
    @Query(value = "INSERT INTO user_history (ID_USER, salary, status) VALUES (:userId, :salary, :status)", nativeQuery = true)
    void saveToHistory(@Param("userId") Integer userId, @Param("salary") Double salary, @Param("status") String status);
}

使用示例（用户信息变更时保存历史）：

// 获取旧用户数据
User oldUser = userRepository.findById(userId).orElseThrow();
// 保存到历史表
userRepository.saveToHistory(oldUser.getId(), oldUser.getSalary(), oldUser.getStatus());
// 更新主表用户信息
oldUser.setSalary(newSalary);
oldUser.setStatus(newStatus);
userRepository.save(oldUser);

方式二：动态切换表名（复用实体直接持久化） #

通过Hibernate拦截器动态修改表名，无需额外编写SQL：

步骤1：自定义表名拦截器

public class DynamicTableNameInterceptor extends EmptyInterceptor {
    private static final ThreadLocal<String> TABLE_NAME = new ThreadLocal<>();

    public static void setTableName(String tableName) {
        TABLE_NAME.set(tableName);
    }

    public static void clearTableName() {
        TABLE_NAME.remove();
    }

    @Override
    public String onPrepareStatement(String sql) {
        String targetTable = TABLE_NAME.get();
        if (targetTable != null && sql.contains("user ")) {
            sql = sql.replace("user ", targetTable + " ");
        }
        return super.onPrepareStatement(sql);
    }
}

步骤2：配置拦截器

在application.properties中添加配置：

spring.jpa.properties.hibernate.session_factory.interceptor=com.yourpackage.DynamicTableNameInterceptor

步骤3：保存历史记录

@Service
@Transactional
public class UserService {

    @Autowired
    private EntityManager entityManager;

    public void saveUserHistory(User oldUser) {
        // 切换表名为user_history
        DynamicTableNameInterceptor.setTableName("user_history");
        try {
            // 重置主键，避免和主表主键冲突
            oldUser.setId(null);
            entityManager.persist(oldUser);
        } finally {
            // 清除线程变量，避免影响后续操作
            DynamicTableNameInterceptor.clearTableName();
        }
    }
}

4. 查询关联的历史记录 #

通过主用户实体直接获取历史记录：

User user = userRepository.findById(userId).orElseThrow();
List<User> historyRecords = user.getHistoryRecords();

内容的提问来源于stack exchange，提问作者James