@@ -44,23 +44,19 @@ Successfully installed tikv-client-0.1.0
44
44
Python TiKV client is synchronous by defult:
45
45
46
46
``` python
47
- from tikv_client import TransactionClient
47
+ from tikv_client import RawClient
48
48
49
- client = TransactionClient .connect(" 127.0.0.1:2379" )
49
+ client = RawClient .connect([ " 127.0.0.1:2379" ] )
50
50
51
- txn = client.begin(pessimistic = True )
52
- txn.put(b " k1" , b " v1" )
53
- txn.put(b " k2" , b " v2" )
54
- txn.put(b " k3" , b " v3" )
55
- txn.put(b " k4" , b " v4" )
56
- txn.put(b " k5" , b " v5" )
57
- txn.commit()
51
+ client.put(b " k1" , b " v1" )
52
+ client.put(b " k2" , b " v2" )
53
+ client.put(b " k3" , b " v3" )
54
+ client.batch_put({b " k4" : b " v4" , b " k5" : b " v5" })
58
55
59
- snapshot = client.snapshot(client.current_timestamp())
60
- print (snapshot.get(b " k3" ))
61
- print (snapshot.batch_get([b " k1" , b " k4" ]))
56
+ print (client.get(b " k3" ))
57
+ print (client.batch_get([b " k1" , b " k4" ]))
62
58
63
- for k, v in snapshot .scan(b " k1" , end = None , limit = 10 , include_start = False ):
59
+ for k, v in client .scan(b " k1" , end = None , limit = 10 , include_start = False ):
64
60
print (k, v)
65
61
```
66
62
@@ -71,7 +67,7 @@ import asyncio
71
67
from tikv_client.asynchronous import TransactionClient
72
68
73
69
async def main ():
74
- client = await TransactionClient.connect(" 127.0.0.1:2379" )
70
+ client = await TransactionClient.connect([ " 127.0.0.1:2379" ] )
75
71
76
72
txn = await client.begin(pessimistic = True )
77
73
await txn.put(b " k1" , b " v1" )
@@ -81,7 +77,7 @@ async def main():
81
77
await txn.put(b " k5" , b " v5" )
82
78
await txn.commit()
83
79
84
- snapshot = client.snapshot(await client.current_timestamp())
80
+ snapshot = client.snapshot(await client.current_timestamp(), pessimistic = True )
85
81
print (await snapshot.get(b " k3" ))
86
82
print (await snapshot.batch_get([b " k1" , b " k4" ]))
87
83
0 commit comments