Skip to content

Commit 16eb4cb

Browse files
committed
add elastic lucence query support
1 parent 5f1ed08 commit 16eb4cb

File tree

3 files changed

+29
-25
lines changed

3 files changed

+29
-25
lines changed

console/atest-ui/src/components/Button.vue

Whitespace-only changes.

console/atest-ui/src/views/DataManager.vue

Lines changed: 25 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -34,8 +34,17 @@ watch(store, (s) => {
3434
return
3535
}
3636
})
37-
queryDataMeta.value.currentDatabase = ''
38-
sqlQuery.value = ''
37+
38+
switch (kind.value) {
39+
case 'atest-store-elasticsearch':
40+
case 'atest-store-etcd':
41+
sqlQuery.value = '*'
42+
break
43+
default:
44+
queryDataMeta.value.currentDatabase = ''
45+
sqlQuery.value = ''
46+
}
47+
3948
executeQuery()
4049
})
4150
@@ -63,13 +72,22 @@ const describeTable = (data: QueryData) => {
6372
case 'atest-store-cassandra':
6473
sqlQuery.value = `@describeTable_${queryDataMeta.value.currentDatabase}:${data.label}`
6574
break
75+
break
6676
default:
6777
sqlQuery.value = `@describeTable_${data.label}`
6878
}
6979
executeQuery()
7080
}
7181
const queryTables = () => {
72-
sqlQuery.value = ``
82+
switch (kind.value) {
83+
case 'atest-store-elasticsearch':
84+
if (sqlQuery.value === '') {
85+
sqlQuery.value = '*'
86+
}
87+
break
88+
default:
89+
sqlQuery.value = ``
90+
}
7391
executeQuery()
7492
}
7593
watch(kind, (k) => {
@@ -84,6 +102,9 @@ watch(kind, (k) => {
84102
case 'atest-store-redis':
85103
queryTip.value = 'Enter key'
86104
break;
105+
case 'atest-store-elasticsearch':
106+
queryTip.value = 'field:value OR field:other'
107+
break;
87108
}
88109
})
89110
@@ -153,12 +174,6 @@ const executeQuery = async () => {
153174
return executeWithQuery(sqlQuery.value)
154175
}
155176
const executeWithQuery = async (sql: string) => {
156-
switch (kind.value) {
157-
case 'atest-store-etcd':
158-
sqlQuery.value = '*'
159-
break;
160-
}
161-
162177
let success = false
163178
try {
164179
const data = await API.DataQueryAsync(store.value, kind.value, queryDataMeta.value.currentDatabase, sql);
@@ -197,7 +212,7 @@ const executeWithQuery = async (sql: string) => {
197212
<template>
198213
<div>
199214
<el-container style="height: calc(100vh - 50px);">
200-
<el-aside v-if="kind === 'atest-store-orm' || kind === 'atest-store-iotdb' || kind === 'atest-store-cassandra'">
215+
<el-aside v-if="kind === 'atest-store-orm' || kind === 'atest-store-iotdb' || kind === 'atest-store-cassandra' || kind === 'atest-store-elasticsearch'">
201216
<el-scrollbar>
202217
<el-select v-model="queryDataMeta.currentDatabase" placeholder="Select database"
203218
@change="queryTables" filterable>

console/atest-ui/src/views/net.ts

Lines changed: 4 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -785,21 +785,10 @@ interface QueryObject {
785785
key: string
786786
}
787787
var DataQueryAsync = (store: string, kind: string, currentDatabase: string, query: string) => {
788-
const queryObj = {} as QueryObject;
789-
switch (kind) {
790-
case 'atest-store-orm':
791-
case 'atest-store-cassandra':
792-
case 'atest-store-iotdb':
793-
queryObj['sql'] = query;
794-
queryObj['key'] = currentDatabase;
795-
break;
796-
case 'atest-store-etcd':
797-
case 'atest-store-redis':
798-
case 'atest-store-elasticsearch':
799-
queryObj['key'] = query;
800-
queryObj['sql'] = query;
801-
break;
802-
}
788+
const queryObj = {
789+
'key': currentDatabase,
790+
'sql': query,
791+
} as QueryObject;
803792
const requestOptions = {
804793
method: 'POST',
805794
headers: {

0 commit comments

Comments
 (0)