数据库查询
在连接数据库之后,我们可以使用DB.Query()
函数执行SQL查询语句,并将查询结果保存到*sql.Rows
类型的对象中。以下是一个使用DB.Query()
函数查询一张表中的所有数据的示例:
goCopy coderows, err := db.Query("SELECT * FROM users")
if err != nil {
panic(err)
}
defer rows.Close()
for rows.Next() {
var id int
var name string
var age int
err = rows.Scan(&id, &name, &age)
if err != nil {
panic(err)
}
fmt.Println(id, name, age)
}
err = rows.Err()
if err != nil {
panic(err)
}
在上述代码中,我们调用db.Query()
函数执行一个SELECT语句,并将结果保存到*sql.Rows
类型的对象中。我们通过迭代*sql.Rows
对象中的每一行数据来处理查询结果。在迭代每一行数据时,我们调用rows.Scan()`方法将每一行数据保存到变量中,并打印出来。
最后,我们还需要检查查询过程中是否出现了错误。如果出现了错误,我们将通过rows.Err()
方法获取到错误信息,并进行相应的处理。