Go语言中模型结构化与依赖管理：避免循环引用与数据库集成最佳实践

// models/person/person.go
package person

import "models/team" // 导入 team 包

type Person struct {
    Name string
    Team team.Team // Person 依赖 Team
}

// models/team/team.go
package team

import "models/person" // 导入 person 包

type Team struct {
    Name   string
    People []*person.Person // Team 依赖 Person
}

// models/models.go
package models

// Person 结构体定义
type Person struct {
    ID   int
    Name string
    Team *Team // Person 引用 Team
}

// Team 结构体定义
type Team struct {
    ID     int
    Name   string
    People []*Person // Team 引用 Person
}

// NewPerson 创建一个新的 Person 实例
func NewPerson(id int, name string, team *Team) *Person {
    return &Person{ID: id, Name: name, Team: team}
}

// NewTeam 创建一个新的 Team 实例
func NewTeam(id int, name string) *Team {
    return &Team{ID: id, Name: name, People: []*Person{}}
}

// AddPersonToTeam 将人员添加到团队
func (t *Team) AddPersonToTeam(p *Person) {
    p.Team = t // 确保人员的团队引用也更新
    t.People = append(t.People, p)
}

package main

import "your_project/models" // 假设 models 包位于 your_project 目录下

func main() {
    teamA := models.NewTeam(1, "Alpha Team")
    person1 := models.NewPerson(101, "Alice", teamA)
    person2 := models.NewPerson(102, "Bob", teamA)

    teamA.AddPersonToTeam(person1)
    teamA.AddPersonToTeam(person2)

    // ... 后续操作
}

// dbclient/client.go
package dbclient

import "database/sql"

// DBClient 定义了数据库操作的接口
type DBClient interface {
    QueryRow(query string, args ...interface{}) *sql.Row
    Exec(query string, args ...interface{}) (sql.Result, error)
    // ... 其他需要的数据库操作方法，如 Query, Prepare, BeginTx 等
}

// SQLDBClient 是一个实现了 DBClient 接口的具体数据库客户端
type SQLDBClient struct {
    DB *sql.DB
}

// NewSQLDBClient 创建一个新的 SQLDBClient 实例
func NewSQLDBClient(db *sql.DB) *SQLDBClient {
    return &SQLDBClient{DB: db}
}

func (s *SQLDBClient) QueryRow(query string, args ...interface{}) *sql.Row {
    return s.DB.QueryRow(query, args...)
}

func (s *SQLDBClient) Exec(query string, args ...interface{}) (sql.Result, error) {
    return s.DB.Exec(query, args...)
}

// repository/person_repository.go
package repository

import (
    "database/sql"
    "fmt"
    "your_project/dbclient"
    "your_project/models"
)

// PersonRepository 定义了人员数据访问的接口
type PersonRepository interface {
    GetByID(id int) (*models.Person, error)
    GetAll() ([]*models.Person, error)
    Save(person *models.Person) error
    // ... 其他人员相关的 CRUD 操作
}

// SQLPersonRepository 是 PersonRepository 接口的 SQL 实现
type SQLPersonRepository struct {
    db dbclient.DBClient // 依赖于 DBClient 接口
}

// NewSQLPersonRepository 创建一个新的 SQLPersonRepository 实例
func NewSQLPersonRepository(client dbclient.DBClient) *SQLPersonRepository {
    return &SQLPersonRepository{db: client}
}

// GetByID 根据ID获取人员信息
func (r *SQLPersonRepository) GetByID(id int) (*models.Person, error) {
    query := "SELECT id, name, team_id FROM persons WHERE id = ?"
    row := r.db.QueryRow(query, id)

    p := &models.Person{}
    var teamID *int // 假设 team_id 可以为空，或者需要单独查询团队信息
    err := row.Scan(&p.ID, &p.Name, &teamID)
    if err != nil {
        if err == sql.ErrNoRows {
            return nil, nil // 未找到
        }
        return nil, fmt.Errorf("failed to get person by ID %d: %w", id, err)
    }

    // 实际应用中，如果 Person.Team 是一个完整的 Team 对象，