如何在Hibernate中将@ElementCollection List<String>迁移为List<Address>且不丢失数据

1. 提前调整数据库表结构 #

首先执行SQL语句，为employee_addresses表新增address_type列（对应Address类的addressType属性），并设置符合业务需求的默认值：

ALTER TABLE employee_addresses 
ADD COLUMN address_type VARCHAR(255) DEFAULT 'HOME';

2. 过渡阶段：同时保留新旧字段 #

修改Employee实体，暂时保留原有的List<String>字段用于迁移，新增List<Address>字段并确保两者映射到同一张表：

@Entity
public class Employee {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    // 旧字段，仅用于数据迁移，完成后删除
    @ElementCollection
    @CollectionTable(name = "employee_addresses", joinColumns = @JoinColumn(name = "employee_id"))
    @Column(name = "address")
    @Deprecated
    private List<String> oldAddresses;

    // 新字段，明确属性与表列的映射关系
    @ElementCollection
    @CollectionTable(name = "employee_addresses", joinColumns = @JoinColumn(name = "employee_id"))
    @AttributeOverrides({
        @AttributeOverride(name = "address", column = @Column(name = "address")),
        @AttributeOverride(name = "addressType", column = @Column(name = "address_type"))
    })
    private List<Address> addresses;

    // getter、setter及其他字段
}

3. 执行数据迁移 #

编写一次性迁移逻辑，将旧字段的字符串地址转换为Address对象并保存：

// 示例：使用Hibernate Session执行批量迁移
Session session = sessionFactory.openSession();
Transaction tx = session.beginTransaction();

// 批量读取所有员工（数据量大时建议分批次查询）
List<Employee> employees = session.createQuery("FROM Employee", Employee.class).list();

for (Employee employee : employees) {
    List<Address> addressList = new ArrayList<>();
    for (String addrStr : employee.getOldAddresses()) {
        Address address = new Address();
        address.setAddress(addrStr);
        address.setAddressType(AddressTypeEnum.HOME); // 为原有数据设置默认地址类型
        addressList.add(address);
    }
    employee.setAddresses(addressList);
    session.update(employee);
}

tx.commit();
session.close();

4. 验证数据一致性 #

查询employee_addresses表，确认：

• address列的原有数据完整保留
• address_type列已被正确填充默认值

5. 清理代码与映射 #

验证无误后，删除Employee实体中的oldAddresses字段，简化映射配置（若Address类的属性名与表列名完全匹配，可省略@AttributeOverrides）：

@Entity
public class Employee {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @ElementCollection
    @CollectionTable(name = "employee_addresses", joinColumns = @JoinColumn(name = "employee_id"))
    private List<Address> addresses;

    // getter、setter及其他字段
}

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