Java转go，个人觉得学习一门新的语言最重要的是可以将我们已经实现的项目通过新的语言实现，这样可以快速看到效果不至于失去了兴趣。作为web 开发，无论是单体架构也好，还是微服务架构也好，最基本的还是增删改查。所以mvc模式以及与数据库交互的逻辑都是通用的，可以通过增删改查入门一个框架，然后再详细学习，循序渐进。
准备条件
go 的orm 框架这里选择的是gorm
go mod 管理
1、引入相关的依赖下载相关的依赖
由于go 讲究没有的代码要删除，所以必须先import 然后使用 go mod tidy 下载
2、建立数据库连接
建立数据库连接实际上是tcp 连接，那么 IP + 端口 以及数据库等都是固定需要的,然后就是用户名，密码，驱动。在go中比较简单，将这些参数都合并在一起,DSN参数就是我们的root:pass@tpc(ip+端口)/数据库。使用数据库连接池，提高线程复用。建立config,创建连接配置方法。
package config
import (
"fmt"
"gorm.io/driver/mysql"
"gorm.io/gorm"
"time"
)
type MysqlDS struct {
}
func NewMysqlDS() *MysqlDS {
return &MysqlDS{}
}
var DB *gorm.DB
func (this *MysqlDS) InitMysql() {
DB = this.MysqlConn()
}
func (this *MysqlDS)MysqlConn() (Db * gorm.DB) {
//1、设置dsn
Db, err := gorm.Open(mysql.New(mysql.Config{
DSN: "root:@Zsaoesanm123034@tcp(192.51.63.14:3306)/majorshunt?charset=utf8&parseTime=True&loc=Local", // Data Source Name，参考 #dsn-data-source-name
}), &gorm.Config{})
if err != nil {
fmt.Println("数据库连接失败")
}
sqlDB, _ := Db.DB()
sqlDB.SetMaxIdleConns(10) // SetMaxIdleConns 设置空闲连接池中连接的最大数量
sqlDB.SetMaxOpenConns(100) // SetMaxOpenConns 设置打开数据库连接的最大数量。
sqlDB.SetConnMaxLifetime(time.Hour) // SetConnMaxLifetime 设置了连接可复用的最大时间。
return
}
2、创建模型结构体
定义 model 层，也就是java 的bean，例如我们创建一个model
type Student struct {
SID string `db:"id" json:"id"` //主键
SName string `db:"s_name" json:"s_name"` //姓名
SGpa float64 `db:"s_gpa" json:"s_gpa"` //绩点
MId int `db:"m_id" json:""` //专业代号
SPass string `db:"s_pass" json:"s_pass"` //学号
SPhone string `db:"s_phone" json:"s_phone"` //电话号码
SYear string `db:"s_year" json:"s_year"` //入学年份
CId string `db:"c_id" json:"c_id"` //所属学院
TId int `db:"t_id" json:"t_id"` //所属类别
SGrade string `db:"s_grade" json:"s_grade"` //所属年级
SSex int `db:"s_sex" json:"s_sex"` //性别
SClass string `db:"s_class" json:"s_class"` //班级
SRank int `db:"s_rank" json:"s_rank"` //排名
SEnroll string `db:"s_enroll" json:"s_enroll"` //录取号
}
func NewStudent() *Student {
return &Student{}
}
//按照用户名密码进行查询
func (this *Student) List(where map[string]interface{}) (totalCount int64, StudentList []Student, err error) {
connectDb := config.DB
if err := connectDb.
Where(where).
Table("majorshunt.student").
Count(&totalCount).
Find(&StudentList).
Error; err != nil {
return totalCount, StudentList, err
}
return totalCount, StudentList, nil
}
//添加学生
func (this *Student) AddStudent(StudentModel Student) (string,error){
connectDb := config.DB
this = &StudentModel
res := connectDb.Table("majorshunt.student").Create(this)
if res.Error != nil {
return "0", res.Error
}
return this.SID, nil
}
//修改学生 修改 sId的数据
func (this *Student) UpdateStudent(StudentModel Student,sId string) (err error){
connectDb := config.DB
err = connectDb.
Table("majorshunt.student").
Where("s_id = ?", sId).
Updates(StudentModel).Error
return
}
//删除学生
func (this *Student) DelStudent(sId string) (err error){
connectDb := config.DB
err = connectDb.
Table("majorshunt.student").
Where("s_id = ?", sId).
Delete(this).Error
return err
}
3、在main 函数中执行
func main() {
//增加
AddStudent()
//查询
SelectStudentList()
//修改
UpdateStudent()
//查询
SelectStudentList()
//删除
DelStudent()
}
func init() {
//初始化 mysql连接
config.NewMysqlDS().InitMysql()
//初始化 redis
config.NewRedisConf().InitRedis()
}
func SelectStudentList() {
//构造条件
params := make(map[string]interface{},1)
params["s_id"] = "031740317"
totalCount,data,_ := model.NewStudent().List(params)
fmt.Println(totalCount," ",data)
}
func AddStudent(){
//构造Student 数据
student :=model.Student{
SID: "031740317",
SName: "赵德满",
}
sId,_ := model.NewStudent().AddStudent(student)
if sId != ""{
fmt.Println("插入成功")
}else {
fmt.Println("插入失败")
}
}
func DelStudent(){
err := model.NewStudent().DelStudent("031740317")
if err == nil{
fmt.Println("删除成功")
}else {
fmt.Println("删除失败")
}
}
func UpdateStudent() {
student := model.Student{
SID: "031740317",
SName: "zhaodeman",
}
err := model.NewStudent().UpdateStudent(student,"031740317")
if err == nil{
fmt.Println("修改成功")
}else {
fmt.Println(err)
}
}
4、总结
简单就是美
