我目前正在从事 Golang Google App Engine 项目，遇到了一个小问题。我有一个带有表“parties”的数据库“party”。问题是当执行以下代码时，会打印一个 EMPTY json 数组——它实际上很长，但它只包含空的 Parties。 (而且我的数据库中确实有条目)

Go 代码(不是全部):

func getParties(w http.ResponseWriter, r *http.Request) {
    rows := getRowsFromSql("select * from parties;")
    parties := scanForParties(rows)

    json, _ := json.Marshal(parties)
    fmt.Fprint(w, string(json))
}

func scanForParties(rows *sql.Rows) []Party {
    var parties []Party

    for rows.Next() {
        var id int
        var name, author, datetime, datetime_to, host, location, description, longtitude, latitude, primary_image_id string
        rows.Scan(&id, &name, &author, &datetime, &datetime_to, &host, &location, &description, &longtitude, &latitude, &primary_image_id)
        party := Party{
            Id:           id,
            Name:         name,
            Author:       author,
            Datetime:     datetime,
            Datetime_to:  datetime_to,
            Host:         host,
            Location:     location,
            Description:  description,
            Longtitude:   longtitude,
            Latitude:     latitude,
            PrimaryImgId: primary_image_id,
        }
        parties = append(parties, party)
    }

    return parties
}

func getRowsFromSql(query string) *sql.Rows {
    con, err := sql.Open("mysql", dbConnectString)
    if err != nil {
        panic(err)
    }
    defer con.Close()

    rows, err2 := con.Query(query)
    if err != nil {
        panic(err2)
    }
    return rows

}

type Party struct {
    Id           int
    Name         string
    Author       string
    Datetime     string
    Datetime_to  string
    Host         string
    Location     string
    Description  string
    Longtitude   string
    Latitude     string
    PrimaryImgId string
}

还有我的派对 table :

mysql> describe parties;
+------------------+----------------+------+-----+-------------------+-----------------------------+
| Field            | Type           | Null | Key | Default           | Extra                       |
+------------------+----------------+------+-----+-------------------+-----------------------------+
| id               | int(11)        | NO   | PRI | NULL              | auto_increment              |
| name             | varchar(64)    | NO   |     |                   |                             |
| author           | varchar(64)    | YES  |     | NULL              |                             |
| datetime         | datetime       | YES  |     | NULL              |                             |
| last_edited      | timestamp      | NO   |     | CURRENT_TIMESTAMP | on update CURRENT_TIMESTAMP |
| datetime_to      | datetime       | YES  |     | NULL              |                             |
| host             | text           | YES  |     | NULL              |                             |
| location         | text           | YES  |     | NULL              |                             |
| description      | text           | YES  |     | NULL              |                             |
| longitude        | decimal(23,20) | YES  |     | NULL              |                             |
| latitude         | decimal(23,20) | YES  |     | NULL              |                             |
| primary_image_id | varchar(256)   | YES  |     | NULL              |                             |
+------------------+----------------+------+-----+-------------------+-----------------------------+

但是，这个旧版本的代码工作得很好:

func getParties(w http.ResponseWriter, r *http.Request) {

    con, dbErr := sql.Open("mysql", dbConnectString)

    defer con.Close()

    if dbErr == nil {
        rows, _ := con.Query("select id, name, author, datetime from parties where datetime >= NOW();")

        var parties []Party

        var id int
        var name string
        var author string
        var datetime string

        for rows.Next() {
            rows.Scan(&id, &name, &author, &datetime)
            party := Party{}
            party.Id = id
            party.Name = name
            party.Author = author
            party.Datetime = datetime
            parties = append(parties, party)
        }

        if len(parties) > 0 {
            json, _ := json.Marshal(parties)
            fmt.Fprint(w, string(json))
        } else {
            fmt.Fprint(w, "{}")
        }

    } else {
        fmt.Fprint(w, "{\"Error\"}")
    }
}

知道为什么会这样吗？ 提前致谢:)

最佳答案

这是一个猜测，但我认为这是因为您要在此处关闭与数据库的连接:

defer con.Close()

这将在 getRowsFromSql 返回时关闭与数据库的连接，因此当您开始在 scanForParties 中调用 rows.Next() 时数据库连接消失了。关闭数据库连接后，任何行集合将不再可用。

某些东西可能因此而返回一个错误，但由于您没有在任何您不知道的地方检查任何错误。在 Go 中，只要函数可以返回一个错误就检查错误是惯用的(其他语言也是如此，在 Go 中更是如此，因为没有异常)。

关于mysql - go mysql 返回空值，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/29397645/