为什么我在向Postgres插入数据后,即使插入成功,也会收到“ErrNoRows(sql:no rows in result set)”的错误提示?

8

我正在使用golang-postgres进行工作:

"database/sql"
_ "github.com/lib/pq"

我在做什么:

我运行了一个选择查询。如果在选择时没有找到任何条目,我会继续插入一个。否则,更新或其他操作...

问题是,每次插入返回ErrNoRows("sql: no rows in result set"),即使我可以在数据库中看到插入成功并添加了一行。

此外,lastInsertID始终保持为0,而如果我在数据库中检查,则具有实际值(例如131)

似乎代码下面的注释2附近的错误被缓存了,并再次显示出来。

// 1. Select first
sQueryStmt, sPrepErr := db.Prepare(selectQuery)
    if sPrepErr != nil {
        glog.V(3).Infof("selectQuery prepare failed. err: %v", sPrepErr)
        return sPrepErr
    }

    queryErr := sQueryStmt.QueryRow(today, itemID).Scan(&a, &b, &c, &d, &e, &f, &g, &h, &i, &j)
    if queryErr != nil {

// 2. Getting ErrNoRows here is expected, for the first entry
        if queryErr == sql.ErrNoRows {
            glog.V(3).Infof("selectQuery returned no results. err: %v", queryErr)

            var lastInsertID int
            iQueryStmt, iPrepErr := db.Prepare(insertQuery)
            if iPrepErr != nil {
                glog.V(3).Infof("insertQuery prepare failed. err: %v", iPrepErr)
                return iPrepErr
            }
            insertErr := iQueryStmt.QueryRow(today, today, today, taskID).Scan(&lastInsertID)
            if insertErr != nil {
                // 3. Somehow, even after row is correctly being created, I am getting insertErr as "sql: no rows in result set" here
                glog.V(3).Infof("insertQuery failed. err: %v", insertErr)
            } else {
// control never comes to this part.
                glog.V(3).Infof("insertQuery Successful. lastInsertID: %v", lastInsertID)
            }
        } else {
            glog.V(3).Infof("Couldn't run query on Postgres database. err: %v", queryErr)
            return queryErr
        }
}

database/sql 内部调试时,显示它在下面的代码块中返回了这个错误:

    if !r.rows.Next() {
        if err := r.rows.Err(); err != nil {
            return err
        }
        return ErrNoRows
    }

但每次查询数据库时,数据总是已经被插入

编辑:

selectQuery = `select task_id, creation_date, times_x_ran,
                        a_count, b_count, c_count, d_count, e_count 
                        from reports where creation_date = $1 and task_id = $2`

insertQuery = `insert into reports 
                (creation_date, creation_time, last_modified, task_id, times_x_ran, times_y_ran, a, b, c, d, e, x_errors, y_errors) 
                    values 
                    ($1, $2, $3, $4,
                    1, 0, 
                    0, 0, 0, 0, 0, 
                    '', '' )`

2
你能展示一下你的查询内容吗?insertQuery/selectQuery字符串是什么?我问这个是因为如果你的insertQuery没有返回语句,也就是没有东西可以扫描,你会得到这个错误。 - mkopriva
已更新问题。 - Tushar
3
您的插入查询语句没有返回任何内容,因此调用Scan(&lastInsertedID)将始终导致该错误。 - mkopriva
这是您需要的内容:https://www.postgresql.org/docs/9.5/dml-returning.html - mkopriva
1
好的,明白了。谢谢伙计。 我想我只需要添加“返回id”。 - Tushar
1个回答

12

您实际上提出了两个问题,我会分别回答:

  1. 即使插入成功,为什么会出现ErrNoRows?

    这是预期的行为,因为默认情况下,INSERT不返回任何行。你的“错误”并不真正成问题。如果您希望INSERT返回行,请在末尾使用'RETURNING'子句。

    “结果集中没有行”的状态通过错误进行通信可能是您困惑的原因。但是只有当您期望行时才应将其视为错误。

  2. lastInsertID始终保持为0。

    这也是预期的行为。如文档所述:

      

    pq不支持database/sql中Result类型的LastInsertId()方法。要返回INSERT(或UPDATE或DELETE)的标识符,请使用带有标准Query或QueryRow调用的Postgres RETURNING子句:


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接