|
@@ -7,6 +7,7 @@ import com.xzl.web.model.common.Result;
|
|
import com.xzl.web.model.dataGovernance.dto.CreateTableDTO;
|
|
import com.xzl.web.model.dataGovernance.dto.CreateTableDTO;
|
|
import com.xzl.web.model.dataGovernance.dto.DataReplicationParam;
|
|
import com.xzl.web.model.dataGovernance.dto.DataReplicationParam;
|
|
import com.xzl.web.model.dataGovernance.dto.SysDataLogQueryParam;
|
|
import com.xzl.web.model.dataGovernance.dto.SysDataLogQueryParam;
|
|
|
|
+import com.xzl.web.model.dataGovernance.dto.TableDataQueryParam;
|
|
import com.xzl.web.model.dataGovernance.entity.*;
|
|
import com.xzl.web.model.dataGovernance.entity.*;
|
|
import com.xzl.web.service.DataGovernanceService;
|
|
import com.xzl.web.service.DataGovernanceService;
|
|
import org.apache.ibatis.io.Resources;
|
|
import org.apache.ibatis.io.Resources;
|
|
@@ -181,8 +182,25 @@ public class DataGovernanceServiceImpl implements DataGovernanceService {
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public List<Map> getTableData(String tableName) {
|
|
|
|
- return dataGovernanceMapper.getTableDataByTableName(tableName);
|
|
|
|
|
|
+ public Result<Map> getTableData(TableDataQueryParam param) {
|
|
|
|
+ Result<Map> result = new Result<>();
|
|
|
|
+ PageParam pageParam = param.getPageParam();
|
|
|
|
+ result.setPageParam(pageParam);
|
|
|
|
+ Map<String, String> queryParam = new HashMap<>();
|
|
|
|
+ Integer page = null;
|
|
|
|
+ if (pageParam.getPageNum() == 1) {
|
|
|
|
+ page = 0;
|
|
|
|
+ } else {
|
|
|
|
+ page = (pageParam.getPageNum() - 1) * pageParam.getPageSize();
|
|
|
|
+ }
|
|
|
|
+ queryParam.put("page", String.valueOf(page));
|
|
|
|
+ queryParam.put("pageSize", String.valueOf(pageParam.getPageSize()));
|
|
|
|
+ queryParam.put("tableName", param.getTableName());
|
|
|
|
+ Integer count = dataGovernanceMapper.getDataCount(param.getTableName());
|
|
|
|
+ result.setCount(count);
|
|
|
|
+ List<Map> tableData = dataGovernanceMapper.getTableData(queryParam);
|
|
|
|
+ result.setTableData(tableData);
|
|
|
|
+ return result;
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -282,8 +300,10 @@ public class DataGovernanceServiceImpl implements DataGovernanceService {
|
|
public File exportTable(String databaseName, String tableName) throws Exception {
|
|
public File exportTable(String databaseName, String tableName) throws Exception {
|
|
String table = databaseName + "." + tableName;
|
|
String table = databaseName + "." + tableName;
|
|
Map<String, String> createTableSql = dataGovernanceMapper.getCreateTableSql(table);
|
|
Map<String, String> createTableSql = dataGovernanceMapper.getCreateTableSql(table);
|
|
- List<Map> tableData = dataGovernanceMapper.getTableDataByTableName(table);
|
|
|
|
Map<String, String> param = new HashMap<>();
|
|
Map<String, String> param = new HashMap<>();
|
|
|
|
+ param.put("tableName",table);
|
|
|
|
+ List<Map> tableData = dataGovernanceMapper.getTableData(param);
|
|
|
|
+ param=new HashMap<>();
|
|
param.put("dataBaseName", databaseName);
|
|
param.put("dataBaseName", databaseName);
|
|
param.put("tableName", tableName);
|
|
param.put("tableName", tableName);
|
|
List<String> tableTitle = dataGovernanceMapper.getTableTitleListByTableName(param);
|
|
List<String> tableTitle = dataGovernanceMapper.getTableTitleListByTableName(param);
|