|
|
@@ -1,9 +1,11 @@
|
|
|
package com.server;
|
|
|
|
|
|
+import com.dao.ChartsConfigMapper;
|
|
|
import com.dao.DataConnectorMapper;
|
|
|
import com.dao.UserMapper;
|
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
+import com.model.bo.ColumnConfigAndSql;
|
|
|
import com.model.bo.DatabaseConfig;
|
|
|
import com.model.bo.GroupUpdateId;
|
|
|
import com.model.po.BaseConfig;
|
|
|
@@ -15,6 +17,8 @@ import com.model.vo.configVo.ChangeOrderInfo;
|
|
|
import com.model.vo.configVo.ColumnRenameInfo;
|
|
|
import com.model.vo.configVo.DataConnectorInfo;
|
|
|
import com.model.vo.configVo.GroupInfo;
|
|
|
+import com.model.vo.dataVo.ColumnValuesInfo;
|
|
|
+import com.util.BasesSource.DynamicDataSourceContextHolder;
|
|
|
import com.util.GetTokenData;
|
|
|
import com.util.ScreenUtil;
|
|
|
import com.util.SqlMatch;
|
|
|
@@ -51,7 +55,12 @@ public class DataConnectorService {
|
|
|
GetTokenData getTokenData;
|
|
|
@Autowired
|
|
|
UserMapper userMapper;
|
|
|
-
|
|
|
+ @Autowired
|
|
|
+ ChartsConfigMapper chartsConfigMapper;
|
|
|
+ @Autowired
|
|
|
+ ChartsUtilService chartsUtilService;
|
|
|
+ @Autowired
|
|
|
+ GetChartsDataUtilService getChartsDataUtilService;
|
|
|
/*
|
|
|
保存数据源
|
|
|
*/
|
|
|
@@ -333,4 +342,67 @@ public class DataConnectorService {
|
|
|
return new RepEntity(RepCode.success, dataConnectorMapper.getConnectorGroup());
|
|
|
}
|
|
|
|
|
|
+ /*
|
|
|
+ 查询数据源数据
|
|
|
+ */
|
|
|
+ public RepEntity getConnectorData(String token, int dataId){
|
|
|
+
|
|
|
+ int baseId = getChartsDataUtilService.getBaseIdByConnect(dataId);
|
|
|
+ System.out.println("切换数据库"+baseId);
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ Map<String, String> resultMap = getTokenData.getTokenData(token);
|
|
|
+ int id = Integer.parseInt(resultMap.get("id"));
|
|
|
+ int createId = dataConnectorMapper.getCreateIdById(dataId);
|
|
|
+ ColumnValuesInfo columnValuesInfo = new ColumnValuesInfo();
|
|
|
+ ColumnConfigAndSql columnConfigAndSql = chartsConfigMapper.getConfigAndSql(dataId);
|
|
|
+ String sql = columnConfigAndSql.getSql();
|
|
|
+ String columnConfig = columnConfigAndSql.getColumnConfig();
|
|
|
+ columnValuesInfo.setColumnConfig(columnConfig);
|
|
|
+
|
|
|
+ if (id == createId){
|
|
|
+ try {
|
|
|
+ if (!DynamicDataSourceContextHolder.isContainsDataSource(String.valueOf(baseId))) {
|
|
|
+ //joinPoint.getSignature() :获取连接点的方法签名对象
|
|
|
+ System.out.println("数据源 " + baseId + " 不存在使用默认的数据源 -> ");
|
|
|
+ } else {
|
|
|
+ System.out.println("使用数据源:" + baseId);
|
|
|
+ DynamicDataSourceContextHolder.setDataSourceType(String.valueOf(baseId));
|
|
|
+ }
|
|
|
+ columnValuesInfo.setValues(dataConnectorMapper.getValues(sql));
|
|
|
+ }catch (Exception e){
|
|
|
+ e.printStackTrace();
|
|
|
+ System.out.println("异常");
|
|
|
+ return new RepEntity(RepCode.erro);
|
|
|
+ }finally {
|
|
|
+ System.out.println("关闭数据源");
|
|
|
+ DynamicDataSourceContextHolder.clearDataSourceType();
|
|
|
+ }
|
|
|
+ }else {
|
|
|
+ String sqls = chartsUtilService.columnNameUtil(id, dataId, sql, true, 0, createId);
|
|
|
+ if ("".equals(sqls)){
|
|
|
+ return new RepEntity(RepCode.NoAuthority);
|
|
|
+ }
|
|
|
+ try {
|
|
|
+ if (!DynamicDataSourceContextHolder.isContainsDataSource(String.valueOf(baseId))) {
|
|
|
+ //joinPoint.getSignature() :获取连接点的方法签名对象
|
|
|
+ System.out.println("数据源 " + baseId + " 不存在使用默认的数据源 -> ");
|
|
|
+ } else {
|
|
|
+ System.out.println("使用数据源:" + baseId);
|
|
|
+ DynamicDataSourceContextHolder.setDataSourceType(String.valueOf(baseId));
|
|
|
+ }
|
|
|
+ columnValuesInfo.setValues(dataConnectorMapper.getValues(sqls));
|
|
|
+ }catch (Exception e){
|
|
|
+ e.printStackTrace();
|
|
|
+ System.out.println("异常");
|
|
|
+ return new RepEntity(RepCode.erro);
|
|
|
+ }finally {
|
|
|
+ System.out.println("关闭数据源");
|
|
|
+ DynamicDataSourceContextHolder.clearDataSourceType();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return new RepEntity(RepCode.success, columnValuesInfo);
|
|
|
+ }
|
|
|
+
|
|
|
}
|