为什么sqlx的copyin语句会挂起？

Question

我已经写了一个玩具应用程序来尝试通过sqlx使用Postgresql。我有一个大容量插入器

pq.CopyIn

作为准备好的陈述的内容

stmt, _ := tx.Preparex(pq.CopyIn(tablename, column, column, ...)

然后，我将继续向正在创建的体量插入添加行。

tx.Exec(..., ..., ...)

然后最后执行准备好的语句

stmt.Exec()

这以前工作得很好，但是现在我又回到了它，试着执行这个代码，它挂在

stmt.Exec

我是否在代码中遗漏了什么，或者这一切都与数据库引擎有关，没有响应。

这是我的完整代码。

package main

import (
    _ "database/sql"
    "fmt"
    "log"
    "encoding/json"
    "io/ioutil"
    "os"

    "github.com/jmoiron/sqlx"
    "github.com/lib/pq"
)

var schema = `
    CREATE TABLE IF NOT EXISTS contact (
        id Serial,
        first_name text,
        last_name text,
        email text
);`

type Contact struct {
    Id int            `json:"-"`
    First_name string `json:"first_name"`
    Last_name string  `json:"last_name"`
    Email string      `json:"email"`
}

type Contacts struct {
    Contacts []Contact `json:"contacts"`
}

func (c *Contacts) createFromJSON(json_str []byte) error {
    b := []byte(json_str)
    err := json.Unmarshal(b, &c)
    if err != nil {
        log.Fatal(err)
    }

    return err
}

func (c *Contacts) save(db *sqlx.DB) error {
    tx := db.MustBegin()

    stmt, _ := tx.Preparex(pq.CopyIn("contact", "first_name", "last_name", "email"))

    for _, contact := range c.Contacts {
        tx.Exec(contact.First_name, contact.Last_name, contact.Email)

    }

    _, err := stmt.Exec()

    if err != nil {
        log.Fatal(err)
        return err
    }
    err = stmt.Close()
    if err != nil {
        log.Fatal(err)
        return err
    }

    tx.Commit()

    return nil
}

func connect() (*sqlx.DB, error) {
    db, err := sqlx.Connect("postgres", "user=pqgotest dbname=pqgotest sslmode=disable")
    if err != nil {
        log.Fatal(err)
    }

    return db, err
}


func createTables(db *sqlx.DB) {
    db.MustExec(schema)
}


func main() {
    db, err := connect()
    if err != nil {
        os.Exit(1)
    }

    createTables(db)
    contactsJson, e := ioutil.ReadFile("./contacts.json")
    if e != nil {
        fmt.Printf("File error: %v\n", e)
        os.Exit(1)
    }

    tx := db.MustBegin()
    tx.MustExec("DELETE FROM contact")
    tx.Commit()

    contacts := new(Contacts)

    contacts.createFromJSON(contactsJson)

    contacts.save(db)

    people := new(Contacts)
    db.Select(people.Contacts, "SELECT * FROM contact ORDER BY email,id ASC")

    for _, contact := range people.Contacts {
        contact_json, err := json.Marshal(contact)
        if err != nil {
            log.Fatal(err)
            os.Exit(1)
        }
        fmt.Printf("%s\n", contact_json)
    }


}

如果有帮助的话，我也可以包括contacts.json文件的内容。

使现代化

是的，最后很明显。我在从tx创建一个声明，

stmt, _ := tx.Preparex(pq.CopyIn(tablename, column, column, ...)

进一步的补充应该是stmt

stmt.Exec(..., ..., ...)

另一个与这个问题不直接相关的错误是，我在结构联系人的联系人字段中插入了一个联系人数组

people := new(Contacts)
db.Select(people.Contacts, "SELECT * FROM contact ORDER BY email,id ASC")

应该传递一个指针，指向Contacts数组字段中Contacts的Select方法db，如下所示

db.Select(&people.Contacts, "SELECT * FROM contact ORDER BY email,id ASC")

以防人们稍后尝试运行此代码，并想知道为什么它没有将结果打印到控制台。

Answer 1

从大宗进口部分https://godoc.org/github.com/lib/pq，应该是

stmt.Exec(contact.First_name, contact.Last_name, contact.Email)