sql：预期有 8 个参数，使用 `preparex` 和 `context.context`

Question

我的问题与那个无关。我的问题主要是关于preparexand ctx。我已经完成了使用的实现db.NamedExec，我的代码正在为这些工作。我在这里试图做的是理解context.context和preparex。使用这两个实现。代码片段：模型.gotype User struct {    ID        int       `db:"id" json:"id"`    CreatedAt time.Time `db:"created_at" json:"created_at"`    UpdatedAt time.Time `db:"updated_at" json:"updated_at"`    DeletedAt time.Time `db:"deleted_at" json:"deleted_at"`    Username  string    `db:"username" json:"username"`    Password  string    `db:"password" json:"password"`    FirstName string    `db:"first_name" json:"first_name"`    LastName  string    `db:"last_name" json:"last_name"`    Phone     string    `db:"phone" json:"phone"`    Status bool         `db:"status" json:"status"`    Addrs  []UserAddress}询问：queryInsertUserData = `    INSERT INTO users (id, created_at, updated_at, deleted_at, username, password, first_name, last_name, phone, status) VALUES($1, now(), now(), $2, $3, $4, $5, $6, $7, $8)`type queries struct {    insertUserData,     insertAddrData *sqlx.Stmt}//prepareStatement is a method for preparing sqlx statementfunc (queries *queries) prepareStatement(db *sqlx.DB, query string) (*sqlx.Stmt, error) {    stmt, err := db.Preparex(query) //https://go.dev/doc/database/prepared-statements    if err != nil {        return nil, err    }    return stmt, err}constructUserData, err := queries.prepareStatement(db, queryInsertUserData)queries.insertUserData = constructUserData执行：// Insert User datafunc (postgres *Postgres) InsertUserData(ctx context.Context) (*entity.User, error) {    c := entity.User{}    err := postgres.queries.insertUserData.SelectContext(ctx, &c) //<---here    if err != nil {        return nil, err    }    return &c, nil}我的 ctx 是：ctx = context.WithValue(ctx, "ID", 1)ctx = context.WithValue(ctx, "Username", "John")ctx = context.WithValue(ctx, "Password", "pass")当我经过postgres.queries.insertUserData.SelectContext(ctx, &c)我正进入（状态：sql: expected 8 arguments, got 0为什么它说得了0？谁能帮我这个？如何传递 ctx 并提供插入查询值？

Answer 1

我没有得到你的代码的结构，但从主要上下文（插入查询）你应该做这样的事情：

package main

import (

    "context"

    "database/sql"

    "log"

)

var db *sql.DB

type User struct {

    ID        int       `db:"id" json:"id"`

    CreatedAt time.Time `db:"created_at" json:"created_at"`

    UpdatedAt time.Time `db:"updated_at" json:"updated_at"`

    DeletedAt time.Time `db:"deleted_at" json:"deleted_at"`

    Username  string    `db:"username" json:"username"`

    Password  string    `db:"password" json:"password"`

    FirstName string    `db:"first_name" json:"first_name"`

    LastName  string    `db:"last_name" json:"last_name"`

    Phone     string    `db:"phone" json:"phone"`

    Status bool         `db:"status" json:"status"`

    Addrs  []UserAddress

}

func main() {

    users := []User {

        {...User 1 data...},

        {...User 2 data...},

    }

    stmt, err := db.Prepare("INSERT INTO users (id, created_at, updated_at, deleted_at, username, password, first_name, last_name, phone, status) VALUES($1, now(), now(), $2, $3, $4, $5, $6, $7, $8)")

    if err != nil {

        log.Fatal(err)

    }

    defer stmt.Close() // Prepared statements take up server resources and should be closed after use.

    for id, user := range users {

        if _, err := stmt.Exec(id+1, user.Username, user.Password,... other data); err != nil {

            log.Fatal(err)

        }

    }

}

此外，您可以使用强大的Gorm包来使用所有关系数据库。

Answer 2

我使用这个助手来插入。

使用查询语法如下：

INSERT INTO checks (

    status) VALUES (:status)

    returning id;

样本结构

    type Row struct {

        Status string `db:"status"`

    }

// Insert inserts row into table using query SQL command

// table used only for loging, actual table name defined in query

// function expects Query with named parameters

func Insert(ctx context.Context, row interface{}, query string, table string, tx *sqlx.Tx) (int64, error) {

    // convert named query to native parameters format

    query, args, err := tx.BindNamed(query, row)

    if err != nil {

        return 0, fmt.Errorf("cannot bind parameters for insert into %q: %w", table, err)

    }

    var id struct {

        Val int64 `db:"id"`

    }

    err = sqlx.GetContext(ctx, tx, &id, query, args...)

    if err != nil {

        return 0, fmt.Errorf("cannot insert into %q: %w", table, err)

    }

    return id.Val, nil

}