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

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}
/**删除一个根据id*/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}
/**使用main函数测试*/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)   }}