Go语言中怎么利用CURD操作MySQL，针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

创建好 Go 项目，需要引用驱动依赖：

goget-ugithub.com/go-sql-driver/mysql

使用 MySQL 驱动：

funcOpen(driverName,dataSourceNamestring)(*DB,error)

Open 打开一个 dirverName 指定的数据库，dataSourceName 指定数据源，一般至少包括数据库文件名和其它连接必要的信息。

初始化连接

vardb*sql.DB//声明一个全局的db变量//初始化MySQL函数funcinitMySQL()(errerror){dsn:="root:password@tcp(127.0.0.1:3306)/dbname"db,err=sql.Open("mysql",dsn)iferr!=nil{return}err=db.Ping()iferr!=nil{return}return}funcmain(){//初始化MySQLerr:=initMySQL()iferr!=nil{panic(err)}deferdb.Close()}

初始化连接 MySQL 后需要借助 db.Ping 函数来判断连接是否成功。

SetMaxOpenConns

func(db*DB)SetMaxOpenConns(nint)

SetMaxOpenConns设置与数据库建立连接的最大数目。

如果 n 大于 0 且小于最大闲置连接数，会将最大闲置连接数减小到匹配最大开启连接数的限制。

如果 n <= 0，不会限制最大开启连接数，默认为0（无限制）。

SetMaxIdleConns

func(db*DB)SetMaxIdleConns(nint)

SetMaxIdleConns设置连接池中的最大闲置连接数。

如果 n 大于最大开启连接数，则新的最大闲置连接数会减小到匹配最大开启连接数的限制。

如果 n <= 0，不会保留闲置连接。

CURD

进行 CURD 操作，需要对数据库建立连接，同时有供操作的数据（数据库与数据表）：

初始化数据

建立数据库 sql_demo

CREATEDATABASEsql_demo;USEsql_demo;

创建数据表 user

CREATETABLE`user`(`id`BIGINT(20)NOTNULLAUTO_INCREMENT,`name`VARCHAR(20)DEFAULT'',`age`INT(11)DEFAULT'0',PRIMARYKEY(`id`))ENGINE=InnoDBAUTO_INCREMENT=1DEFAULTCHARSET=utf8mb4;

查询 SELECT

便于接收数据，定义一个 user 结构体接收数据：

typeuserstruct{idintageintnamestring}

查询一行数据

db.QueryRow() 执行一次查询，并期望返回最多一行结果（即 Row ）。QueryRow 总是返回非 nil 的值，直到返回值的 Scan 方法被调用时，才会返回被延迟的错误。（如：未找到结果）

func(db*DB)QueryRow(querystring,args...interface{})*Row

实例代码如下：

//查询一行数据funcqueryRowDemo()(u1*user,errerror){//声明查询语句sqlStr:="SELECTid,name,ageFROMuserWHEREid=?"//声明一个user类型的变量varuuser//执行查询并且扫描至uerr=db.QueryRow(sqlStr,1).Scan(&u.id,&u.age,&u.name)iferr!=nil{returnnil,err}u1=&ureturn}funcmain(){//初始化MySQLerr:=initMySQL()iferr!=nil{panic(err)}deferdb.Close()u1,err:=queryRowDemo()iferr!=nil{fmt.Printf("err:%s",err)}fmt.Printf("id:%d,age:%d,name:%s\n",u1.id,u1.age,u1.name)」

结果如下：

id:1,age:111,name:22

多行查询

db.Query()执行一次查询，返回多行结果（即 Rows ），一般用于执行 select 命令。参数 args 表示 query 中的占位参数。

func(db*DB)Query(querystring,args...interface{})(*Rows,error)

实例代码如下：

//查询多行数据funcqueryMultiRowDemo(){sqlStr:="SELECTid,name,ageFROMuserWHEREid>?"rows,err:=db.Query(sqlStr,0)iferr!=nil{fmt.Printf("querydatafailed，err:%s\n",err)return}//查询完数据后需要进行关闭数据库链接deferrows.Close()forrows.Next(){varuusererr:=rows.Scan(&u.id,&u.age,&u.name)iferr!=nil{fmt.Printf("scandatafailed,err:%v\n",err)return}fmt.Printf("id:%dname:%sage:%d\n",u.id,u.name,u.age)}}

执行结果：

id:1name:111age:22id:3name:张三age:22

使用 rows.Next() 循环读取结果集中的数据。

增加数据 INSERT

增加、删除、更新操作均使用 Exec 方法。

func(db*DB)Exec(querystring,args...interface{})(Result,error)

实例代码如下：

//增加一行数据funcinsertRowDemo(){sqlStr:="INSERTINTOuser(name,age)VALUES(?,?)"result,err:=db.Exec(sqlStr,"小羽",22)iferr!=nil{fmt.Printf("insertdatafailed,err:%v\n",err)return}id,err:=result.LastInsertId()iferr!=nil{fmt.Printf("getinsertlastInsertIdfailed,err:%v\n",err)return}fmt.Printf("insertsuccess,id:%d\n",id)}

执行结果：

insertsuccess,id:4

更新数据 UPDATE

//更新一组数据funcupdateRowDemo(){sqlStr:="UPDATEuserSETage=?WHEREid=?"result,err:=db.Exec(sqlStr,22,1)iferr!=nil{fmt.Printf("updatedatafailed,err:%v\n",err)return}n,err:=result.RowsAffected()iferr!=nil{fmt.Printf("getrowsaffectedfailed,err:%v\n",err)return}fmt.Printf("updatesuccess,affectedrows:%d\n",n)}

删除数据 DELETE

//删除一行数据funcdeleteRowDemo(){sqlStr:="DELETEFROMuserWHEREid=?"result,err:=db.Exec(sqlStr,2)iferr!=nil{fmt.Printf("deletedatafailed,err:%d\n",err)return}n,err:=result.RowsAffected()iferr!=nil{fmt.Printf("getaffectedfailed,err:%v\n",err)return}fmt.Printf("deletesuccess,affectedrows:%d\n",n)}

关于Go语言中怎么利用CURD操作MySQL问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注亿速云行业资讯频道了解更多相关知识。