go语言中mysql怎么使用

本篇内容介绍了“go语言中mysql怎么使用”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！golang支持多种数据库1、MySQLMySQL是一款关系型数据库管理系统，MySQL采用了双授权政策，可以将数据保存在不同的表中，从而增加数据库的速度和灵活性，具有体积小、速度快、总体拥有成本低的特点。2、Oracleoracle是一款关系数据库管理系统，在数据库领域处于领先地位，领先地位具有可移植性好、使用方便、功能强的特点，适用于各类大、中、小、微机环境，是一种效率高、可靠性好、吞吐量高的数据库。3、SQLiteSQLite是一款轻型数据库，其遵循ACID关系型数据库管理系统，其设计目的为嵌入式，所用可以在很多嵌入式产品中使用SQLite，同时可以和C#、PHP、Java等程序语言相结合使用。4、MongoDBMongoDB是一个基于分布式文件存储的数据库，其目的是为WEB应用提供可扩展的高性能数据存储方案，MongoDB支持的数据结构非常松散，且支持多查询语言和建立索引。5、PostgreSQLPostgreSQL是一个功能强大、源代码开放的对象关系型数据库管理系统，具有复杂查询、外键、触发器、视图、事务完整性、多版本并发控制等特性，PostgreSQL可以通过函数在数据库服务器端执行指令程序，且用户可以自定义索引方法。6、SQL SeverSQL Sever是一个关系型数据库管理系统，具有使用方便、可伸缩性好、相关软件集成程度高的优点，可以提供更安全可靠的存储性能，使用SQL Sever可以构建和管理用于业务的高可用和高性能的数据应用程序。golang操作MySQL数据库下面主要从增删查改以及事物等方面介绍go语言中mysql的使用一、连接数据库使用sql.Open()函数打开数据库连接，数据库的连接字符串（dsn）格式如下：

 admin:123456@tcp(10.2.1.5)/irisapp

代码如下：

 func(f*mysql_db)mysql_open(){
db,err:=sql.Open("mysql",dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname)
iferr!=nil{
fmt.Println("链接失败")
}
fmt.Println("链接成功")
f.db=db
}

二、插入

 func(f*mysql_db)mysql_insert(){//insert添加数据
fmt.Println("开始插入")
stmt,err:=f.db.Prepare("INSERTINTOdepart(departName,memo)VALUES(?,?)")
//deferstmt.Close()
iferr!=nil{
fmt.Println("插入失败")
return
}
stmt.Exec("dd","adadcccda")
fmt.Println("插入成功")
}

三、查询

 func(f*mysql_db)mysql_select(sql_datastring){//select查询数据
fmt.Println("sql:",sql_data)
rows,err:=f.db.Query(sql_data)
iferr!=nil{
fmt.Println("查询失败")
}
forrows.Next(){
vardepartIDint
vardepartNamestring
varmemostring
err=rows.Scan(&departID,&departName,&memo)
iferr!=nil{
panic(err)
}
fmt.Println("departName:",departName)
}
}

四、更新

 func(f*mysql_db)mysql_update(){//update修改数据
stmt,err:=f.db.Prepare("updatedepartsetdepartName=?,memo=?wheredepartId=?")
//deferstmt.Close()
iferr!=nil{
//错误处理
}
result,_:=stmt.Exec("aa","asdfadsadsfa",1)
ifresult==nil{
fmt.Println("修改失败")
}
affect_count,_:=result.RowsAffected()//返回影响的条数,注意有两个返回值
fmt.Println("%v",affect_count)
}

五、删除

 func(f*mysql_db)mysql_delete(){//delete删除数据
stmt,err:=f.db.Prepare("deletefromdepartwheredepartId=?")
//deferstmt.Close()
iferr!=nil{
//错误处理
}
stmt.Exec(2)//不返回任何结果
fmt.Println("删除成功")
}

六、事物

 func(f*mysql_db)mysql_tran(){
//事务
tx,err:=f.db.Begin()//声明一个事务的开始
iferr!=nil{
fmt.Println(err)
return
}
insert_sql:="insertintodepart(departName,memo)VALUES(免费云主机域名?,?)"
insert_stmt,insert_err:=tx.Prepare(insert_sql)
ifinsert_err!=nil{
fmt.Println(insert_err)
return
}
insert_res,insert_err:=insert_stmt.Exec("ff","ff")
last_insert_id,_:=insert_res.LastInsertId()
fmt.Println(last_insert_id)
//defertx.Rollback()//回滚之前上面的last_login_id是有的，但在回滚后该操作没有被提交，被回滚了，所以上面打印的Last_login_id的这条数据是不存在与数据库表中的
tx.Commit()//这里提交了上面的操作，所以上面的执行的sql会在数据库中产生一条数据
}

