Skip to content

Commit 1be2af6

Browse files
authored
Merge pull request #286 fix execute text query with params
2 parents eb5a8ec + c38dc49 commit 1be2af6

File tree

2 files changed

+10
-2
lines changed

2 files changed

+10
-2
lines changed

tests/table/table_test.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,3 +37,13 @@ def create_table(session: ydb.Session):
3737

3838
res = driver_sync.scheme_client.describe_path(table_path)
3939
assert res.type == ydb.scheme.SchemeEntryType.TABLE
40+
41+
def test_select_text_query_with_params(self, driver_sync):
42+
def select(session: ydb.Session):
43+
text_query = "DECLARE $v AS Int64; SELECT $v"
44+
session.prepare(text_query)
45+
with session.transaction() as tx:
46+
tx.execute(text_query, {"$v": 1})
47+
48+
pool = ydb.SessionPool(driver=driver_sync)
49+
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)