This is an automated email from the ASF dual-hosted git repository.
FreeOnePlus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-mcp-server.git
The following commit(s) were added to refs/heads/master by this push:
new 0ae690c test: lock token-bound database routing priority (#158)
0ae690c is described below
commit 0ae690cead3f6760c7dc476d98e836e0c6108289
Author: Yijia Su <[email protected]>
AuthorDate: Thu Jul 30 19:02:22 2026 +0800
test: lock token-bound database routing priority (#158)
---
test/utils/test_doris_user_pool_manager.py | 39 ++++++++++++++++++++++++++++++
1 file changed, 39 insertions(+)
diff --git a/test/utils/test_doris_user_pool_manager.py
b/test/utils/test_doris_user_pool_manager.py
index e8285f0..8540382 100644
--- a/test/utils/test_doris_user_pool_manager.py
+++ b/test/utils/test_doris_user_pool_manager.py
@@ -310,6 +310,45 @@ async def
test_get_connection_context_uses_owner_based_release(manager, monkeypa
assert len(pool.release_calls) == 1
[email protected]
+async def test_token_database_config_takes_priority_over_valid_global_config(
+ manager,
+ monkeypatch,
+):
+ token = "tenant-token"
+ token_db_config = SimpleNamespace(
+ host="tenant-fe",
+ port=19030,
+ user="tenant_reader",
+ password="tenant_pw",
+ database="tenant_db",
+ charset="utf8mb4",
+ )
+ manager.token_manager = SimpleNamespace(
+ get_database_config_by_token=lambda raw: (
+ token_db_config if raw == token else None
+ )
+ )
+ token_pool = FakePool("tenant")
+ create_pool = AsyncMock(return_value=token_pool)
+ monkeypatch.setattr(manager, "_create_pool_with_config", create_pool)
+
+ pool, selected_config = await manager.get_pool_for_token(token)
+
+ assert pool is token_pool
+ assert selected_config == {
+ "host": "tenant-fe",
+ "port": 19030,
+ "user": "tenant_reader",
+ "password": "tenant_pw",
+ "database": "tenant_db",
+ "charset": "utf8mb4",
+ }
+ create_pool.assert_awaited_once_with(selected_config)
+ assert manager.original_db_config["user"] == "root"
+ assert manager.active_db_config["user"] == "root"
+
+
@pytest.mark.asyncio
async def test_static_token_release_uses_captured_owner_pool(manager,
monkeypatch):
token = "static-token"
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
