Golang中使用Sqlx执行存储过程并传入JSON参数

在 sqlx 中执行带有 JSON 参数的存储过程，可以通过以下方式实现：

package main

import (
    "encoding/json"
    "fmt"
    "github.com/jmoiron/sqlx"
    _ "github.com/lib/pq" // PostgreSQL 驱动示例
)

// 定义 JSON 数据结构
type UserData struct {
    Name  string `json:"name"`
    Email string `json:"email"`
    Age   int    `json:"age"`
}

func main() {
    // 连接数据库
    db, err := sqlx.Connect("postgres", "user=postgres dbname=test sslmode=disable")
    if err != nil {
        panic(err)
    }
    defer db.Close()

    // 准备 JSON 数据
    userData := UserData{
        Name:  "张三",
        Email: "zhangsan@example.com",
        Age:   25,
    }

    // 将结构体序列化为 JSON 字符串
    jsonData, err := json.Marshal(userData)
    if err != nil {
        panic(err)
    }

    // 执行存储过程
    // 假设存储过程名为 process_user_data，接受一个 JSON 参数
    query := "CALL process_user_data($1)"
    
    // 使用 sqlx 执行存储过程
    _, err = db.Exec(query, string(jsonData))
    if err != nil {
        panic(err)
    }

    fmt.Println("存储过程执行成功")
}

对于需要返回结果的存储过程，可以使用 sqlx.Named：

// 如果存储过程有输出参数
type Result struct {
    Status  string `db:"status"`
    Message string `db:"message"`
}

func callStoredProcedureWithOutput(db *sqlx.DB, inputJSON string) (Result, error) {
    var result Result
    
    // 使用命名参数
    query := `CALL process_user_data(:input, @status, @message);
              SELECT @status as status, @message as message`
    
    // 准备参数映射
    params := map[string]interface{}{
        "input": inputJSON,
    }
    
    // 使用 NamedQuery 执行
    rows, err := db.NamedQuery(query, params)
    if err != nil {
        return result, err
    }
    defer rows.Close()
    
    if rows.Next() {
        err = rows.StructScan(&result)
    }
    
    return result, err
}

对于 MySQL 数据库，JSON 参数的传递方式类似：

// MySQL 示例
func callMySQLProcedure(db *sqlx.DB) error {
    data := map[string]interface{}{
        "name":  "李四",
        "email": "lisi@example.com",
    }
    
    jsonData, _ := json.Marshal(data)
    
    // MySQL 调用存储过程
    _, err := db.Exec("CALL process_data(?)", string(jsonData))
    return err
}

如果存储过程需要多个 JSON 参数：

func callProcedureWithMultipleJSONParams(db *sqlx.DB) error {
    userInfo := map[string]interface{}{"name": "王五", "age": 30}
    addressInfo := map[string]interface{}{"city": "北京", "street": "长安街"}
    
    userJSON, _ := json.Marshal(userInfo)
    addressJSON, _ := json.Marshal(addressInfo)
    
    query := "CALL process_user_complete($1, $2)"
    _, err := db.Exec(query, string(userJSON), string(addressJSON))
    return err
}

确保数据库驱动支持 JSON 类型，并且存储过程能够正确解析 JSON 参数。不同的数据库系统（PostgreSQL、MySQL、SQL Server）可能有细微的语法差异，需要根据实际使用的数据库调整调用方式。