大并发情况下mysql 如何解决脏数据


package main

import "fmt"

import "database/sql"
import _ "github.com/go-sql-driver/mysql"
import "time"

func main() {

ch := make(chan int, 10)

go searchsql(ch)
go searchsql(ch)
go searchsql(ch)
time.Sleep(1 * time.Second)
}

func searchsql(p <-chan int) {
var id int
var account string
db, err := sql.Open("mysql", "root:password@tcp(192.168.0.31:3306)/app?charset=utf8")
if err != nil {
fmt.Println("failed to open database:", err.Error())
return
}
tx, _ := db.Begin()
rows, err := tx.Query("select id,account from accounts where flag=0 limit 1 for update")

if err != nil {
fmt.Println("fetech data failed:", err.Error())
return
}
defer rows.Close()
for rows.Next() {
rows.Scan(&id, &account)
fmt.Println("id:", id, "name:", account)
}
tx.Exec("update accounts set flag=? where id=?", "1", id)
tx.Commit()
defer db.Close()
}

  


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM