@@ -133,7 +133,7 @@ def callee(session):
133
133
return pool .retry_operation_sync (callee )
134
134
135
135
136
- def select_prepared (pool , path , series_id , season_id , episode_id ):
136
+ def select_parametrized (pool , path , series_id , season_id , episode_id ):
137
137
def callee (session ):
138
138
query = """
139
139
PRAGMA TablePathPrefix("{}");
@@ -171,7 +171,7 @@ def callee(session):
171
171
commit_tx = True ,
172
172
settings = ydb .table .ExecDataQuerySettings ().with_keep_in_cache (True ),
173
173
)
174
- print ("\n > select_prepared_transaction :" )
174
+ print ("\n > select_parametrized_transaction :" )
175
175
for row in result_sets [0 ].rows :
176
176
print ("episode title:" , row .title , ", air date:" , row .air_date )
177
177
@@ -180,8 +180,8 @@ def callee(session):
180
180
return pool .retry_operation_sync (callee )
181
181
182
182
183
- # Prepared query with session-based cache (obsolete)
184
- def select_prepared_session_based (pool , path , series_id , season_id , episode_id ):
183
+ # Prepared query with session-based cache
184
+ def select_prepared (pool , path , series_id , season_id , episode_id ):
185
185
def callee (session ):
186
186
query = """
187
187
PRAGMA TablePathPrefix("{}");
@@ -386,5 +386,8 @@ def run(endpoint, database, path):
386
386
select_prepared (pool , full_path , 2 , 3 , 7 )
387
387
select_prepared (pool , full_path , 2 , 3 , 8 )
388
388
389
+ select_parametrized (pool , full_path , 2 , 3 , 9 )
390
+ select_parametrized (pool , full_path , 2 , 3 , 10 )
391
+
389
392
explicit_tcl (pool , full_path , 2 , 6 , 1 )
390
- select_prepared (pool , full_path , 2 , 6 , 1 )
393
+ select_parametrized (pool , full_path , 2 , 6 , 1 )
0 commit comments