大並發情況下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