调用

 funcmain(){
db:=&mysql_db{}
db.mysql_open()
db.mysql_insert()
db.mysql_update()
db.mysql_delete()
db.mysql_tran()
db.mysql_select("selectdepartID,departName,memofromdepart")
db.mysql_close()//关闭
}

启动后输出如下：

 D:Go_Pathgosrcmysqldemo>gorunmysqldemo.go
链接成功
开始插入
插入成功
0
删除成功
10
sql:selectdepartID,departName,memofromdepart
departName:aa
departName:dd
departName:dd
departName:dd
departName:dd
departName:dd
departName:ff
departName:dd
departName:ff

完整代码

 packagemain

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

var(
dbhostsip="10.2.1.5:3306"
dbusername="admin"
dbpassword="123456"
dbname="irisapp"
)

typemysql_dbstruct{
db*sql.DB
}

func(f*mysql_db)mysql_open(){
db,err:=sql.Open("mysql",dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname)
iferr!=nil{
fmt.Println("链接失败")
}
fmt.Println("链接成功")
f.db=db
}

func(f*mysql_db)mysql_close(){
deferf.db.Close()
}

func(f*mysql_db)mysql_select(sql_datastring){//select查询数据
fmt.Println("sql:",sql_data)
rows,err:=f.db.Query(sql_data)
iferr!=nil{
fmt.Println("查询失败")
}
forrows.Next(){
vardepartIDint
vardepartNamestring
varmemostring
err=rows.Scan(&departID,&departName,&memo)
iferr!=nil{
panic(err)
}
fmt.Println("departName:",departName)
}

}

func(f*mysql_db)mysql_insert(){//insert添加数据
fmt.Println("开始插入")
stmt,err:=f.db.Prepare("INSERTINTOdepart(departName,memo)VALUES(?,?)")
//deferstmt.Close()
iferr!=nil{
fmt.Println("插入失败")
return
}
stmt.Exec("dd","adadcccda")
fmt.Println("插入成功")
}

func(f*mysql_db)mysql_update(){//update修改数据
stmt,err:=f.db.Prepare("updatedepartsetdepartName=?,memo=?wheredepartId=?")
//deferstmt.Close()
iferr!=nil{
//错误处理
}
result,_:=stmt.Exec("aa","asdfadsadsfa",1)
ifresult==nil{
fmt.Println("修改失败")
}
affect_count,_:=result.RowsAffected()//返回影响的条数,注意有两个返回值
fmt.Println(affect_count)
}

func(f*mysql_db)mysql_delete(){//delete删除数据
stmt,err:=f.db.Prepare("deletefromdepartwheredepartId=?")
//deferstmt.Close()
iferr!=nil{
//错误处理
}
stmt.Exec(2)//不返回任何结果
fmt.Println("删除成功")
}

func(f*mysql_db)mysql_tran(){
//事务
tx,err:=f.db.Begin()//声明一个事务的开始
iferr!=nil{
fmt.Println(err)
return
}
insert_sql:="insertintodepart(departName,memo)VALUES(?,?)"
insert_stmt,insert_err:=tx.Prepare(insert_sql)
ifinsert_err!=nil{
fmt.Println(insert_err)
return
}
insert_res,insert_err:=insert_stmt.Exec("ff","ff")
last_insert_id,_:=insert_res.LastInsertId()
fmt.Println(last_insert_id)
//defertx.Rollback()//回滚之前上面的last_login_id是有的，但在回滚后该操作没有被提交，被回滚了，所以上面打印的Last_login_id的这条数据是不存在与数据库表中的
tx.Commit()//这里提交了上面的操作，所以上面的执行的sql会在数据库中产生一条数据
}

funcmain(){
db:=&mysql_db{}
db.mysql_open()
db.mysql_insert()
db.mysql_update()
db.mysql_delete()
db.mysql_tran()
db.mysql_select("selectdepartID,departName,memofromdepart")
db.mysql_close()//关闭

}

“go语言中mysql怎么使用”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注百云主机网站，小编将为大家输出更多高质量的实用文章！

相关推荐: 如何用C语言代码求1到100的和

今天小编给大家分享一下如何用C语言代码求1到100的和的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们一起来了解一下吧。题目：求1+2+3+……+98+99+100…