Go语言中lib/pq与PostgreSQL SQL占位符的正确使用指南

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/lib/pq" // 导入 PostgreSQL 驱动
    "log"
)

func main() {
    // 数据库连接字符串，请根据您的PostgreSQL配置修改
    // 例如: "host=localhost port=5432 user=youruser password=yourpassword dbname=yourdb sslmode=disable"
    connStr := "user=postgres password=mysecretpassword dbname=testdb sslmode=disable" // 替换为您的连接字符串
    db, err := sql.Open("postgres", connStr)
    if err != nil {
        log.Fatalf("无法连接到数据库: %v", err)
    }
    defer db.Close()

    err = db.Ping()
    if err != nil {
        log.Fatalf("数据库连接失败: %v", err)
    }
    fmt.Println("成功连接到PostgreSQL数据库！")

    // 1. 创建示例表 (如果不存在)
    _, err = db.Exec(`CREATE TABLE IF NOT EXISTS things (
        id SERIAL PRIMARY KEY,
        name TEXT NOT NULL UNIQUE
    )`)
    if err != nil {
        log.Fatalf("创建表失败: %v", err)
    }
    fmt.Println("表 'things' 已准备就绪。")

    // 2. 插入一条测试数据 (使用正确的 $1 占位符)
    testName := "GoLangThing"
    _, err = db.Exec("INSERT INTO things (name) VALUES ($1) ON CONFLICT (name) DO NOTHING", testName)
    if err != nil {
        log.Fatalf("插入测试数据失败: %v", err)
    }
    fmt.Printf("已确保数据 '%s' 存在。\n", testName)

    // --- 3. 错误示例：使用问号占位符进行查询 ---
    fmt.Println("\n--- 错误示例：使用问号占位符 ---")
    var queriedID int
    incorrectName := "NonExistentThing" // 使用一个不存在的名称，避免sql.ErrNoRows混淆错误类型
    err = db.QueryRow("SELECT id FROM things WHERE name = ?", incorrectName).Scan(&queriedID)
    if err != nil {
        // 预期错误：pq: syntax error at end of input
        fmt.Printf("查询失败 (预期错误): %v\n", err)
    } else {
        fmt.Printf("错误示例中意外成功，ID: %d\n", queriedID)
    }
}

查询失败 (预期错误): pq: syntax error at end of input at character 41

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/lib/pq" // 导入 PostgreSQL 驱动
    "log"
)

func main() {
    // 数据库连接字符串，请根据您的PostgreSQL配置修改
    connStr := "user=postgres password=mysecretpassword dbname=testdb sslmode=disable" // 替换为您的连接字符串
    db, err := sql.Open("postgres", connStr)
    if err != nil {
        log.Fatalf("无法连接到数据库: %v", err)
    }
    defer db.Close()

    err = db.Ping()
    if err != nil {
        log.Fatalf("数据库连接失败: %v", err)
    }
    fmt.Println("成功连接到PostgreSQL数据库！")

    // 1. 创建示例表 (如果不存在)
    _, err = db.Exec(`CREATE TABLE IF NOT EXISTS things (
        id SERIAL PRIMARY KEY,
        name TEXT NOT NULL UNIQUE
    )`)
    if err != nil {
        log.Fatalf("创建表失败: %v", err)
    }
    fmt.Println("表 'things' 已准备就绪。")

    // 2. 插入一条测试数据 (使用正确的 $1 占位符)
    testName := "GoLangThing"
    _, err = db.Exec("INSERT INTO things (name) VALUES ($1) ON CONFLICT (name) DO NOTHING", testName)
    if err != nil {
        log.Fatalf("插入测试数据失败: %v", err)
    }
    fmt.Printf("已确保数据 '%s' 存在。\n", testName)

    // --- 3. 正确示例：使用美元符号占位符进行查询 ---
    fmt.Println("\n--- 正确示例：使用美元符号占位符 ---")
    var correctID int
    err = db.QueryRow("SELECT id FROM things WHERE name = $1", testName).Scan(&correctID)
    if err != nil {
        log.Fatalf("正确查询失败: %v", err)
    }
    fmt.Printf("成功查询到 '%s' 的 ID: %d\n", testName, correctID)

    // --- 4. 多个占位符示例 ---
    fmt.Println("\n--- 多个占位符示例 ---")
    newTestName := "UpdatedGoLangThing"
    _, err = db.Exec("UPDATE things SET name = $1 WHERE id = $2", newTestName, correctID)
    if err != nil {
        log.Fatalf("更新数据失败: %v", err)
    }
    fmt.Printf("成功更新 ID 为 %d 的记录，新名称为 '%s'\n", correctID, newTestName)

    // 查询更新后的数据以验证
    var updatedName string
    err = db.QueryRow("SELECT name FROM things WHERE id = $1", correctID).Scan(&updatedName)
    if err != nil {
        log.Fatalf("查询更新后数据失败: %v", err)
    }
    fmt.Printf("验证：ID %d 的记录名称现为 '%s'\n", correctID, updatedName)
}