Skip to content

Commit 832d53c

Browse files
committed
fix execute text query with params
1 parent e58371e commit 832d53c

File tree

2 files changed

+11
-2
lines changed

2 files changed

+11
-2
lines changed

tests/table/table_test.py

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
import decimal
12
import ydb
23

34

@@ -27,3 +28,13 @@ def create_table(session: ydb.Session):
2728

2829
res = driver_sync.scheme_client.describe_path(table_path)
2930
assert res.type == ydb.scheme.SchemeEntryType.TABLE
31+
32+
def test_select_text_query_with_params(self, driver_sync):
33+
def select(session: ydb.Session):
34+
text_query = "DECLARE $v AS Int64; SELECT $v"
35+
session.prepare(text_query)
36+
with session.transaction() as tx:
37+
tx.execute(text_query, {"$v": 1})
38+
39+
pool = ydb.SessionPool(driver=driver_sync)
40+
pool.retry_operation_sync(select)

ydb/_tx_ctx_impl.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,5 @@ def wrap_result_and_tx_id(rpc_state, response_pb, session_state, tx_state, query
159159
issues._process_response(response_pb.operation)
160160
message = _apis.ydb_table.ExecuteQueryResult()
161161
response_pb.operation.result.Unpack(message)
162-
if message.query_meta.id:
163-
session_state.keep(query, message.query_meta.id)
164162
tx_state.tx_id = None if not message.tx_meta.id else message.tx_meta.id
165163
return convert.ResultSets(message.result_sets, session_state.table_client_settings)

0 commit comments

Comments
 (0)