Go语言中实现ORM：深入理解内存缓存与真正的对象关系映射

package main

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

    _ "github.com/go-sql-driver/mysql" // 导入MySQL驱动，或其他数据库驱动
)

// Person 结构体定义，用于映射数据库中的people表
type Person struct {
    ID        int
    FirstName string
    LastName  string
    Job       string
    Location  string
}

func main() {
    // 1. 打开数据库连接
    // 替换为你的数据库连接字符串
    db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/testdb")
    if err != nil {
        log.Fatalf("无法打开数据库连接: %v", err)
    }
    defer db.Close() // 确保在函数结束时关闭数据库连接

    // 2. 验证数据库连接
    err = db.Ping()
    if err != nil {
        log.Fatalf("无法连接到数据库: %v", err)
    }
    fmt.Println("成功连接到数据库!")

    // 假设数据库中有一个名为 'people' 的表，结构如下：
    // CREATE TABLE people (
    //     id INT AUTO_INCREMENT PRIMARY KEY,
    //     first_name VARCHAR(255),
    //     last_name VARCHAR(255),
    //     job VARCHAR(255),
    //     location VARCHAR(255)
    // );
    // INSERT INTO people (first_name, last_name, job, location) VALUES ('John', 'Doe', 'Engineer', 'San Francisco');
    // INSERT INTO people (first_name, last_name, job, location) VALUES ('Jane', 'Smith', 'Designer', 'New York');


    // 3. 查询单个Person对象 (按需加载)
    var person Person
    // 使用 QueryRow 查询单行数据
    row := db.QueryRow("SELECT id, first_name, last_name, job, location FROM people WHERE id = ?", 1)
    err = row.Scan(&person.ID, &person.FirstName, &person.LastName, &person.Job, &person.Location)
    if err != nil {
        if err == sql.ErrNoRows {
            fmt.Println("未找到 ID 为 1 的人员记录")
        } else {
            log.Fatalf("查询人员记录失败: %v", err)
        }
    } else {
        fmt.Printf("查询到人员: %+v\n", person)
    }

    // 4. 修改Person对象并更新到数据库
    if person.ID != 0 { // 确保查询到了人员
        person.Job = "Senior " + person.Job // 修改职位
        // 使用 Exec 执行更新操作
        _, err = db.Exec("UPDATE people SET job = ? WHERE id = ?", person.Job, person.ID)
        if err != nil {
            log.Fatalf("更新人员记录失败: %v", err)
        }
        fmt.Printf("已将 ID %d 的人员职位更新为 %s\n", person.ID, person.Job)
    }

    // 5. 插入新的Person对象
    newPerson := Person{
        FirstName: "Alice",
        LastName:  "Johnson",
        Job:       "Data Scientist",
        Location:  "Boston",
    }
    // 使用 Exec 执行插入操作，并获取新插入的ID
    res, err := db.Exec("INSERT INTO people (first_name, last_name, job, location) VALUES (?, ?, ?, ?)",
        newPerson.FirstName, newPerson.LastName, newPerson.Job, newPerson.Location)
    if err != nil {
        log.Fatalf("插入新人员记录失败: %v", err)
    }
    id, _ := res.LastInsertId()
    fmt.Printf("已插入新人员，ID 为: %d\n", id)

    // 6. 删除Person对象
    // 使用 Exec 执行删除操作
    _, err = db.Exec("DELETE FROM people WHERE first_name = ? AND last_name = ?", "Alice", "Johnson")
    if err != nil {
        log.Fatalf("删除人员记录失败: %v", err)
    }
    fmt.Println("已从数据库中删除 Alice Johnson。")
}