如何执行插入查询，其中参数的数据来自选择查询的结果集

Question

我正在尝试从位于另一台服务器中的一个数据库 (db) 获取数据，并将获取的数据插入另一台服务器中的另一个数据库 (db1)。到目前为止，我能够从数据库中选择数据，但无法将其插入到 db1 中。我在数据库中得到空值。任何帮助，将不胜感激。我的代码片段如下：func searchHandler(w http.ResponseWriter, r *http.Request) {dsn := "server=*****.ecc4q.****.com; user id=******; password=***************"db, err := sql.Open("mssql", dsn) if err != nil {    log.Fatal(err)}err = db.Ping()if err != nil {    log.Fatal(err)}rows, err := db.Query("select Incident_Number, Last_Resolved_Date, Corporate_ID from ITSM.dbo.HPD_Help_Desk_Classic")if err != nil {    log.Println(err)}defer db.Close()dsn1 := "server=******.md3q.***.com;user id=*****;password=********"db1, err := sql.Open("mssql", dsn1) if err != nil {    log.Fatal(err)}err = db1.Ping()if err != nil {    log.Fatal(err)}for rows.Next() {    err := rows.Scan(&Incident_Number, &Last_Resolved_Date, &Corporate_ID)        if err != nil {            log.Fatal(err)        }    stmt1, err := db1.Prepare("INSERT INTO mdesk.dbo.tbl_tcktinfo(TicketNumber, ResolvedDate, CDSID) VALUES(?,?,?)")        if err != nil {            log.Println(err)        }    res, err := stmt1.Exec(TicketNumber, ResolvedDate, CDSID)        if err != nil {            log.Println(err)        }    log.Println(Incident_Number, Last_Resolved_Date, Corporate_ID)}defer db1.Close() }

Answer 1

您将记录从以下行扫描到Incident_Number, Last_Resolved_Date,中：Corporate_ID

err := rows.Scan(&Incident_Number, &Last_Resolved_Date, &Corporate_ID)

但是你在Exec()函数中传递了不同的参数。您必须传递扫描变量才能将记录插入到不同的数据库表中。

stmt1, err := db1.Prepare("INSERT INTO mdesk.dbo.tbl_tcktinfo(TicketNumber, ResolvedDate, CDSID) VALUES(?,?,?)")

if err != nil {

    log.Fatal(err)

}

defer stmt1.Close() // always clean up after yourself, preferably return errors here, too

for rows.Next() {

    err := rows.Scan(&Incident_Number, &Last_Resolved_Date, &Corporate_ID)

        if err != nil {

            log.Fatal(err)

        }

    res, err := stmt1.Exec(Incident_Number, Last_Resolved_Date, Corporate_ID)

        if err != nil {

            log.Println(err)

        }

    log.Println(Incident_Number, Last_Resolved_Date, Corporate_ID)

}

Answer 2

添加到已接受的答案：我建议您多做一些事情以确保一致性，并更“负责任地”处理您的资源。你正在关闭你的数据库连接，当然，但我会养成以几乎相同的方式处理其他资源的习惯。

此外，如果中途出现问题，我强烈建议您将插入包装到事务中，而不是必须截断表并重新启动进程：

defer rows.Close() // close your rows resource

defer db1.Close() // close at the very end

tx, err := db1.BeginTx(context.Background(), nil) // pass in a context with timeout or some other cancelable context if needed

if err != nil {

    return err // I'm returning, you can do as you like with this

}

stmt, err := tx.Prepare("INSERT INTO ...") // create the statement once

defer stmt.Close() // add to defer stack

for rows.Next() {

     // instead of your Camel_Snake_Cased vars, I'm using the preferred style and camelCase your var names instead...

    if err := rows.Scan(&incidentNumber, &lastResolvedDate, &corporateID); err != nil {

       tx.Rollback() // rollback transaction

       return err

    }

    if err := stmt.Exec(incidentNumber, lastResolvedDate, corporateID); err != nil {

        tx.Rollback() // again, rollback...

        return err

    }

}

if err := tx.Commit(); err !≃ nil {

    tx.Rollback() // not needed, but I add it as a habit

    return err

}

return nil

现在重要的是要注意所有这些Close()函数和tx.Rollback()调用都返回错误。最好至少将它们包装在日志调用中，如下所示：

log.Printf("Rolling back: %+v", tx.Rollback())

// and

log.Printf("Closing DB/ROWS/STMT: %+v", db1.Close()) // same for rows, stmt etc..