Go语言连接数据库驱动安装和示例

Posted 2022-03-28 boonya

目录

安装driver

 处理驱动

连接mysql示例 

---

安装driver

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

执行命令会报错，因为地址被墙了。

需要修改代理：

go env -w GOPROXY=https://goproxy.cn

执行成功！

 处理驱动

需要在错误的引入处删掉手动让IDE提示加入，这样就不会报错了。

连接mysql示例 

示例来源：Go连接MYSQL - rickiyang - 博客园

package main

import (
	"database/sql"
	"encoding/json"
	"fmt"
	_ "github.com/go-sql-driver/mysql"
	"github.com/pkg/errors"
	"strings"
)

//数据库配置
const (
	userName = "root"
	password = "123456"
	ip       = "127.0.0.1"
	port     = "3306"
	dbName   = "test"
)

//Db数据库连接池
var DB *sql.DB

type User struct 
	id    int64
	name  string
	age   int8
	sex   int8
	phone string


//注意方法名大写，就是public
func InitDB() 
	//构建连接："用户名:密码@tcp(IP:端口)/数据库?charset=utf8"
	path := strings.Join([]stringuserName, ":", password, "@tcp(", ip, ":", port, ")/", dbName, "?charset=utf8", "")
	//打开数据库,前者是驱动名，所以要导入： _ "github.com/go-sql-driver/mysql"
	DB, _ = sql.Open("mysql", path)
	//设置数据库最大连接数
	DB.SetConnMaxLifetime(100)
	//设置上数据库最大闲置连接数
	DB.SetMaxIdleConns(10)
	//验证连接
	if err := DB.Ping(); err != nil 
		fmt.Println("open database fail")
		return
	
	fmt.Println("connnect success")


//查询操作
func Query() 
	var user User
	rows, e := DB.Query("select * from user where id in (1,2,3)")
	if e == nil 
		errors.New("query incur error")
	
	for rows.Next() 
		e := rows.Scan(user.sex, user.phone, user.name, user.id, user.age)
		if e != nil 
			fmt.Println(json.Marshal(user))
		
	
	rows.Close()
	DB.QueryRow("select * from user where id=1").Scan(user.age, user.id, user.name, user.phone, user.sex)

	stmt, e := DB.Prepare("select * from user where id=?")
	query, e := stmt.Query(1)
	query.Scan()


func DeleteUser(user User) bool 
	//开启事务
	tx, err := DB.Begin()
	if err != nil 
		fmt.Println("tx fail")
	
	//准备sql语句
	stmt, err := tx.Prepare("DELETE FROM user WHERE id = ?")
	if err != nil 
		fmt.Println("Prepare fail")
		return false
	
	//设置参数以及执行sql语句
	res, err := stmt.Exec(user.id)
	if err != nil 
		fmt.Println("Exec fail")
		return false
	
	//提交事务
	tx.Commit()
	//获得上一个insert的id
	fmt.Println(res.LastInsertId())
	return true


func InsertUser(user User) bool 
	//开启事务
	tx, err := DB.Begin()
	if err != nil 
		fmt.Println("tx fail")
		return false
	
	//准备sql语句
	stmt, err := tx.Prepare("INSERT INTO user (`name`, `phone`) VALUES (?, ?)")
	if err != nil 
		fmt.Println("Prepare fail")
		return false
	
	//将参数传递到sql语句中并且执行
	res, err := stmt.Exec(user.name, user.phone)
	if err != nil 
		fmt.Println("Exec fail")
		return false
	
	//将事务提交
	tx.Commit()
	//获得上一个插入自增的id
	fmt.Println(res.LastInsertId())
	return true


func main() 
	InitDB()

	user:= Username: "boonya",phone: "18081829343"
	InsertUser(user)

	Query()

	defer DB.Close()