提交 5c26b598 authored 作者: taojinlong's avatar taojinlong

Merge branch 'main' of github.com:dataease/dataease into main

...@@ -144,7 +144,6 @@ public class ChartViewService { ...@@ -144,7 +144,6 @@ public class ChartViewService {
} else if (StringUtils.equalsIgnoreCase(table.getType(), "sql")) { } else if (StringUtils.equalsIgnoreCase(table.getType(), "sql")) {
datasourceRequest.setQuery(getSQL(ds.getType(), " (" + dataTableInfoDTO.getSql() + ") AS tmp ", xAxis, yAxis, extFilterList)); datasourceRequest.setQuery(getSQL(ds.getType(), " (" + dataTableInfoDTO.getSql() + ") AS tmp ", xAxis, yAxis, extFilterList));
} }
LogUtil.info(datasourceRequest.getQuery());
data = datasourceProvider.getData(datasourceRequest); data = datasourceProvider.getData(datasourceRequest);
} else if (table.getMode() == 1) {// 抽取 } else if (table.getMode() == 1) {// 抽取
// 获取数据集de字段 // 获取数据集de字段
...@@ -159,7 +158,6 @@ public class ChartViewService { ...@@ -159,7 +158,6 @@ public class ChartViewService {
String tableName = "ds_" + table.getId().replaceAll("-", "_"); String tableName = "ds_" + table.getId().replaceAll("-", "_");
datasourceRequest.setTable(tableName); datasourceRequest.setTable(tableName);
datasourceRequest.setQuery(getSQL(ds.getType(), tableName, xAxis, yAxis, extFilterList)); datasourceRequest.setQuery(getSQL(ds.getType(), tableName, xAxis, yAxis, extFilterList));
LogUtil.info(datasourceRequest.getQuery());
data = datasourceProvider.getData(datasourceRequest); data = datasourceProvider.getData(datasourceRequest);
} }
......
...@@ -242,7 +242,6 @@ public class DataSetTableService { ...@@ -242,7 +242,6 @@ public class DataSetTableService {
String table = dataTableInfoDTO.getTable(); String table = dataTableInfoDTO.getTable();
datasourceRequest.setQuery(createQuerySQL(ds.getType(), table, fieldArray) + " LIMIT " + (page - 1) * pageSize + "," + realSize); datasourceRequest.setQuery(createQuerySQL(ds.getType(), table, fieldArray) + " LIMIT " + (page - 1) * pageSize + "," + realSize);
LogUtil.info(datasourceRequest.getQuery());
try { try {
data.addAll(datasourceProvider.getData(datasourceRequest)); data.addAll(datasourceProvider.getData(datasourceRequest));
} catch (Exception e) { } catch (Exception e) {
...@@ -262,7 +261,6 @@ public class DataSetTableService { ...@@ -262,7 +261,6 @@ public class DataSetTableService {
String sql = dataTableInfoDTO.getSql(); String sql = dataTableInfoDTO.getSql();
datasourceRequest.setQuery(createQuerySQL(ds.getType(), " (" + sql + ") AS tmp ", fieldArray) + " LIMIT " + (page - 1) * pageSize + "," + realSize); datasourceRequest.setQuery(createQuerySQL(ds.getType(), " (" + sql + ") AS tmp ", fieldArray) + " LIMIT " + (page - 1) * pageSize + "," + realSize);
LogUtil.info(datasourceRequest.getQuery());
try { try {
data.addAll(datasourceProvider.getData(datasourceRequest)); data.addAll(datasourceProvider.getData(datasourceRequest));
} catch (Exception e) { } catch (Exception e) {
...@@ -281,7 +279,6 @@ public class DataSetTableService { ...@@ -281,7 +279,6 @@ public class DataSetTableService {
datasourceRequest.setDatasource(ds); datasourceRequest.setDatasource(ds);
String table = DorisTableUtils.dorisName(dataSetTableRequest.getId()); String table = DorisTableUtils.dorisName(dataSetTableRequest.getId());
datasourceRequest.setQuery(createQuerySQL(ds.getType(), table, fieldArray) + " LIMIT " + (page - 1) * pageSize + "," + realSize); datasourceRequest.setQuery(createQuerySQL(ds.getType(), table, fieldArray) + " LIMIT " + (page - 1) * pageSize + "," + realSize);
LogUtil.info(datasourceRequest.getQuery());
try { try {
data.addAll(jdbcProvider.getData(datasourceRequest)); data.addAll(jdbcProvider.getData(datasourceRequest));
} catch (Exception e) { } catch (Exception e) {
...@@ -301,7 +298,6 @@ public class DataSetTableService { ...@@ -301,7 +298,6 @@ public class DataSetTableService {
datasourceRequest.setDatasource(ds); datasourceRequest.setDatasource(ds);
String table = DorisTableUtils.dorisName(dataSetTableRequest.getId()); String table = DorisTableUtils.dorisName(dataSetTableRequest.getId());
datasourceRequest.setQuery(createQuerySQL(ds.getType(), table, fieldArray) + " LIMIT " + (page - 1) * pageSize + "," + realSize); datasourceRequest.setQuery(createQuerySQL(ds.getType(), table, fieldArray) + " LIMIT " + (page - 1) * pageSize + "," + realSize);
LogUtil.info(datasourceRequest.getQuery());
try { try {
data.addAll(jdbcProvider.getData(datasourceRequest)); data.addAll(jdbcProvider.getData(datasourceRequest));
} catch (Exception e) { } catch (Exception e) {
......
...@@ -815,7 +815,9 @@ export default { ...@@ -815,7 +815,9 @@ export default {
invalid_dataset: 'Kettle未运行,无效数据集', invalid_dataset: 'Kettle未运行,无效数据集',
check_all: '全选', check_all: '全选',
can_not_union_self: '被关联表不能与关联表相同', can_not_union_self: '被关联表不能与关联表相同',
float: '小数' float: '小数',
edit_custom_table: '编辑自助数据集',
edit_field: '编辑字段'
}, },
datasource: { datasource: {
datasource: '数据源', datasource: '数据源',
......
...@@ -2,7 +2,7 @@ ...@@ -2,7 +2,7 @@
<el-col> <el-col>
<el-row style="height: 26px;"> <el-row style="height: 26px;">
<span style="line-height: 26px;"> <span style="line-height: 26px;">
{{ $t('dataset.add_custom_table') }} {{ param.tableId?$t('dataset.edit_custom_table'):$t('dataset.add_custom_table') }}
</span> </span>
<el-row style="float: right"> <el-row style="float: right">
<el-button size="mini" @click="cancel"> <el-button size="mini" @click="cancel">
...@@ -62,7 +62,7 @@ ...@@ -62,7 +62,7 @@
</template> </template>
<script> <script>
import { post } from '@/api/dataset/dataset' import { post, getTable } from '@/api/dataset/dataset'
import DatasetGroupSelector from '../common/DatasetGroupSelector' import DatasetGroupSelector from '../common/DatasetGroupSelector'
import DatasetCustomField from '../common/DatasetCustomField' import DatasetCustomField from '../common/DatasetCustomField'
...@@ -89,15 +89,7 @@ export default { ...@@ -89,15 +89,7 @@ export default {
watch: { watch: {
'checkedList': function() { 'checkedList': function() {
// console.log(this.checkedList) // console.log(this.checkedList)
if (this.checkedList && this.checkedList.length > 0) { this.getUnionData()
// 根据第一个选择的数据集找到关联视图
post('dataset/union/listByTableId/' + this.checkedList[0].tableId, {}).then(response => {
// console.log(response)
this.unionData = response.data
})
} else {
this.unionData = []
}
} }
}, },
mounted() { mounted() {
...@@ -105,6 +97,11 @@ export default { ...@@ -105,6 +97,11 @@ export default {
this.calHeight() this.calHeight()
} }
this.calHeight() this.calHeight()
if (this.param && this.param.id && this.param.tableId) {
this.getCustomTable()
this.getUnionData()
}
}, },
methods: { methods: {
calHeight() { calHeight() {
...@@ -144,6 +141,9 @@ export default { ...@@ -144,6 +141,9 @@ export default {
} }
} }
// console.log(this.checkedList) // console.log(this.checkedList)
this.getData()
},
getData() {
// request to get data // request to get data
if (this.checkedList.length > 0) { if (this.checkedList.length > 0) {
const table = { const table = {
...@@ -169,6 +169,17 @@ export default { ...@@ -169,6 +169,17 @@ export default {
this.$refs.plxTable.reloadData(datas) this.$refs.plxTable.reloadData(datas)
} }
}, },
getUnionData() {
if (this.checkedList && this.checkedList.length > 0) {
// 根据第一个选择的数据集找到关联视图
post('dataset/union/listByTableId/' + this.checkedList[0].tableId, {}).then(response => {
// console.log(response)
this.unionData = response.data
})
} else {
this.unionData = []
}
},
save() { save() {
const table = { const table = {
id: this.param.tableId, id: this.param.tableId,
...@@ -185,6 +196,22 @@ export default { ...@@ -185,6 +196,22 @@ export default {
}) })
}, },
getCustomTable() {
getTable(this.param.tableId).then(response => {
const table = response.data
this.name = table.name
this.checkedList = JSON.parse(table.info).list
this.getCheckTable(this.checkedList[0].tableId)
this.getData()
})
},
getCheckTable(tableId) {
getTable(tableId).then(response => {
this.table = response.data
})
},
cancel() { cancel() {
this.dataReset() this.dataReset()
this.$emit('switchComponent', { name: '' }) this.$emit('switchComponent', { name: '' })
......
...@@ -28,8 +28,8 @@ ...@@ -28,8 +28,8 @@
</el-form-item> </el-form-item>
<el-form-item class="form-item"> <el-form-item class="form-item">
<el-select v-model="mode" filterable :placeholder="$t('dataset.connect_mode')" size="mini"> <el-select v-model="mode" filterable :placeholder="$t('dataset.connect_mode')" size="mini">
<el-option :label="$t('dataset.direct_connect')" value="0" /> <el-option :label="$t('dataset.direct_connect')" value="0" />
<el-option :label="$t('dataset.sync_data')" value="1" :disabled="!kettleRunning"/> <el-option :label="$t('dataset.sync_data')" value="1" :disabled="!kettleRunning" />
</el-select> </el-select>
</el-form-item> </el-form-item>
<el-form-item class="form-item" style="float: right;"> <el-form-item class="form-item" style="float: right;">
...@@ -58,7 +58,7 @@ ...@@ -58,7 +58,7 @@
</template> </template>
<script> <script>
import {listDatasource, post, isKettleRunning} from '@/api/dataset/dataset' import { listDatasource, post, isKettleRunning } from '@/api/dataset/dataset'
export default { export default {
name: 'AddDB', name: 'AddDB',
...@@ -103,7 +103,7 @@ export default { ...@@ -103,7 +103,7 @@ export default {
activated() { activated() {
this.initDataSource() this.initDataSource()
}, },
created(){ created() {
this.kettleState() this.kettleState()
}, },
methods: { methods: {
...@@ -112,7 +112,7 @@ export default { ...@@ -112,7 +112,7 @@ export default {
this.options = response.data this.options = response.data
}) })
}, },
kettleState(){ kettleState() {
isKettleRunning().then(res => { isKettleRunning().then(res => {
this.kettleRunning = res.data this.kettleRunning = res.data
}) })
......
...@@ -28,7 +28,7 @@ ...@@ -28,7 +28,7 @@
:multiple="false" :multiple="false"
:show-file-list="false" :show-file-list="false"
:file-list="fileList" :file-list="fileList"
accept=".xls,.xlsx,.csv" accept=".xls,.xlsx,"
:before-upload="beforeUpload" :before-upload="beforeUpload"
:on-success="uploadSuccess" :on-success="uploadSuccess"
:on-error="uploadFail" :on-error="uploadFail"
......
...@@ -88,7 +88,7 @@ ...@@ -88,7 +88,7 @@
</template> </template>
<script> <script>
import {post, listDatasource, isKettleRunning} from '@/api/dataset/dataset' import { post, listDatasource, isKettleRunning } from '@/api/dataset/dataset'
import { codemirror } from 'vue-codemirror' import { codemirror } from 'vue-codemirror'
import { getTable } from '@/api/dataset/dataset' import { getTable } from '@/api/dataset/dataset'
// 核心样式 // 核心样式
...@@ -171,11 +171,11 @@ export default { ...@@ -171,11 +171,11 @@ export default {
this.initTableInfo() this.initTableInfo()
}, },
created(){ created() {
this.kettleState() this.kettleState()
}, },
methods: { methods: {
kettleState(){ kettleState() {
isKettleRunning().then(res => { isKettleRunning().then(res => {
this.kettleRunning = res.data this.kettleRunning = res.data
}) })
......
...@@ -103,7 +103,7 @@ ...@@ -103,7 +103,7 @@
</template> </template>
<script> <script>
import {isKettleRunning, post} from '@/api/dataset/dataset' import { isKettleRunning, post } from '@/api/dataset/dataset'
export default { export default {
name: 'DatasetGroupSelector', name: 'DatasetGroupSelector',
...@@ -169,11 +169,11 @@ export default { ...@@ -169,11 +169,11 @@ export default {
this.tree(this.groupForm) this.tree(this.groupForm)
this.tableTree() this.tableTree()
}, },
created(){ created() {
this.kettleState() this.kettleState()
}, },
methods: { methods: {
kettleState(){ kettleState() {
isKettleRunning().then(res => { isKettleRunning().then(res => {
this.kettleRunning = res.data this.kettleRunning = res.data
}) })
...@@ -213,8 +213,8 @@ export default { ...@@ -213,8 +213,8 @@ export default {
}).then(response => { }).then(response => {
this.tables = response.data this.tables = response.data
for (let i = 0; i < this.tables.length; i++) { for (let i = 0; i < this.tables.length; i++) {
if(this.tables[i].mode===1 && this.kettleRunning === false){ if (this.tables[i].mode === 1 && this.kettleRunning === false) {
this.$set(this.tables[i],"disabled",true) this.$set(this.tables[i], 'disabled', true)
} }
} }
this.tableData = JSON.parse(JSON.stringify(this.tables)) this.tableData = JSON.parse(JSON.stringify(this.tables))
...@@ -248,7 +248,7 @@ export default { ...@@ -248,7 +248,7 @@ export default {
}, },
sceneClick(data, node) { sceneClick(data, node) {
if(data.disabled){ if (data.disabled) {
this.$message({ this.$message({
type: 'warning', type: 'warning',
message: this.$t('dataset.invalid_dataset'), message: this.$t('dataset.invalid_dataset'),
......
...@@ -14,11 +14,14 @@ ...@@ -14,11 +14,14 @@
</span> </span>
</el-popover> </el-popover>
<el-row style="float: right"> <el-row style="float: right">
<el-button v-if="table.type ==='custom'" size="mini" @click="editCustom">
{{ $t('dataset.edit_custom_table') }}
</el-button>
<el-button v-if="table.type ==='sql'" size="mini" @click="editSql"> <el-button v-if="table.type ==='sql'" size="mini" @click="editSql">
{{ $t('dataset.edit_sql') }} {{ $t('dataset.edit_sql') }}
</el-button> </el-button>
<el-button size="mini" @click="edit"> <el-button size="mini" @click="edit">
{{ $t('dataset.edit') }} {{ $t('dataset.edit_field') }}
</el-button> </el-button>
<!-- <el-button size="mini" type="primary" @click="createChart">--> <!-- <el-button size="mini" type="primary" @click="createChart">-->
<!-- {{$t('dataset.create_view')}}--> <!-- {{$t('dataset.create_view')}}-->
...@@ -116,6 +119,9 @@ export default { ...@@ -116,6 +119,9 @@ export default {
editSql() { editSql() {
this.$emit('switchComponent', { name: 'AddSQL', param: { id: this.table.sceneId, tableId: this.table.id }}) this.$emit('switchComponent', { name: 'AddSQL', param: { id: this.table.sceneId, tableId: this.table.id }})
}, },
editCustom() {
this.$emit('switchComponent', { name: 'AddCustom', param: { id: this.table.sceneId, tableId: this.table.id }})
},
reSearch(val) { reSearch(val) {
this.tableViewRowForm = val.form this.tableViewRowForm = val.form
......
...@@ -242,7 +242,7 @@ ...@@ -242,7 +242,7 @@
</template> </template>
<script> <script>
import { loadTable, getScene, addGroup, delGroup, addTable, delTable, groupTree, isKettleRunning} from '@/api/dataset/dataset' import { loadTable, getScene, addGroup, delGroup, addTable, delTable, groupTree, isKettleRunning } from '@/api/dataset/dataset'
export default { export default {
name: 'Group', name: 'Group',
...@@ -546,7 +546,7 @@ export default { ...@@ -546,7 +546,7 @@ export default {
}, },
addData(name) { addData(name) {
this.$emit('switchComponent', { name: name, param: this.currGroup}) this.$emit('switchComponent', { name: name, param: this.currGroup })
}, },
sceneClick(data, node) { sceneClick(data, node) {
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论