From 93edc75276e2fa3c209b6ac1eb98d9b7feb2c6d8 Mon Sep 17 00:00:00 2001 From: rick Date: Thu, 27 Feb 2025 22:36:01 +0800 Subject: [PATCH] feat(DataManager): add support for multiple databases - Add currentDatabase parameter to DataQuery function - Update API request to include X-Database header - Modify query object for atest-store-orm to include database key --- console/atest-ui/src/views/DataManager.vue | 2 +- console/atest-ui/src/views/net.ts | 6 ++++-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/console/atest-ui/src/views/DataManager.vue b/console/atest-ui/src/views/DataManager.vue index a8e4b42..59e894a 100644 --- a/console/atest-ui/src/views/DataManager.vue +++ b/console/atest-ui/src/views/DataManager.vue @@ -90,7 +90,7 @@ const keyValueDataHandler = (data) => { } const executeQuery = async () => { - API.DataQuery(store.value, kind.value, sqlQuery.value, (data) => { + API.DataQuery(store.value, kind.value, currentDatabase.value, sqlQuery.value, (data) => { switch (kind.value) { case 'atest-store-orm': ormDataHandler(data) diff --git a/console/atest-ui/src/views/net.ts b/console/atest-ui/src/views/net.ts index 9705caa..1bc0552 100644 --- a/console/atest-ui/src/views/net.ts +++ b/console/atest-ui/src/views/net.ts @@ -773,11 +773,12 @@ var SBOM = (callback: (d: any) => void) => { .then(callback) } -var DataQuery = (store: string, kind: string, query: string, callback: (d: any) => void, errHandler: (d: any) => void) => { +var DataQuery = (store: string, kind: string, currentDatabase: string, query: string, callback: (d: any) => void, errHandler: (d: any) => void) => { const queryObj = {} switch (kind) { case 'atest-store-orm': queryObj['sql'] = query; + queryObj['key'] = currentDatabase; break; case 'atest-store-etcd': queryObj['key'] = query; @@ -786,7 +787,8 @@ var DataQuery = (store: string, kind: string, query: string, callback: (d: any) const requestOptions = { method: 'POST', headers: { - 'X-Store-Name': store + 'X-Store-Name': store, + 'X-Database': currentDatabase }, body: JSON.stringify(queryObj) }