go语言中mysql怎么使用

本篇内容介绍了“Go语言中mysql怎么使用”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

golang支持多种数据库

Mysql

mysql是一款关系型数据库管理系统，Mysql采用了双授权政策，可以将数据保存在不同的表中，从而增加数据库的速度和灵活性，具有体积小、速度快、总体拥有成本低的特点。

oracle

oracle是一款关系数据库管理系统，在数据库领域处于领先地位，领先地位具有可移植性好、使用方便、功能强的特点，适用于各类大、中、小、微机环境，是一种效率高、可靠性好、吞吐量高的数据库。

SQLite

SQLite是一款轻型数据库，其遵循ACID关系型数据库管理系统，其设计目的为嵌入式，所用可以在很多嵌入式产品中使用SQLite，同时可以和C#、PHP、Java等程序语言相结合使用。

MongoDB

mongoDB是一个基于分布式文件存储的数据库，其目的是为WEB应用提供可扩展的高性能数据存储方案，MongoDB支持的数据结构非常松散，且支持多查询语言和建立索引。

postgresql

PostgreSQL是一个功能强大、源代码开放的对象关系型数据库管理系统，具有复杂查询、外键、触发器、视图、事务完整性、多版本并发控制等特性，PostgreSQL可以通过函数在数据库服务器端执行指令程序，且用户可以自定义索引方法。

SQL Sever

SQL 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)    if err != nil {        fmt.Println("链接失败")    }    fmt.Println("链接成功")    f.db = db}

二、插入

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

三、查询

func (f *mysql_db) mysql_select(sql_data string) {   //select 查询数据    fmt.Println("sql:", sql_data)    rows, err := f.db.Query(sql_data)    if err != nil {        fmt.Println("查询失败")    }    for rows.Next() {        var departID int        var departName string        var memo string        err = rows.Scan(&departID, &departName, &memo)        if err != nil {            panic(err)        }        fmt.Println("departName:", departName)    }}

四、更新

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

五、删除

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

六、事物

func (f *mysql_db) mysql_tran(){    //事务    tx,err := f.db.Begin()        //声明一个事务的开始    if err != nil {        fmt.Println(err)        return    }    insert_sql := "insert into depart (departName,memo) VALUES(?,?)"    insert_stmt,insert_err := tx.Prepare(insert_sql)    if insert_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)    // defer tx.Rollback()            //回滚之前上面的last_login_id是有的，但在回滚后该操作没有被提交，被回滚了，所以上面打印的Last_login_id的这条数据是不存在与数据库表中的    tx.Commit()                        //这里提交了上面的操作，所以上面的执行的sql 会在数据库中产生一条数据}

调用

func main() {    db := &mysql_db{}    db.mysql_open()    db.mysql_insert()    db.mysql_update()    db.mysql_delete()    db.mysql_tran()    db.mysql_select("select departID,departName,memo from depart")    db.mysql_close() //关闭}

启动后输出如下：

D:\Go_Path\go\src\mysqldemo>go run mysqldemo.go链接成功开始插入插入成功0删除成功10sql: select departID,departName,memo from departdepartName: aadepartName: DDDepartName: dddepartName: dddepartName: dddepartName: dddepartName: ffdepartName: dddepartName: ff

完整代码

package mainimport (    "database/sql"    "fmt"    _ "GitHub.com/go-sql-driver/mysql"    )var (    dbhostsip  = "10.2.1.5:3306"    dbusername = "admin"    dbpassword = "123456"    dbname     = "irisapp")type mysql_db struct {    db *sql.DB}func (f *mysql_db) mysql_open() {    db, err := sql.Open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname)    if err != nil {        fmt.Println("链接失败")    }    fmt.Println("链接成功")    f.db = db}func (f *mysql_db) mysql_close() {    defer f.db.Close()}func (f *mysql_db) mysql_select(sql_data string) {   //select 查询数据    fmt.Println("sql:", sql_data)    rows, err := f.db.Query(sql_data)    if err != nil {        fmt.Println("查询失败")    }    for rows.Next() {        var departID int        var departName string        var memo string        err = rows.Scan(&departID, &departName, &memo)        if err != nil {            panic(err)        }        fmt.Println("departName:", departName)    }}func (f *mysql_db) mysql_insert() { //insert  添加数据    fmt.Println("开始插入")    stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)")    //defer stmt.Close()    if err != nil {        fmt.Println("插入失败")        return    }    stmt.Exec("dd", "adadcccda")    fmt.Println("插入成功")}func (f *mysql_db) mysql_update() { //update  修改数据    stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?")    //defer stmt.Close()    if err != nil {        //错误处理    }    result,_ := stmt.Exec("aa","asdfadsadsfa",1)    if result == nil {        fmt.Println("修改失败")    }    affect_count,_ := result.RowsAffected()    //返回影响的条数,注意有两个返回值    fmt.Println(affect_count)}func (f *mysql_db) mysql_delete() { //delete  删除数据    stmt, err := f.db.Prepare("delete from depart where departId=?")    //defer stmt.Close()    if err != nil {        //错误处理    }    stmt.Exec(2)     //不返回任何结果    fmt.Println("删除成功")}func (f *mysql_db) mysql_tran(){    //事务    tx,err := f.db.Begin()        //声明一个事务的开始    if err != nil {        fmt.Println(err)        return    }    insert_sql := "insert into depart (departName,memo) VALUES(?,?)"    insert_stmt,insert_err := tx.Prepare(insert_sql)    if insert_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)    // defer tx.Rollback()            //回滚之前上面的last_login_id是有的，但在回滚后该操作没有被提交，被回滚了，所以上面打印的Last_login_id的这条数据是不存在与数据库表中的    tx.Commit()                        //这里提交了上面的操作，所以上面的执行的sql 会在数据库中产生一条数据}func main() {    db := &mysql_db{}    db.mysql_open()    db.mysql_insert()    db.mysql_update()    db.mysql_delete()    db.mysql_tran()    db.mysql_select("select departID,departName,memo from depart")    db.mysql_close() //关闭}

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