Go-MySQL-Driver，让Go语言拥抱MySQL

开源地址：https://github.com/go-sql-driver/mysql

正如官方所说，Go-MySQL-Driver是一个Go的sql或数据库操作包。

• 纯粹的Go语言实现，轻量级和快速
• z支持TCP/IPv4, TCP/IPv6, Unix域套接字或自定义协议
• 自动处理断开的连接，自动连接池(通过数据库/sql包)
• 支持大于16MB的查询
• 完整的sql体系，智能长数据处理

CREATE TABLE `student` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(255) DEFAULT NULL,
  `age` int(2) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;

在项目根目录下执行：

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

package main

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

var my_db *sql.DB     //数据库
var my_tb = "student" //表名


type Student struct {
   Id   int    
   Name string 
   Age  int
}


func init() {
   var err error
   my_db, err = sql.Open("mysql", "root:12345678@tcp(127.0.0.1:3306)/test")
   my_db.SetConnMaxLifetime(100 * time.Second) // 超时时间
   my_db.SetMaxOpenConns(0)                    // 设置最大打开的连接数，默认值为0表示不限制。
   my_db.SetMaxIdleConns(16)                   // 设置闲置的连接数
   if err != nil {
      fmt.Println("连接失败")
   }
   fmt.Println("连接成功") // 检查是否连接成功数据库
}


func FindAllStudent() []Student {
   var students []Student
   var stu Student
   rows, err := my_db.Query("SELECt * FROM " + my_tb)
   if err != nil {
      return nil
   }
   for rows.Next() {
      err := rows.Scan(&stu.Id, &stu.Name, &stu.Age)
      if err != nil {
         return nil
      }
      students = append(students, stu)
   }
   return students
}


func SaveAdminPwd(stu Student) bool {
   tx, err := my_db.Begin()
   if err != nil {
      return false
   }
   stmt, err := tx.Prepare("INSERT INTO " + my_tb + "(id,name,age) VALUES (?,?,?)")
   if err != nil {
      return false
   }
   result, err := stmt.Exec(stu.Id, stu.Name, stu.Age)
   tx.Commit()
   if err != nil {
      return false
   }
   println(result)
   return true
}


func DeleteStudentById(id int) bool {
   tx, err := my_db.Begin()
   if err != nil {
      return false
   }
   stmt, err := tx.Prepare("DELETE  FROM " + my_tb + " WHERe id=?")
   if err != nil {
      return false
   }
   result, err := stmt.Exec(id)
   if err != nil {
      return false
   }
   tx.Commit() //别忘
   println(result)
   return true
}


func GetStudentById(id int) Student {
   var stu Student
   stmt, err := my_db.Prepare("SELECt * FROM " + my_tb + " WHERe id=?")
   rows, err := stmt.Query(id)
   if err != nil {
      return Student{}
   }
   if rows.Next() {
      err := rows.Scan(&stu.Id, &stu.Name,&stu.Age)
      if err != nil {
         return Student{}
      }
   }
   return stu
}


func UpdateStudentById(stu Student) bool {
   prepare, err := my_db.Prepare("UPDATE " + my_tb + " SET name=?,age=? WHERe id=?")
   if err != nil {
      return false
   }
   exec, err := prepare.Exec(stu.Name, stu.Age, stu.Id)
   if err != nil {
      return false
   }
   print(exec)
   return true
}


func main() {
   stu := Student{3, "ww", 32}
   SaveAdminPwd(stu)
   //DeleteStudentById(2)
   studentById := GetStudentById(3)
   fmt.Println(studentById)
   UpdateStudentById(Student{3,"zsss",21})
   s := GetStudentById(3)
   fmt.Println(s)
   students := FindAllStudent()
   for _, stu := range students {
      fmt.Println(stu)
   }
}

~