设计Go语言中的基础对象关系映射（ORM）：原理与实践

package main

import (
    "database/sql"
    "fmt"
    "log"

    _ "github.com/go-sql-driver/mysql" // 导入MySQL驱动，或根据需要选择其他驱动
)

// Person 结构体代表数据库中的 'people' 表的一行
// 字段名通常与数据库列名一致，或使用tag进行映射
type Person struct {
    ID        int    `db:"pID"`       // 数据库中的主键ID
    FirstName string `db:"fName"`
    LastName  string `db:"lName"`
    Job       string `db:"job"`
    Location  string `db:"location"`
}

// DBManager 结构体封装了数据库连接和操作方法
type DBManager struct {
    db *sql.DB
}

// NewDBManager 初始化并返回一个新的DBManager实例
func NewDBManager(dataSourceName string) (*DBManager, error) {
    // sql.Open 不会立即建立连接，只会验证参数
    db, err := sql.Open("mysql", dataSourceName) // 替换为你的数据库驱动和连接字符串
    if err != nil {
        return nil, fmt.Errorf("无法打开数据库连接: %w", err)
    }

    // db.Ping() 尝试与数据库建立连接，用于验证连接字符串是否有效
    if err = db.Ping(); err != nil {
        return nil, fmt.Errorf("无法连接到数据库: %w", err)
    }

    // 设置连接池参数 (可选，但推荐)
    db.SetMaxOpenConns(10) // 最大打开连接数
    db.SetMaxIdleConns(5)  // 最大空闲连接数
    // db.SetConnMaxLifetime(5 * time.Minute) // 连接可复用的最长时间

    return &DBManager{db: db}, nil
}

// Close 关闭数据库连接
func (dm *DBManager) Close() error {
    return dm.db.Close()
}

// GetPersonByID 根据ID从数据库中检索一个Person对象
func (dm *DBManager) GetPersonByID(id int) (*Person, error) {
    p := &Person{}
    // QueryRow 用于查询单行数据
    row := dm.db.QueryRow("SELECT pID, fName, lName, job, location FROM people WHERE pID = ?", id)

    // Scan 将查询结果映射到结构体字段
    err := row.Scan(&p.ID, &p.FirstName, &p.LastName, &p.Job, &p.Location)
    if err != nil {
        if err == sql.ErrNoRows {
            return nil, fmt.Errorf("未找到ID为 %d 的人员", id)
        }
        return nil, fmt.Errorf("扫描人员数据失败: %w", err)
    }
    return p, nil
}

// SavePerson 插入新人员或更新现有人员
func (dm *DBManager) SavePerson(p *Person) error {
    if p.ID == 0 { // 假设ID为0表示新记录，需要插入
        result, err := dm.db.Exec(
            "INSERT INTO people (fName, lName, job, location) VALUES (?, ?, ?, ?)",
            p.FirstName, p.LastName, p.Job, p.Location,
        )
        if err != nil {
            return fmt.Errorf("插入人员失败: %w", err)
        }
        // 获取新插入记录的ID
        lastID, err := result.LastInsertId()
        if err != nil {
            return fmt.Errorf("获取最后插入ID失败: %w", err)
        }
        p.ID = int(lastID) // 更新结构体的ID
    } else { // 否则，更新现有记录
        _, err := dm.db.Exec(
            "UPDATE people SET fName = ?, lName = ?, job = ?, location = ? WHERE pID = ?",
            p.FirstName, p.LastName, p.Job, p.Location, p.ID,
        )
        if err != nil {
            return fmt.Errorf("更新人员失败: %w", err)
        }
    }
    return nil
}

// DeletePerson 根据ID从数据库中删除一个Person对象
func (dm *DBManager) DeletePerson(id int) error {
    _, err := dm.db.Exec("DELETE FROM people WHERE pID = ?", id)
    if err != nil {
        return fmt.Errorf("删除ID为 %d 的人员失败: %w", err)
    }
    return nil
}

func main() {
    // 示例用法（需要一个运行中的数据库和正确的DSN）
    // 实际应用中，dataSourceName应从配置中读取
    // 例如： "user:password@tcp(127.0.0.1:3306)/dbname?charset=utf8mb4&parseTime=True&loc=Local"
    // 请替换为你的实际数据库连接字符串
    dataSourceName := "root:password@tcp(127.0.0.1:3306)/testdb?charset=utf8mb4&parseTime=True&loc=Local" // 示例DSN

    dm, err := NewDBManager(dataSourceName)
    if err != nil {
        log.Fatalf("初始化数据库管理器失败: %v", err)
    }
    defer dm.Close() // 确保在main函数结束时关闭数据库连接

    fmt.Println("数据库管理器初始化成功。")

    // 1. 插入新人员
    newPerson := &Person{
        FirstName: "Alice",
        LastName:  "Smith",
        Job:       "Software Engineer",
        Location:  "New York",
    }
    if err := dm.SavePerson(newPerson); err != nil {
        log.Printf("插入新人员失败: %v", err)
    } else {
        fmt.Printf("新人员插入成功，ID: %d\n", newPerson.ID)
    }

    // 2. 获取人员并更新
    if newPerson.ID != 0 { // 确保新人员已成功插入
        retrievedPerson, err := dm.GetPersonByID(newPerson.ID)
        if err != nil {
            log.Printf("获取人员失败: %v", err)
        } else {
            fmt.Printf("获取到人员: %+v\n", retrievedPerson)
            retrievedPerson.Job = "Senior Software Engineer"
            if