一.查询注意点

  • Golang中执行查询与新增、删除、修改中stmt的执行方法有区别,由于需要把查询到的结果取出来,所以还需要进行取值处理

二.代码示例

  1. package main
  3. import (
  4.    "fmt"
  5.    //驱动已经放入到标准库文件夹,由于不使用所以需要空导入,在前面添加_
  6.    _ "github.com/go-sql-driver/mysql"
  7.    //Golang中数据库操作包
  8.    "database/sql"
  9. )
  11. func main() {
  12.    /*
  13.    第一个参数:连接什么数据库
  14.    第二个参数:连接字符串
  15.    语法:数据库登录用户名:密码@tcp(mysql主机ip:端口)/database名称
  16.     */
  17.    db,err:=sql.Open("mysql","root:root@tcp(localhost:3306)/first")
  18.    db.Ping()
  19.    //Error处理
  20.    if err!=nil{
  21.       fmt.Println("数据库连接失败")
  22.    }
  23.    //关闭连接
  24.    defer func() {
  25.       if db!=nil{
  26.          db.Close()
  27.          fmt.Println("关闭连接")
  28.       }
  29.    }()
  30.    /*
  31.       准备处理SQL语句
  32.       支持占位符,防止SQL注入
  33.     */
  34.    stmt,err:=db.Prepare("select * from people")
  35.    //错误处理
  36.    if err!=nil{
  37.       fmt.Println("预处理失败",err)
  38.    }
  39.    //关闭对象
  40.    defer func() {
  41.       if stmt!=nil{
  42.          stmt.Close()
  43.          fmt.Println("stmt关闭")
  44.       }
  45.    }()
  46.    /*
  47.    Exec() 参数为不定项参数,对应占位符?个数
  48.     */
  49.    rows,err:=stmt.Query()
  50.    if err!=nil{
  51.       fmt.Println("查询失败",err)
  52.    }
  53.    //循环遍历结果
  54.    for rows.Next(){
  55.       var id int
  56.       var name,address string
  57.       //把行内值付给变量
  58.       rows.Scan(&id,&name,&address)
  59.       fmt.Println(id,name,address)
  60.    }
  61.    defer func() {
  62.       if rows!=nil{
  63.          rows.Close()
  64.          fmt.Println("关闭结果集")
  65.       }
  66.    }()
  67. }