File tree Expand file tree Collapse file tree 2 files changed +16
-7
lines changed Expand file tree Collapse file tree 2 files changed +16
-7
lines changed Original file line number Diff line number Diff line change @@ -32,7 +32,7 @@ def callee(session):
32
32
33
33
tx .begin ()
34
34
35
- tx .execute ("""INSERT INTO example (key, value) VALUES (0033 , "onepieceisreal");""" )
35
+ tx .execute ("""INSERT INTO example (key, value) VALUES (0055 , "onepieceisreal");""" )
36
36
37
37
for result_set in tx .execute ("""SELECT COUNT(*) FROM example;""" ):
38
38
print (f"rows: { str (result_set .rows )} " )
@@ -52,7 +52,7 @@ def callee(session):
52
52
53
53
tx .begin ()
54
54
55
- tx .execute ("""INSERT INTO example (key, value) VALUES (0044 , "onepieceisreal");""" )
55
+ tx .execute ("""INSERT INTO example (key, value) VALUES (0066 , "onepieceisreal");""" )
56
56
57
57
for result_set in tx .execute ("""SELECT COUNT(*) FROM example;""" ):
58
58
print (f"rows: { str (result_set .rows )} " )
Original file line number Diff line number Diff line change
1
+ __all__ = [
2
+ "QueryOnlineReadOnly" ,
3
+ "QuerySerializableReadWrite" ,
4
+ "QuerySnapshotReadOnly" ,
5
+ "QueryStaleReadOnly" ,
6
+ "QuerySessionPool" ,
7
+ "QueryClientSync"
8
+ ]
9
+
1
10
from .base import (
2
11
IQueryClient ,
3
12
SupportedDriverType ,
7
16
from .session import QuerySessionSync
8
17
9
18
from .._grpc .grpcwrapper .ydb_query_public_types import (
10
- QueryOnlineReadOnly , # noqa
11
- QuerySerializableReadWrite , # noqa
12
- QuerySnapshotReadOnly , # noqa
13
- QueryStaleReadOnly , # noqa
19
+ QueryOnlineReadOnly ,
20
+ QuerySerializableReadWrite ,
21
+ QuerySnapshotReadOnly ,
22
+ QueryStaleReadOnly ,
14
23
)
15
24
16
- from .pool import QuerySessionPool # noqa
25
+ from .pool import QuerySessionPool
17
26
18
27
19
28
class QueryClientSync (IQueryClient ):
You can’t perform that action at this time.
0 commit comments