从Mysql服务器读取数据

导入所需的包，然后准备一个与数据库中tb_student表的示例具有相同模式的结构体，稍后该结构体将用作查询结果的容器数据类型。

package main
import "fmt"
import "database/sql"
import _ "github.com/go-sql-driver/mysql"


type student struct {
 id string,
 name string,
 age int,
 grade int,
}

使用的数据库驱动需要使用_符号导入，因为尽管database/sql包需要它，但我们并不直接与驱动交互。

接下来，创建一个连接数据库的函数。

func connect() (*sql.DB, error) {
 db, err := sql.Open("mysql","root:@tcp(127.0.0.1:3306)/db_learn_go")
 if err != nil {
  return nil, err
 }
 return db, nil
}

我们使用的 mysql 驱动程序的连接字符串方案非常独特，下面的 root@tcp(127.0.0.1:3306)/db_learn_go 是可以在 go MYSQL Driver 驱动程序上使用的连接字符串方案，如果您使用另一个mysql，根据所使用的驱动程序，连接方案可能会有所不同。

user:password@tcp(host:port)/dbname
user@tcp(host:port)/dbname

下面是对 connect() 函数中使用的连接字符串的解释。

root@tcp(127.0.0.1:3306)/db_learn_go
// user => root
// password =>
// host => 127.0.0.1 atau localhost
// port => 3306
// dbname => db_learn_go

连接数据库的函数创建完成后，就可以练习从数据库服务器读取数据的过程了。准备函数
sqlQuery() 使用以下代码。

func sqlQuery() {
 db, err := connect()
 if err != nil {
 fmt.Println(err.Error())
 return
 }
 defer db.Close()
 var age = 27
 rows, err := db.Query("select id, name, grade from tb_student where age = ?
 if err != nil {
 fmt.Println(err.Error())
 return
 }
 defer rows.Close()
 var result []student
 for rows.Next() {
 var each = student{}
 var err = rows.Scan(&each.id, &each.name, &each.grade)
 if err != nil {
 fmt.Println(err.Error())
 return
 }
 result = append(result, each)
 }
 if err = rows.Err(); err != nil {
 fmt.Println(err.Error())
 return
 }
 for _, each := range result {
 fmt.Println(each.name)
 }
}

每次创建新连接时，不要忘记始终关闭连接实例。您可以使用 defer 关键字，如上面的代码所示，defer
db.Close() .
db.Query()函数用于执行sql查询。该函数的第二个参数是可变参数，因此可以留空。在上面的代码中，您可以看到其中一个 where 子句的值为问号 (?)。

该符号将被其后面的参数中的值（年龄变量的值）替换。强烈推荐这种类型的查询编写技术，以防止 SQL 注入。该函数生成一个 sql.*Rows 类型的实例，当不再使用时也需要将其关闭（ defer rows.Close() ）。接下来，准备一个元素类型为 struct Student 且名称为 result 的数组。稍后查询结果将存储在变量中。然后执行循环，条件引用为 rows.Next() 。该循环执行的次数与记录总数相同，从第一条记录到最后一条记录依次执行。 sql.Rows 的 Scan() 方法用于检索正在迭代的记录的值，并将其存储在指针变量中。根据查询中选择的字段，用于存储记录字段的变量被顺序写入为可变参数。请参阅下面的比较以了解更多详细信息。 // 查询
选择 ID、姓名、年级...
// 扫描
rows.Scan(&each.id, &each.name, &each.grade ...
然后将获得的记录数据通过语句
附加到结果切片中 结果=附加（结果，每个）。
好的，现在只需在 main 中调用 sqlQuery() 函数，然后运行程序即可。

func main() {
sqlQuery()
}

我只是一个普通的博客作者。如果还有太多不足之处还请见谅。

以上是从Mysql服务器读取数据的详细内容。更多信息请关注PHP中文网其他相关文章！