File tree Expand file tree Collapse file tree 3 files changed +6
-7
lines changed Expand file tree Collapse file tree 3 files changed +6
-7
lines changed Original file line number Diff line number Diff line change @@ -19,13 +19,13 @@ def main():
19
19
pool = ydb .QuerySessionPool (driver )
20
20
# with pool.checkout() as session:
21
21
def callee (session ):
22
- print ("=" * 50 )
22
+ print ("=" * 50 )
23
23
print ("BEFORE ACTION" )
24
24
it = session .execute ("""SELECT COUNT(*) FROM example;""" )
25
25
for result_set in it :
26
26
print (f"rows: { str (result_set .rows )} " )
27
27
28
- print ("=" * 50 )
28
+ print ("=" * 50 )
29
29
print ("INSERT WITH COMMIT TX" )
30
30
tx = session .transaction ()
31
31
@@ -38,13 +38,13 @@ def callee(session):
38
38
39
39
tx .commit ()
40
40
41
- print ("=" * 50 )
41
+ print ("=" * 50 )
42
42
print ("AFTER COMMIT TX" )
43
43
44
44
for result_set in session .execute ("""SELECT COUNT(*) FROM example;""" ):
45
45
print (f"rows: { str (result_set .rows )} " )
46
46
47
- print ("=" * 50 )
47
+ print ("=" * 50 )
48
48
print ("INSERT WITH ROLLBACK TX" )
49
49
50
50
tx = session .transaction ()
@@ -58,7 +58,7 @@ def callee(session):
58
58
59
59
tx .rollback ()
60
60
61
- print ("=" * 50 )
61
+ print ("=" * 50 )
62
62
print ("AFTER ROLLBACK TX" )
63
63
64
64
for result_set in session .execute ("""SELECT COUNT(*) FROM example;""" ):
Original file line number Diff line number Diff line change 19
19
from .tracing import * # noqa
20
20
from .topic import * # noqa
21
21
from .draft import * # noqa
22
- from .query import * # noqa
22
+ from .query import * # noqa
23
23
24
24
try :
25
25
import ydb .aio as aio # noqa
Original file line number Diff line number Diff line change @@ -155,7 +155,6 @@ def create_execute_query_request(
155
155
exec_mode : QueryExecMode = None ,
156
156
parameters : dict = None ,
157
157
concurrent_result_sets : bool = False ,
158
-
159
158
):
160
159
syntax = QuerySyntax .YQL_V1 if not syntax else syntax
161
160
exec_mode = QueryExecMode .EXECUTE if not exec_mode else exec_mode
You can’t perform that action at this time.
0 commit comments