提交 105d8a2a authored 作者: fit2cloud-chenyw's avatar fit2cloud-chenyw

feat: datasource采用新的列表

上级 a0ee5d63
package io.dataease.base.mapper.ext;
import io.dataease.base.domain.Datasource;
import io.dataease.base.mapper.ext.query.GridExample;
import java.util.List;
public interface ExtDataSourceMapper {
List<Datasource> query(GridExample example);
}
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="io.dataease.base.mapper.ext.ExtDataSourceMapper">
<select id="query" parameterType="io.dataease.base.mapper.ext.query.GridExample" resultMap="io.dataease.base.mapper.DatasourceMapper.BaseResultMap">
select id , name , `desc` ,`type` , configuration ,create_time ,update_time from datasource
<if test="_parameter != null">
<include refid="io.dataease.base.mapper.ext.query.GridSql.gridCondition" />
</if>
<if test="orderByClause != null">
order by ${orderByClause}
</if>
<if test="orderByClause == null">
order by update_time desc
</if>
</select>
</mapper>
...@@ -12,7 +12,7 @@ ...@@ -12,7 +12,7 @@
</select> </select>
<select id="nodesByExample" resultType="io.dataease.base.mapper.ext.query.GridExample" resultMap="simpleNode"> <select id="nodesByExample" parameterType="io.dataease.base.mapper.ext.query.GridExample" resultMap="simpleNode">
select dept_id as id, pid from sys_dept select dept_id as id, pid from sys_dept
<include refid="io.dataease.base.mapper.ext.query.GridSql.gridCondition" /> <include refid="io.dataease.base.mapper.ext.query.GridSql.gridCondition" />
</select> </select>
......
...@@ -5,6 +5,7 @@ import com.github.pagehelper.PageHelper; ...@@ -5,6 +5,7 @@ import com.github.pagehelper.PageHelper;
import io.dataease.base.domain.Datasource; import io.dataease.base.domain.Datasource;
import io.dataease.commons.utils.PageUtils; import io.dataease.commons.utils.PageUtils;
import io.dataease.commons.utils.Pager; import io.dataease.commons.utils.Pager;
import io.dataease.controller.sys.base.BaseGridRequest;
import io.dataease.datasource.service.DatasourceService; import io.dataease.datasource.service.DatasourceService;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
...@@ -34,9 +35,10 @@ public class DatasourceController { ...@@ -34,9 +35,10 @@ public class DatasourceController {
} }
@PostMapping("/list/{goPage}/{pageSize}") @PostMapping("/list/{goPage}/{pageSize}")
public Pager<List<Datasource>> getDatasourceList(@RequestBody Datasource request, @PathVariable int goPage, @PathVariable int pageSize) throws Exception { public Pager<List<Datasource>> getDatasourceList(@RequestBody BaseGridRequest request, @PathVariable int goPage, @PathVariable int pageSize) throws Exception {
Page<Object> page = PageHelper.startPage(goPage, pageSize, true); Page<Object> page = PageHelper.startPage(goPage, pageSize, true);
return PageUtils.setPageInfo(page, datasourceService.getDatasourceList(request)); // return PageUtils.setPageInfo(page, datasourceService.getDatasourceList(request));
return PageUtils.setPageInfo(page, datasourceService.gridQuery(request));
} }
@GetMapping("/delete/{datasourceID}") @GetMapping("/delete/{datasourceID}")
......
...@@ -2,7 +2,10 @@ package io.dataease.datasource.service; ...@@ -2,7 +2,10 @@ package io.dataease.datasource.service;
import io.dataease.base.domain.*; import io.dataease.base.domain.*;
import io.dataease.base.mapper.*; import io.dataease.base.mapper.*;
import io.dataease.base.mapper.ext.ExtDataSourceMapper;
import io.dataease.base.mapper.ext.query.GridExample;
import io.dataease.commons.exception.DEException; import io.dataease.commons.exception.DEException;
import io.dataease.controller.sys.base.BaseGridRequest;
import io.dataease.datasource.provider.DatasourceProvider; import io.dataease.datasource.provider.DatasourceProvider;
import io.dataease.datasource.provider.ProviderFactory; import io.dataease.datasource.provider.ProviderFactory;
import io.dataease.datasource.request.DatasourceRequest; import io.dataease.datasource.request.DatasourceRequest;
...@@ -22,6 +25,9 @@ public class DatasourceService { ...@@ -22,6 +25,9 @@ public class DatasourceService {
@Resource @Resource
private DatasourceMapper datasourceMapper; private DatasourceMapper datasourceMapper;
@Resource
private ExtDataSourceMapper extDataSourceMapper;
public Datasource addDatasource(Datasource datasource) { public Datasource addDatasource(Datasource datasource) {
DatasourceExample example = new DatasourceExample(); DatasourceExample example = new DatasourceExample();
example.createCriteria().andNameEqualTo(datasource.getName()); example.createCriteria().andNameEqualTo(datasource.getName());
...@@ -49,6 +55,11 @@ public class DatasourceService { ...@@ -49,6 +55,11 @@ public class DatasourceService {
return datasourceMapper.selectByExampleWithBLOBs(example); return datasourceMapper.selectByExampleWithBLOBs(example);
} }
public List<Datasource> gridQuery(BaseGridRequest request){
GridExample gridExample = request.convertExample();
return extDataSourceMapper.query(gridExample);
}
public void deleteDatasource(String datasourceId) { public void deleteDatasource(String datasourceId) {
datasourceMapper.deleteByPrimaryKey(datasourceId); datasourceMapper.deleteByPrimaryKey(datasourceId);
} }
......
...@@ -4,6 +4,7 @@ export function dsGrid(pageIndex, pageSize, data) { ...@@ -4,6 +4,7 @@ export function dsGrid(pageIndex, pageSize, data) {
return request({ return request({
url: 'datasource/list/' + pageIndex + '/' + pageSize, url: 'datasource/list/' + pageIndex + '/' + pageSize,
method: 'post', method: 'post',
loading: true,
data data
}) })
} }
......
...@@ -682,7 +682,7 @@ export default { ...@@ -682,7 +682,7 @@ export default {
please_input_password: '请输入密码', please_input_password: '请输入密码',
please_input_host: '请输入主机', please_input_host: '请输入主机',
please_input_port: '请输入端口', please_input_port: '请输入端口',
modify: '修改组织', modify: '编辑数据连接',
validate_success: '校验成功', validate_success: '校验成功',
delete: '删除组织', delete: '删除组织',
delete_confirm: '删除该组织会关联删除该组织下的所有资源(如:相关工作空间,项目,测试用例等),确定要删除吗?', delete_confirm: '删除该组织会关联删除该组织下的所有资源(如:相关工作空间,项目,测试用例等),确定要删除吗?',
......
<template> <template>
<div v-loading="result.loading"> <layout-content v-loading="$store.getters.loadingMap[$store.getters.currentPath]">
<complex-table
<el-card class="table-card"> :data="data"
<template v-slot:header> :columns="columns"
<ms-table-header :buttons="buttons"
:condition.sync="condition" :header="header"
:create-tip="$t('datasource.create')" :search-config="searchConfig"
:title="$t('commons.datasource')" :pagination-config="paginationConfig"
@search="initTableData" @select="select"
@create="create" @search="search"
/> >
<template #buttons>
<fu-table-button icon="el-icon-circle-plus-outline" :label="$t('datasource.create')" @click="create" />
</template> </template>
<!-- system menu datasource table-->
<el-table border class="adjust-table" :data="tableData" style="width: 100%"> <!-- <el-table-column type="selection" fix /> -->
<el-table-column prop="name" :label="$t('commons.name')" /> <el-table-column prop="name" :label="$t('commons.name')" />
<el-table-column prop="desc" :label="$t('commons.description')" /> <el-table-column prop="desc" :label="$t('commons.description')" />
<el-table-column prop="type" :label="$t('datasource.type')" /> <el-table-column prop="type" :label="$t('datasource.type')" />
<el-table-column :label="$t('commons.operating')"> <fu-table-operations :buttons="buttons" :label="$t('commons.operating')" fix />
<template v-slot:default="scope">
<ms-table-operator @editClick="edit(scope.row)" @deleteClick="handleDelete(scope.row)" /> </complex-table>
</template>
</el-table-column>
</el-table>
<ms-table-pagination
:change="initTableData"
:current-page.sync="currentPage"
:page-size.sync="pageSize"
:total="total"
/>
</el-card>
<!-- add datasource form --> <!-- add datasource form -->
<el-dialog <el-dialog
:close-on-click-modal="false" :close-on-click-modal="false"
:title="$t('datasource.create')" :title="formType=='add' ? $t('datasource.create') : $t('datasource.modify')"
:visible.sync="dialogDatasourceAddVisible" :visible.sync="dialogVisible"
width="30%" width="30%"
:destroy-on-close="true" :destroy-on-close="true"
@closed="closeFunc" @closed="closeFunc"
...@@ -84,130 +76,37 @@ ...@@ -84,130 +76,37 @@
</el-form-item> </el-form-item>
</el-form> </el-form>
<template v-slot:footer>
<ms-dialog-footer
:is-show-validate="true"
@cancel="dialogDatasourceAddVisible = false"
@validate="validaDatasource('createDatasource')"
@confirm="createDatasource('createDatasource')"
/>
</template>
</el-dialog>
<!-- update datasource form --> <div slot="footer" class="dialog-footer">
<el-dialog <el-button type="text" @click="dialogVisible = false">{{ $t('commons.cancel') }}</el-button>
:close-on-click-modal="false" <el-button type="primary" @click="saveDatasource('createDatasource')">确认</el-button>
:title="$t('datasource.modify')" </div>
:visible.sync="dialogDatasourceUpdateVisible"
width="30%"
:destroy-on-close="true"
@close="closeFunc"
>
<el-form
ref="updateDatasourceForm"
:model="form"
label-position="right"
label-width="100px"
size="small"
:rules="rule"
>
<el-form-item
:label="$t('commons.name')"
prop="name"
:rules="[{required: true, message: this.$t('datasource.input_name'), trigger: 'blur'},
{min: 2, max: 25, message: this.$t('commons.input_limit', [2, 25]), trigger: 'blur'}]"
>
<el-input v-model="form.name" autocomplete="off" />
</el-form-item>
<el-form-item
:label="$t('commons.description')"
prop="desc"
:rules="[{required: true, message: this.$t('datasource.input_desc'), trigger: 'blur'},
{min: 2, max: 50, message: this.$t('commons.input_limit', [2, 50]), trigger: 'blur'}]"
>
<el-input v-model="form.desc" autocomplete="off" />
</el-form-item>
<el-form-item v-show="form.configuration.dataSourceType=='jdbc'" :label="$t('datasource.data_base')" prop="configuration.dataBase" :rules="{required: true, message: $t('datasource.please_input_data_base'), trigger: 'blur'}">
<el-input v-model="form.configuration.dataBase" autocomplete="off" />
</el-form-item>
<el-form-item v-show="form.configuration.dataSourceType=='jdbc'" :label="$t('datasource.user_name')" prop="configuration.username">
<el-input v-model="form.configuration.username" autocomplete="off" />
</el-form-item>
<el-form-item v-show="form.configuration.dataSourceType=='jdbc'" :label="$t('datasource.password')" prop="configuration.password" :rules="{required: true, message: $t('datasource.please_input_password'), trigger: 'change'}">
<el-input v-model="form.configuration.password" autocomplete="off" />
</el-form-item>
<el-form-item v-show="form.configuration.dataSourceType=='jdbc'" :label="$t('datasource.host')" prop="configuration.host" :rules="{required: true, message: $t('datasource.please_input_host'), trigger: 'change'}">
<el-input v-model="form.configuration.host" autocomplete="off" />
</el-form-item>
<el-form-item v-show="form.configuration.dataSourceType=='jdbc'" :label="$t('datasource.port')" prop="configuration.port" :rules="{required: true, message: $t('datasource.please_input_port'), trigger: 'change'}">
<el-input v-model="form.configuration.port" autocomplete="off" />
</el-form-item>
</el-form>
<template v-slot:footer>
<ms-dialog-footer
:is-show-validate="true"
@cancel="dialogDatasourceUpdateVisible = false"
@validate="validaDatasource('updateDatasourceForm')"
@confirm="updateDatasource('updateDatasourceForm')"
/>
</template>
</el-dialog> </el-dialog>
<ms-delete-confirm ref="deleteConfirm" :title="$t('datasource.delete')" @delete="_handleDelete" /> </layout-content>
</div>
</template> </template>
<script> <script>
import MsTablePagination from '@/metersphere/common/pagination/TablePagination'
import MsTableHeader from '@/metersphere/common/components/MsTableHeader'
import MsTableOperator from '@/metersphere/common/components/MsTableOperator'
import MsDialogFooter from '@/metersphere/common/components/MsDialogFooter'
import {
listenGoBack,
removeGoBackListener
} from '@/metersphere/common/js/utils'
import MsDeleteConfirm from '@/metersphere/common/components/MsDeleteConfirm'
import LayoutContent from '@/components/business/LayoutContent'
import ComplexTable from '@/components/business/complex-table'
import { checkPermission } from '@/utils/permission'
import { formatCondition } from '@/utils/index'
import { dsGrid, addDs, editDs, delDs, validateDs } from '@/api/system/datasource' import { dsGrid, addDs, editDs, delDs, validateDs } from '@/api/system/datasource'
export default { export default {
name: 'DEDatasource', name: 'DEDatasource',
components: { components: {
MsDeleteConfirm, LayoutContent,
MsTablePagination, ComplexTable
MsTableHeader,
MsTableOperator,
MsDialogFooter
}, },
data() { data() {
return { return {
queryPath: '/datasource/list', formType: 'add',
deletePath: '/datasource/delete/', dialogVisible: false,
createPath: '/datasource/add', data: [],
updatePath: '/datasource/update',
validatePath: '/datasource/validate',
result: {},
dialogDatasourceAddVisible: false,
dialogDatasourceUpdateVisible: false,
dialogDatasourceMemberVisible: false,
dialogDatasourceMemberAddVisible: false,
dialogDatasourceMemberUpdateVisible: false,
multipleSelection: [],
currentPage: 1,
pageSize: 10,
total: 0,
dialogCurrentPage: 1,
dialogPageSize: 10,
dialogTotal: 0,
currentRow: {},
condition: {},
dialogCondition: {},
tableData: [],
memberLineData: [],
form: { configuration: {}}, form: { configuration: {}},
allTypes: [{ name: 'mysql', type: 'jdbc' }, { name: 'sqlServer', type: 'jdbc' }], allTypes: [{ name: 'mysql', type: 'jdbc' }, { name: 'sqlServer', type: 'jdbc' }],
memberForm: {},
rule: { rule: {
name: [ name: [
{ required: true, message: this.$t('organization.input_name'), trigger: 'blur' }, { required: true, message: this.$t('organization.input_name'), trigger: 'blur' },
...@@ -217,79 +116,62 @@ export default { ...@@ -217,79 +116,62 @@ export default {
{ required: true, message: this.$t('organization.input_name'), trigger: 'blur' }, { required: true, message: this.$t('organization.input_name'), trigger: 'blur' },
{ max: 50, message: this.$t('commons.input_limit', [0, 50]), trigger: 'blur' } { max: 50, message: this.$t('commons.input_limit', [0, 50]), trigger: 'blur' }
] ]
},
header: '',
columns: [],
buttons: [
{
label: this.$t('commons.edit'), icon: 'el-icon-edit', click: this.edit,
show: checkPermission(['datasource:edit'])
}, {
label: this.$t('commons.delete'), icon: 'el-icon-delete', type: 'danger', click: this.del,
show: checkPermission(['datasource:del'])
}
],
searchConfig: {
useQuickSearch: true,
quickPlaceholder: '按名称搜索',
combine: false,
components: [
// { field: 'name', label: '姓名', component: 'FuComplexInput', defaultOperator: 'eq' },
{ field: 'name', label: '名称', component: 'FuComplexInput' },
{
field: 'type',
label: '类型',
component: 'FuComplexSelect',
options: [{ label: 'mysql', value: 'mysql' }, { label: 'sqlServer', value: 'sqlServer' }],
multiple: false
}
// { field: 'deptId', label: '组织', component: conditionTable }
]
},
paginationConfig: {
currentPage: 1,
pageSize: 10,
total: 0
} }
} }
}, },
activated() { activated() {
this.initTableData() this.search()
}, },
methods: { methods: {
create() { select(selection) {
this.dialogDatasourceAddVisible = true console.log(selection)
listenGoBack(this.closeFunc)
}, },
dataFilter(val) { create() {
if (val) { this.formType = 'add'
this.memberForm.userList = this.memberForm.copyUserList.filter((item) => { this.dialogVisible = true
if (!!~item.id.indexOf(val) || !!~item.id.toUpperCase().indexOf(val.toUpperCase())) {
return true
}
})
} else {
this.memberForm.userList = this.memberForm.copyUserList
}
}, },
edit(row) { edit(row) {
this.dialogDatasourceUpdateVisible = true this.formType = 'modify'
this.dialogVisible = true
this.form = Object.assign({}, row) this.form = Object.assign({}, row)
this.form.configuration = JSON.parse(this.form.configuration) this.form.configuration = JSON.parse(this.form.configuration)
listenGoBack(this.closeFunc)
},
cellClick(row) {
// 保存当前点击的组织信息到currentRow
this.currentRow = row
this.dialogDatasourceMemberVisible = true
const param = {
name: '',
organizationId: row.id
}
const path = '/user/special/org/member/list'
this.result = this.$post(path + '/' + this.dialogCurrentPage + '/' + this.dialogPageSize, param, res => {
const data = res.data
this.memberLineData = data.listObject
const url = '/userrole/list/org/' + row.id
for (let i = 0; i < this.memberLineData.length; i++) {
this.$get(url + '/' + encodeURIComponent(this.memberLineData[i].id), response => {
const roles = response.data
this.$set(this.memberLineData[i], 'roles', roles)
})
}
this.dialogTotal = data.itemCount
})
listenGoBack(this.closeFunc)
},
dialogSearch() {
const row = this.currentRow
this.dialogDatasourceMemberVisible = true
const param = this.dialogCondition
this.$set(param, 'organizationId', row.id)
const path = '/user/special/org/member/list'
this.result = this.$post(path + '/' + this.dialogCurrentPage + '/' + this.dialogPageSize, param, res => {
const data = res.data
this.memberLineData = data.listObject
const url = '/userrole/list/org/' + row.id
for (let i = 0; i < this.memberLineData.length; i++) {
this.$get(url + '/' + encodeURIComponent(this.memberLineData[i].id), response => {
const roles = response.data
this.$set(this.memberLineData[i], 'roles', roles)
})
}
this.dialogTotal = data.itemCount
})
},
handleDelete(datasource) {
this.$refs.deleteConfirm.open(datasource)
}, },
_handleDelete(datasource) { _handleDelete(datasource) {
this.$confirm(this.$t('datasource.delete_confirm'), '', { this.$confirm(this.$t('datasource.delete_confirm'), '', {
confirmButtonText: this.$t('commons.confirm'), confirmButtonText: this.$t('commons.confirm'),
...@@ -298,7 +180,7 @@ export default { ...@@ -298,7 +180,7 @@ export default {
}).then(() => { }).then(() => {
delDs(datasource.id).then(res => { delDs(datasource.id).then(res => {
this.$success(this.$t('commons.delete_success')) this.$success(this.$t('commons.delete_success'))
this.initTableData() this.search()
}) })
}).catch(() => { }).catch(() => {
this.$message({ this.$message({
...@@ -307,37 +189,22 @@ export default { ...@@ -307,37 +189,22 @@ export default {
}) })
}) })
}, },
createDatasource(createDatasourceForm) { saveDatasource(createDatasourceForm) {
this.$refs[createDatasourceForm].validate(valid => { this.$refs[createDatasourceForm].validate(valid => {
if (valid) { if (valid) {
const method = this.formType === 'add' ? addDs : editDs
this.form.configuration = JSON.stringify(this.form.configuration) this.form.configuration = JSON.stringify(this.form.configuration)
addDs(this.form).then(res => { method(this.form).then(res => {
this.$success(this.$t('commons.save_success')) this.$success(this.$t('commons.save_success'))
this.initTableData() this.search()
this.dialogDatasourceAddVisible = false this.dialogVisible = false
}) })
this.dialogDatasourceAddVisible = false
} else { } else {
return false return false
} }
}) })
}, },
updateDatasource(updateDatasourceForm) {
this.$refs[updateDatasourceForm].validate(valid => {
if (valid) {
this.form.configuration = JSON.stringify(this.form.configuration)
editDs(this.form).then(res => {
this.$success(this.$t('commons.modify_success'))
this.dialogDatasourceUpdateVisible = false
this.initTableData()
})
} else {
return false
}
})
},
validaDatasource(datasourceForm) { validaDatasource(datasourceForm) {
this.$refs[datasourceForm].validate(valid => { this.$refs[datasourceForm].validate(valid => {
if (valid) { if (valid) {
...@@ -359,54 +226,46 @@ export default { ...@@ -359,54 +226,46 @@ export default {
} }
} }
}, },
initTableData() { quick_condition(condition) {
dsGrid(this.currentPage, this.pageSize, this.condition).then(response => { const result = {}
const data = response.data if (condition && condition.quick) {
this.tableData = data.listObject for (const [key, value] of Object.entries(condition)) {
this.total = data.itemCount // console.log(`${key}`)
if (`${key}` === 'quick') {
const v_new = Object.assign({}, value)
v_new['field'] = 'name'
result['name'] = v_new
} else {
result[`${key}`] = value
}
}
return result
}
return Object.assign({}, condition)
},
search(condition) {
const temp_param = this.quick_condition(condition)
const temp = formatCondition(temp_param)
const param = temp || {}
const { currentPage, pageSize } = this.paginationConfig
dsGrid(currentPage, pageSize, param).then(response => {
this.data = response.data.listObject
this.paginationConfig.total = response.data.itemCount
}) })
}, },
closeFunc() { closeFunc() {
this.memberLineData = [] this.formType = 'add'
this.initTableData() // this.search()
this.form = { configuration: {}} this.form = { configuration: {}}
removeGoBackListener(this.closeFunc) this.dialogVisible = false
this.dialogDatasourceAddVisible = false
this.dialogDatasourceUpdateVisible = false
this.dialogDatasourceMemberVisible = false
this.dialogDatasourceMemberAddVisible = false
this.dialogDatasourceMemberUpdateVisible = false
},
handleSelectionChange(val) {
this.multipleSelection = val
} }
} }
} }
</script> </script>
<style scoped> <style scoped>
@import "~@/metersphere/common/css/index.css";
.member-size {
text-decoration: underline;
}
.org-member-id {
float: left;
}
.org-member-email {
float: right;
color: #8492a6;
font-size: 13px;
}
.select-width {
width: 100%;
}
.dialog-css >>> .el-dialog__header {
padding: 0;
}
</style> </style>
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论