如何在Grails中映射来自不同数据源的数据库表？

这是个很典型的Grails多数据源关联问题，我来帮你拆解可行的处理方案：

1. 先明确核心限制 #

Grails的GORM默认不支持跨数据源的自动hasMany/belongsTo关联——因为自动生成的中间连接表只能归属一个数据源，没法跨库建立关联。你原来的代码里如果直接保留跨数据源的hasMany，运行时肯定会报错，所以得换思路手动维护关联。

2. 调整域类结构，手动维护关联 #

根据你的场景，分两种常见处理方式：

方式一：用数组/字符串存储关联ID（适合简单场景）

修改Classroom和Laboratory，移除自动hasMany，改用存储Student ID集合的字段，同时指定字段类型适配数据库：

class Classroom { 
    // 存储关联的Student ID列表
    List<Long> studentIds

    static mapping = { 
        datasource 'school'
        // 以PostgreSQL为例，映射为TEXT数组类型；如果是MySQL可以用VARCHAR存储逗号分隔ID，后续自行拆分
        studentIds type: 'text[]'
    } 
} 

class Laboratory { 
    List<Long> studentIds

    static mapping = { 
        datasource 'school'
        studentIds type: 'text[]'
    } 
} 

class Student { 
    String name 
    static mapping = { datasource 'person' } 
}

方式二：手动创建中间关联表（适合复杂查询场景）

单独建一个归属某一数据源（比如school）的关联类，用来维护跨数据源的关联关系：

// 这个类归属school数据源，专门存Classroom和Student的关联
class ClassroomStudent {
    Long classroomId
    Long studentId

    static mapping = {
        datasource 'school'
        table 'classroom_student' // 自定义表名
        id composite: ['classroomId', 'studentId'] // 复合主键
        version false // 不需要乐观锁版本号
    }
}

// 同理创建LaboratoryStudent类
class LaboratoryStudent {
    Long laboratoryId
    Long studentId

    static mapping = {
        datasource 'school'
        table 'laboratory_student'
        id composite: ['laboratoryId', 'studentId']
        version false
    }
}

3. 手动实现关联查询逻辑 #

因为没法再用classroom.students这种自动关联查询，需要自己写方法获取关联数据，比如在Classroom里添加查询方法：

class Classroom { 
    static mapping = { datasource 'school' } 

    // 获取当前教室的所有学生
    List<Student> getStudents() {
        // 先从school数据源拿到关联的Student ID列表
        def studentIds = ClassroomStudent.findAllByClassroomId(this.id)*.studentId
        // 切换到person数据源查询Student
        Student.withDatasource('person') {
            Student.getAll(studentIds)
        }
    }
}

4. 跨数据源事务的注意事项 #

跨数据源操作时，单个事务无法覆盖多个数据源，所以要分开处理每个数据源的事务：

// 示例：给教室添加学生的服务方法
def addStudentToClassroom(Long classroomId, Long studentId) {
    // 处理school数据源的事务
    def classroomOpSuccess = Classroom.withTransaction { status ->
        def classroom = Classroom.get(classroomId)
        if (!classroom) {
            status.setRollbackOnly()
            return false
        }
        new ClassroomStudent(classroomId: classroomId, studentId: studentId).save()
        true
    }

    // 处理person数据源的事务（验证Student存在）
    def studentOpSuccess = Student.withDatasource('person') {
        Student.withTransaction { status ->
            def student = Student.get(studentId)
            student != null
        }
    }

    return classroomOpSuccess && studentOpSuccess
}

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