Golang环境配置步骤

Golang环境配置步骤 需要下载的软件

1、下载 、安装 go 1.19.1

2、下载、安装 golang 2022.2.2
3、注册golang（官方注册）
4、安装并进入 golang。

golang配置

5、配置： File—> Setting…


6、配置上 go语言安装路径
说明：
Global GOPATH 设置 go语言安装路径
Project GOPATH 设置 不用填写
Use GOPATH … 不选择
Index entire GOPATH 选择

7、设置环境： GOPROXY=https://goproxy.cn

8、可以新建 工程 了

9、设置 工程编译运行

10、如果链接 mysql 数据库；命令行下

D:\go_test>go env -w GOPROXY=https://goproxy.cn

D:\go_test>go get -u github.com/go-sql-driver/mysql
go: downloading github.com/go-sql-driver/mysql v1.6.0
go: added github.com/go-sql-driver/mysql v1.6.0

表示mysql驱动 下载装配成功

以下是记录 go操作mysql

package main

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


// 数据库配置
const (
	userName = "root"
	password = "******"   //写上自己的密码
	ip       = "127.0.0.1"
	port     = "3306"
	dbName   = "test"
)

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

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

func main() {
	sum := 1 + 1
	fmt.Printf("huizong汇总002sum: %v\n", sum)

	InitDB()
	Query()
	defer DB.Close()

}

func mysql01() {
	DB, _ := sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/test")
	//设置数据库最大连接数
	DB.SetConnMaxLifetime(100)
	//设置上数据库最大闲置连接数
	DB.SetMaxIdleConns(10)
	//验证连接
	if err := DB.Ping(); err != nil {
		fmt.Println("open database fail")
		return
	}
	fmt.Println("connnect success")
}

// InitDB 注意方法名大写，就是public
func InitDB() {
	//构建连接："用户名:密码@tcp(IP:端口)/数据库?charset=utf8"
	path := strings.Join([]string{userName, ":", 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("connect success")
}

// Query 查询操作
func Query() {
	var user User
	//rows, e := DB.Query("select * from user where id in (1,2,3)")
	rows, e := DB.Query("select * from user ")
	if e == nil {
		errors.New("query incur error")
	}

	fmt.Println("测试开始。。。。。")
	for rows.Next() {
		e := rows.Scan(&user.id, &user.name, &user.age, &user.phone, &user.sex)
		if e != nil {
			fmt.Println(json.Marshal(user))
			fmt.Println(user.name)
			fmt.Println(user.id)
			fmt.Println(user.phone)
		}
	}
	rows.Close()

	DB.QueryRow("select * from user where id=1").Scan(&user.id, &user.name, &user.age, &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
}