安装驱动

go get -u github.com/go-sql-driver/mysql

连接

db, err := sql.Open("mysql", "root:root@tcp(127.0.0.1:3306)/gorm_new_db")
if err != nil {
  log.Fatalf("数据库连接失败 %s", err)
}

执行sql

除查询外，使用Exec函数

package main

import (
  "database/sql"
  "fmt"
  _ "github.com/go-sql-driver/mysql"
  "log"
)

func main() {
  // 连接数据库
  db, err := sql.Open("mysql", "root:root@tcp(127.0.0.1:3306)/gorm_new_db")
  if err != nil {
    log.Fatalf("数据库连接失败 %s", err)
  }
  defer db.Close()
  _, err2 := db.Exec("CREATE TABLE users1(id INT NOT NULL , name VARCHAR(20), PRIMARY KEY(ID));")
  if err2 != nil {
    log.Fatal(err2)
  }

  fmt.Println("successfully create table")

}

查询sql

可以使用Query函数

package main

import (
  "database/sql"
  "fmt"
  _ "github.com/go-sql-driver/mysql"
  "log"
)

func main() {
  // 连接数据库
  db, err := sql.Open("mysql", "root:root@tcp(127.0.0.1:3306)/gorm_new_db")
  if err != nil {
    log.Fatalf("数据库连接失败 %s", err)
  }
  defer db.Close()

  res, err := db.Query("select id, name from users")
  for res.Next() {
    var id int
    var name string
    // 这里scan的字段要对上
    err = res.Scan(&id, &name)
    fmt.Println(id, name, err)
  }

}

可以使用QueryRow函数，查一行

package main

import (
  "database/sql"
  "fmt"
  _ "github.com/go-sql-driver/mysql"
  "log"
)

func main() {
  // 连接数据库
  db, err := sql.Open("mysql", "root:root@tcp(127.0.0.1:3306)/gorm_new_db")
  if err != nil {
    log.Fatalf("数据库连接失败 %s", err)
  }
  defer db.Close()

  var id int
  var name string
  // 这里scan的字段要对上
  err = db.QueryRow("select id, name from users").Scan(&id, &name)
  fmt.Println(id, name, err)

}