真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

Golang是如何使用mysql數(shù)據(jù)庫的？

今天簡單介紹下Golang是如何使用MySQL數(shù)據(jù)庫的。由于Go本身不提供具體數(shù)據(jù)庫驅(qū)動，只提供驅(qū)動接口和管理。各個數(shù)據(jù)庫驅(qū)動需要第三方實(shí)現(xiàn)，并且注冊到Go中的驅(qū)動管理中。github上面的mysql驅(qū)動有好幾個，我在這里選擇的:

成都創(chuàng)新互聯(lián)公司專注于雨山網(wǎng)站建設(shè)服務(wù)及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗(yàn)。 熱誠為您提供雨山營銷型網(wǎng)站建設(shè)，雨山網(wǎng)站制作、雨山網(wǎng)頁設(shè)計、雨山網(wǎng)站官網(wǎng)定制、小程序開發(fā)服務(wù)，打造雨山網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供雨山網(wǎng)站排名全網(wǎng)營銷落地服務(wù)。

https://github.com/go-sql-driver/mysql

下面主要從增刪查改以及事物等方面介紹go語言中mysql的使用

一、連接數(shù)據(jù)庫

使用sql.Open()函數(shù)打開數(shù)據(jù)庫連接，數(shù)據(jù)庫的連接字符串（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  添加數(shù)據(jù)
    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 查詢數(shù)據(jù)
    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  修改數(shù)據(jù)
    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()    //返回影響的條數(shù),注意有兩個返回值
    fmt.Println("%v",affect_count)
}

五、刪除

func (f *mysql_db) mysql_delete() { //delete  刪除數(shù)據(jù)
    stmt, err := f.db.Prepare("delete from depart where departId=?")
    //defer stmt.Close()
    if err != nil {
        //錯誤處理
    }
    stmt.Exec(2)     //不返回任何結(jié)果
    fmt.Println("刪除成功")
}

六、事物

func (f *mysql_db) mysql_tran(){
    //事務(wù)
    tx,err := f.db.Begin()        //聲明一個事務(wù)的開始
    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的這條數(shù)據(jù)是不存在與數(shù)據(jù)庫表中的
    tx.Commit()                        //這里提交了上面的操作，所以上面的執(zhí)行的sql 會在數(shù)據(jù)庫中產(chǎn)生一條數(shù)據(jù)
}

調(diào)用

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() //關(guān)閉
}

啟動后輸出如下：

D:\Go_Path\go\src\mysqldemo>go run mysqldemo.go
鏈接成功
開始插入
插入成功
0
刪除成功
10
sql: select departID,departName,memo from depart
departName: aa
departName: dd
departName: dd
departName: dd
departName: dd
departName: dd
departName: ff
departName: dd
departName: 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 查詢數(shù)據(jù)
    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  添加數(shù)據(jù)
    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  修改數(shù)據(jù)
    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()    //返回影響的條數(shù),注意有兩個返回值
    fmt.Println(affect_count)
}

func (f *mysql_db) mysql_delete() { //delete  刪除數(shù)據(jù)
    stmt, err := f.db.Prepare("delete from depart where departId=?")
    //defer stmt.Close()
    if err != nil {
        //錯誤處理
    }
    stmt.Exec(2)     //不返回任何結(jié)果
    fmt.Println("刪除成功")
}

func (f *mysql_db) mysql_tran(){
    //事務(wù)
    tx,err := f.db.Begin()        //聲明一個事務(wù)的開始
    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的這條數(shù)據(jù)是不存在與數(shù)據(jù)庫表中的
    tx.Commit()                        //這里提交了上面的操作，所以上面的執(zhí)行的sql 會在數(shù)據(jù)庫中產(chǎn)生一條數(shù)據(jù)
}

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() //關(guān)閉

}

總結(jié)

1. 支持預(yù)備表達(dá)式，可以用來優(yōu)化SQL查詢提高性能，減少SQL注入的風(fēng)險, db.Prepare()和 tx.Prepare 都提供了對于預(yù)備表達(dá)式的支持。

2. LastInsertId()　　獲取插入第一條的id

3. RowsAffected()　　獲取影響/插入的條數(shù)

4. 這里只是簡單介紹了go語言開發(fā)中mysql在go語言開發(fā)中的基本使用，其實(shí)真正開發(fā)過程中還是主要使用orm相關(guān)第三方框架，但是底層原理還是要學(xué)的。

以上就是golang使用什么數(shù)據(jù)庫？的詳細(xì)內(nèi)容，更多請關(guān)注創(chuàng)新互聯(lián)其它相關(guān)文章！


新聞標(biāo)題：Golang是如何使用mysql數(shù)據(jù)庫的？
鏈接地址：http://weahome.cn/article/gsjcpi.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220（工作日）

18980820575（7×24）

提交需求

返回頂部