咱们其实可以使用 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%;\"/>
上图是实践过程中产生的数据
- 包装对数据库的增删改查操作
- 写路由的操作
- 安装第三方库 sqlx ,
来源:https://www.cnblogs.com/blueice1204/p/17132896.html
本站部分图文来源于网络,如有侵权请联系删除。