百木园-与人分享,
就是让自己快乐。

GO web 开发 实战,数据库预处理 技术学习分享

咱们其实可以使用 mysql 预处理的方式来操作这些

那么我们一起来看看什么是已处理呢?

什么是预处理?

了解什么是预处理,我们可以来对比一下,普通的 sql 语句执行过程和 预处理的执行过程

普通 sql 语句执行过程:

  • 客户端对 SQL 语句进行 占位符 替换得到完整的 sql 语句
  • 客户端发送完整 sql 语句到 mysql 服务端
  • mysql 服务端执行完整的 sql 语句并将结果返回给客户端

预处理执行过程:

  • 把 sql 语句分成两部

    • 命令部分
    • 数据部分
  • 先把命令部分发送给 mysql 服务端,mysql 服务端进行 sql 预处理
  • 然后把数据部分发送给 mysql 服务端, mysql 服务端对 sql 语句进行占位符替换
  • mysql 服务端执行完整的 sql 语句并将结果返回给客户端

通过步骤和流程,我们大概知道预处理肯定比普通的 sql 执行快

 

 

 

 

 薪资:底薪加绩效(最高底薪50%)

👨🏻‍💻钉钉:马新宇 9455510168
👨🏻‍💻Lark(海外版飞书):maxinyu202212@outlook.com
👨🏻‍💻letstalk: t395300395
👨🏻‍💻telegram:@youmiboss @HRdajisi
👨🏻‍💻谷歌邮箱: blueice19931204@gmail.com
👨🏻‍💻Skype: live:.cid.d850fdc83f05e44a

那么预处理有啥好处?

    • 优化 mysql 服务器重复执行 sql 的方法,可以提升服务器性能,提前让服务器编译,一次编译多次
      执行,节省后续编译的成本
    • 避免 sql 注入的问题

//预处理 插入数据操作
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实现 MySQL 的事务

  • 开启事务处理,会有回滚机制,全部成功了,且提交成功,才算事务处理成功
  • func (db *DB) Begin() (*Tx, error) 事务开始
  • func (tx *Tx) Commit() error 事务提交
  • func (tx *Tx) Rollback() error 事务回滚

    func trasaction(db *sql.DB) {
    
        //开启一个事务
    
        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
        }
    
        //提交事务
        err = tx.Commit()
        if err != nil {
            if tx != nil {
                tx.Rollback()
            }
            fmt.Printf(\"Commit err :%v\", err)
            return
        }
    
        fmt.Println(\"commit success \")
    }

    sqlx使用

    咱们还可以使用第三方库 sqlx

    • 安装第三方库 sqlx ,go get github.com/jmoiron/sqlx
    • 第三方库可以提交高开发效率,简化开发操作

    package main
    
    import (
        \"fmt\"
        \"github.com/jmoiron/sqlx\"
        _ \"github.com/go-sql-driver/mysql\" // 注释掉后异常 _ 调用初始化函数
    )
    
    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)
    
        //插入数据
        insertInfo()
    }

    gin + mysql + rest full api

    当然 之前说到的 http 包里面的方法实现,我们也不需要用它了,咱们也可以交给框架,真的是可以做到高效实现业务,但同时,自己下来还是要去对具体的实现原理多研究研究

    实践如下步骤:

    • 导入 github.com/gin-gonic/gin 库
    • 建立 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;

      <img src=\"https://p3-juejin.byteimg.com/tos-cn-i-k3u1fbpfcp/d8827a4583814e2cb9567af33ddbd3eb~tplv-k3u1fbpfcp-zoom-1.image\" style=\"zoom:100%;\"/>

    上图是实践过程中产生的数据

    • 包装对数据库的增删改查操作
    • 写路由的操作
     

来源:https://www.cnblogs.com/blueice1204/p/17132896.html
本站部分图文来源于网络,如有侵权请联系删除。

未经允许不得转载:百木园 » GO web 开发 实战,数据库预处理 技术学习分享

相关推荐

  • 暂无文章