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
This commit is contained in:
parent
d04519d6b6
commit
93edc75276
|
@ -90,7 +90,7 @@ const keyValueDataHandler = (data) => {
|
||||||
}
|
}
|
||||||
|
|
||||||
const executeQuery = async () => {
|
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) {
|
switch (kind.value) {
|
||||||
case 'atest-store-orm':
|
case 'atest-store-orm':
|
||||||
ormDataHandler(data)
|
ormDataHandler(data)
|
||||||
|
|
|
@ -773,11 +773,12 @@ var SBOM = (callback: (d: any) => void) => {
|
||||||
.then(callback)
|
.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 = {}
|
const queryObj = {}
|
||||||
switch (kind) {
|
switch (kind) {
|
||||||
case 'atest-store-orm':
|
case 'atest-store-orm':
|
||||||
queryObj['sql'] = query;
|
queryObj['sql'] = query;
|
||||||
|
queryObj['key'] = currentDatabase;
|
||||||
break;
|
break;
|
||||||
case 'atest-store-etcd':
|
case 'atest-store-etcd':
|
||||||
queryObj['key'] = query;
|
queryObj['key'] = query;
|
||||||
|
@ -786,7 +787,8 @@ var DataQuery = (store: string, kind: string, query: string, callback: (d: any)
|
||||||
const requestOptions = {
|
const requestOptions = {
|
||||||
method: 'POST',
|
method: 'POST',
|
||||||
headers: {
|
headers: {
|
||||||
'X-Store-Name': store
|
'X-Store-Name': store,
|
||||||
|
'X-Database': currentDatabase
|
||||||
},
|
},
|
||||||
body: JSON.stringify(queryObj)
|
body: JSON.stringify(queryObj)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue