如何使用mysql数据库【Golang 入门系列十】

2020-06-18 00:00:00 数据 数据库 成功 插入 失败

之前,已经讲过一些Golang的基础的东西,感兴趣的可以看看以前的文章,https://www.cnblogs.com/zhangweizhong/category/1275863.html,

今天简单介绍下Golang是如何使用mysql数据库的。由于Go本身不提供具体数据库驱动,只提供驱动接口和管理。各个数据库驱动需要第三方实现,并且注册到Go中的驱动管理中。github上面的mysql驱动有好几个,我在这里选择的https://github.com/go-sql-driver/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链接成功开始插入插入成功删除成功10sql: select departID,departName,memo from departdepartName: aadepartName: dddepartName: dddepartName: dddepartName: dddepartName: dddepartName: ffdepartName: dddepartName: ff


完整代码 

package main
import ( "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() //关闭
}

 

总结

1. 支持预备表达式,可以用来优化SQL查询提高性能,减少SQL注入的风险, db.Prepare()和 tx.Prepare 都提供了对于预备表达式的支持。

2. LastInsertId()  获取插入条的id

3. RowsAffected()  获取影响/插入的条数

4. 这里只是简单介绍了go语言开发中mysql在go语言开发中的基本使用,其实真正开发过程中还是主要使用orm相关第三方框架,但是底层原理还是要学的。


相关文章