当我使用tikv api时,我发现它在TxnKV客户端有一个选项,然后我测试了它,但是我找不到tikv中乐观和悲观的区别是什么?
测试代码是这样的:
func begin() kv.Transaction{
transaction, err := store.Begin()
if err!=nil{
panic(err)
}
return transaction
}
func main() {
pdAddr := os.Getenv("PD_ADDR")
if pdAddr != "" {
os.Args = append(os.Args, "-pd", pdAddr)
}
flag.Parse()
initStore()
k2 := []byte("key2")
v22 := []byte("value22")
v23 := []byte("value22")
testTxn(k2,v22,v23)
}
func testTxn(k2 []byte, v22 []byte, v23 []byte) {
txn1, txn2 := begin(), begin()
txn1.SetOption(kv.Pessimistic, true)
fmt.Println("txn1 after:", txn1.IsPessimistic())
txn2.SetOption(kv.Pessimistic, true)
fmt.Println("txn2 after:", txn2.IsPessimistic())
err := txn1.Set(k2, v22)
if err != nil {
panic(err)
}
err = txn2.Set(k2, v23)
if err != nil {
panic(err)
}
err = txn1.Commit(context.Background())
if err != nil {
panic(err)
}
fmt.Println(get(k2))
err = txn2.Commit(context.Background())
if err != nil {
panic(err)
}
}
无论我设置与否txn1.SetOption(kv.Pessimistic, true)
,txn2.SetOption(kv.Pessimistic, true)
我都没有发现它们之间的区别。
但是在 tidb 或者 mysql 中,用悲观事务修改相同的记录,就会阻塞。
如交易A:
begin;
updata t1 set col ="value1" where id=1;
交易 B:
begin;
updata t1 set col ="value2" where id=1; //it will block until transaction A commit or rollback
我有两个问题:
- tikv的乐观和悲观有什么区别?
- tikv 的悲观锁和 mysql/tidb 的悲观锁有什么区别?
如果有人有任何想法,请与我分享,谢谢