golang實現(xiàn)MySQL預(yù)處理的方法

這篇文章運用簡單易懂的例子給大家介紹golang實現(xiàn)MySQL預(yù)處理的方法，代碼非常詳細，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。

預(yù)處理

預(yù)處理是 MySQL 為了防止客戶端頻繁請求的一種技術(shù)，是對相同處理語句進行預(yù)先加載在 MySQL 中，將操作變量數(shù)據(jù)用占位符來代替，減少對 MySQL 的頻繁請求，使得服務(wù)器高效運行。

在這里客戶端并不是前臺后臺之間的 C/S 架構(gòu)，而是后臺程序?qū)?shù)據(jù)庫服務(wù)器進行操作的 C/S 架構(gòu)，這樣就可以簡要地理解了后臺程序作為 Client 向 MySQL Server 請求并處理結(jié)果了。

普通 SQL 執(zhí)行處理過程：

1. 在客戶端準備 SQL 語句；
2. 發(fā)送 SQL 語句到 MySQL 服務(wù)器；
3. 在 MySQL 服務(wù)器執(zhí)行該 SQL 語句；
4. 服務(wù)器將執(zhí)行結(jié)果返回給客戶端。

預(yù)處理執(zhí)行處理過程：

1. 將 SQL 拆分為結(jié)構(gòu)部分與數(shù)據(jù)部分；
2. 在執(zhí)行 SQL 語句的時候，首先將前面相同的命令和結(jié)構(gòu)部分發(fā)送給 MySQL 服務(wù)器，讓 MySQL 服務(wù)器事先進行一次預(yù)處理（此時并沒有真正的執(zhí)行 SQL 語句）；
3. 為了保證 SQL 語句的結(jié)構(gòu)完整性，在第一次發(fā)送 SQL 語句的時候?qū)⑵渲锌勺兊臄?shù)據(jù)部分都用一個數(shù)據(jù)占位符來表示；
4. 然后把數(shù)據(jù)部分發(fā)送給 MySQL 服務(wù)端，MySQL 服務(wù)端對 SQL 語句進行占位符替換；
5. MySQL 服務(wù)端執(zhí)行完整的 SQL 語句并將結(jié)果返回給客戶端。

預(yù)處理優(yōu)點

• 預(yù)處理語句大大減少了分析時間，只做了一次查詢（雖然語句多次執(zhí)行）；
• 綁定參數(shù)減少了服務(wù)器帶寬，只需發(fā)送查詢的參數(shù)，而不是整個語句；
• 預(yù)處理語句針對** SQL 注入**是非常有用的，因為參數(shù)值發(fā)送后使用不同的協(xié)議，保證了數(shù)據(jù)的合法性。

Go 語言實現(xiàn)

在 Go 語言中，使用 db.Prepare() 方法實現(xiàn)預(yù)處理：

func (db *DB) Prepare(query string) (*Stmt, error)

Prepare 執(zhí)行預(yù)處理 SQL 語句，并返回 Stmt 結(jié)構(gòu)體指針，進行數(shù)據(jù)綁定操作。

查詢操作使用 db.Prepare() 方法聲明預(yù)處理 SQL，使用 stmt.Query() 將數(shù)據(jù)替換占位符進行查詢，更新、插入、刪除操作使用 stmt.Exec() 來操作。

預(yù)處理查詢示例

// 預(yù)處理查詢數(shù)據(jù)func prepareQuery() {
    sqlStr := "SELECT id,name,age FROM user WHERE id > ?"
    stmt, err := db.Prepare(sqlStr)
    if err != nil {
        fmt.Printf("prepare sql failed, err:%v\n", err)
        return
    }
    rows, err := stmt.Query(1)
    if err != nil {
        fmt.Printf("exec failed, err:%v\n", err)
        return
    }
    defer rows.Close()

    for rows.Next() {
        var u user
        err := rows.Scan(&u.id, &u.name, &u.age)
        if err != nil {
            fmt.Printf("scan data failed, err:%v\n", err)
            return
        }
        fmt.Printf("id:%d, name:%s, age:%d\n", u.id, u.name, u.age)
    }}

預(yù)處理更新示例

// 預(yù)處理更新數(shù)據(jù)func prepareUpdate() {
    sqlStr := "UPDATE user SET age = ? WHERE id = ?"
    stmt, err := db.Prepare(sqlStr)
    if err != nil {
        fmt.Printf("prepare sql failed, err:%v\n", err)
        return
    }
    _, err = stmt.Exec(18, 2)
    if err != nil {
        fmt.Printf("exec failed, err:%v\n", err)
        return
    }
    fmt.Printf("prepare update data success")}

預(yù)處理插入示例

// 預(yù)處理更新數(shù)據(jù)func prepareUpdate() {
    sqlStr := "UPDATE user SET age = ? WHERE id = ?"
    stmt, err := db.Prepare(sqlStr)
    if err != nil {
        fmt.Printf("prepare sql failed, err:%v\n", err)
        return
    }
    _, err = stmt.Exec(18, 2)
    if err != nil {
        fmt.Printf("exec failed, err:%v\n", err)
        return
    }
    fmt.Printf("prepare update data success")}

預(yù)處理刪除示例

// 預(yù)處理刪除數(shù)據(jù)func prepareDelete() {
    sqlStr := "DELETE FROM user WHERE id = ?"
    stmt, err := db.Prepare(sqlStr)
    if err != nil {
        fmt.Printf("prepare sql failed, err:%v\n", err)
        return
    }
    result, err := stmt.Exec(3)
    n, err := result.RowsAffected()
    if err != nil {
        fmt.Printf("delete rows failed, err:%v\n", err)
        return
    }
    if n > 0 {
        fmt.Printf("delete data success")
    } else {
        fmt.Printf("delete data error")
    }

關(guān)于golang實現(xiàn)MySQL預(yù)處理的方法就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。