把 sql 語(yǔ)句分成兩部
- 命令部分
- 數(shù)據(jù)部分
先把命令部分發(fā)送給 mysql 服務(wù)端，mysql 服務(wù)端進(jìn)行 sql 預(yù)處理
然后把數(shù)據(jù)部分發(fā)送給 mysql 服務(wù)端， mysql 服務(wù)端對(duì) sql 語(yǔ)句進(jìn)行占位符替換
mysql 服務(wù)端執(zhí)行完整的 sql 語(yǔ)句并將結(jié)果返回給客戶端

通過(guò)步驟和流程，我們大概知道預(yù)處理肯定比普通的 sql 執(zhí)行快

那么預(yù)處理有啥好處？

優(yōu)化 mysql 服務(wù)器重復(fù)執(zhí)行 sql 的方法，可以提升服務(wù)器性能，提前讓服務(wù)器編譯，一次編譯多次執(zhí)行，節(jié)省后續(xù)編譯的成本
避免 sql 注入的問(wèn)題

//預(yù)處理 插入數(shù)據(jù)操作
func prepareInfo(db *sql.DB) {
 sqlInfo := "insert into user (name,age)values(?,?)"

 stmt, err := db.Prepare(sqlInfo)
 if err != nil {
  fmt.Println("Exec err : ", err)
  return
 }

 ret, err := stmt.Exec("花豬2", 28)
 if err != nil {
  fmt.Println("stmt Exec err : ", err)
  return
 }
 ret, err = stmt.Exec("花豬3", 28)
 if err != nil {
  fmt.Println("stmt Exec err : ", err)
  return
 }

 rows, err := ret.RowsAffected()
 if err != nil {
  fmt.Println("stmt Exec err : ", err)
  return
 }
 fmt.Println("rows = ", rows)

}

Go實(shí)現(xiàn) MySQL 的事務(wù)

開(kāi)啟事務(wù)處理，會(huì)有回滾機(jī)制，全部成功了，且提交成功，才算事務(wù)處理成功

func (db *DB) Begin() (*Tx, error) 事務(wù)開(kāi)始
func (tx *Tx) Commit() error 事務(wù)提交
func (tx *Tx) Rollback() error 事務(wù)回滾

func trasaction(db *sql.DB) {

 //開(kāi)啟一個(gè)事務(wù)

 tx, err := db.Begin()
 if err != nil {
  if tx != nil {
   tx.Rollback()
  }
  fmt.Printf("Begin err :%v", err)
  return
 }

 sqlStr := "update user set name='xxx' where id=?"
 _, err = tx.Exec(sqlStr, 9)
 if err != nil {
  if tx != nil {
   tx.Rollback()
  }
  fmt.Printf("Exec err :%v", err)
  return
 }

 sqlStr = "update user set name='xxx' where id=?"
 _, err = tx.Exec(sqlStr, 6)
 if err != nil {
  if tx != nil {
   tx.Rollback()
  }
  fmt.Printf("Exec err :%v", err)
  return
 }

    //提交事務(wù)
 err = tx.Commit()
 if err != nil {
  if tx != nil {
   tx.Rollback()
  }
  fmt.Printf("Commit err :%v", err)
  return
 }

 fmt.Println("commit success ")
}

sqlx使用

咱們還可以使用第三方庫(kù) sqlx

安裝第三方庫(kù) sqlx ，go get github.com/jmoiron/sqlx
第三方庫(kù)可以提交高開(kāi)發(fā)效率，簡(jiǎn)化開(kāi)發(fā)操作

package main

import (
 "fmt"
 "github.com/jmoiron/sqlx"
 _ "github.com/go-sql-driver/mysql" // 注釋掉后異常 _ 調(diào)用初始化函數(shù)
)

var db *sqlx.DB

func insertInfo() {

 sqlStr := "insert into user(name,age)values(?,?)"
 res, err := db.Exec(sqlStr, "xxx", 2)
 if err != nil {
  fmt.Printf("Exec err : %v", err)
  return
 }
 id, err := res.LastInsertId()
 if err != nil {
  fmt.Printf("LastInsertId err : %v", err)
  return
 }
 fmt.Printf("id == %d", id)

 rows, err := res.RowsAffected()
 if err != nil {
  fmt.Printf("RowsAffected err : %v", rows)
  return
 }
 fmt.Printf("rows == %d", rows)
 return

}

func main() {

 var err error
 dsn := "root:123456@tcp(127.0.0.1:3306)/go_test?charset=utf8mb4"
 db, err = sqlx.Connect("mysql", dsn)
 if err != nil {
  fmt.Printf("Connect err : %v\n", err)
  return
 }
 db.SetMaxOpenConns(20)
 db.SetMaxIdleConns(10)

 //插入數(shù)據(jù)
 insertInfo()
}

gin + mysql + rest full api

當(dāng)然之前說(shuō)到的 http 包里面的方法實(shí)現(xiàn)，我們也不需要用它了，咱們也可以交給框架，真的是可以做到高效實(shí)現(xiàn)業(yè)務(wù)，但同時(shí)，自己下來(lái)還是要去對(duì)具體的實(shí)現(xiàn)原理多研究研究

實(shí)踐如下步驟：

導(dǎo)入 github.com/gin-gonic/gin 庫(kù)
建立 users 表， id，name，telephone字段

CREATE TABLE `users` (
`id` BIGINT(20) NOT NULL AUTO_INCREMENT,
`name` VARCHAR(20) DEFAULT '',
`telephone` VARCHAR(20) DEFAULT  '',
PRIMARY KEY(`id`)
)ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT 
CHARSET=utf8mb4;

上圖是實(shí)踐過(guò)程中產(chǎn)生的數(shù)據(jù)

包裝對(duì)數(shù)據(jù)庫(kù)的增刪改查操作
寫路由的操作

到此這篇關(guān)于GO web 數(shù)據(jù)庫(kù)預(yù)處理的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)GO 數(shù)據(jù)庫(kù)預(yù)處理內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: