Skip to content

A
amos-tool
Commit 8144ce93 authored by 陈祥烨's avatar 陈祥烨
Browse files
Options

更新脚本导出

parent 3c3bd7b8
Show whitespace changes
Inline Side-by-side
Showing with 23 additions and 46 deletions
src/main/java/com/yeejoin/amos/api/tool/face/service/StudioResourceService.java
View file @ 8144ce93
......@@ -24,7 +24,6 @@ import org.typroject.tyboot.component.emq.EmqKeeper;
import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
import org.typroject.tyboot.core.rdbms.service.BaseService;
import javax.management.Query;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
import java.io.*;
......@@ -91,7 +90,7 @@ public class StudioResourceService extends BaseService<StudioResourceModel, Stud
return this.queryForList("", false, resourceCode);
}
public void generateSQL(String resourceCode, String dimension,Long ipSeq, Map<String, Object> variables, HttpServletResponse response) {
public void generateSQL(String resourceCode, String dimension, Long ipSeq, Map<String, Object> variables, HttpServletResponse response) {
try {
// if (resourceCode.equals("StudioApplication")){
// ApplicationModel model = applicationService.queryBySeq(Long.valueOf(variables.get(dimension).toString()));
......@@ -135,7 +134,7 @@ public class StudioResourceService extends BaseService<StudioResourceModel, Stud
deleteSql.append(deleteAllSql).append(BRANCH).append(BR);
}
if (!ObjectUtils.isEmpty(model.getResourceInsertSql())) {
String sql = buildInsertSql(model, dimension,ipSeq, variables);
String sql = buildInsertSql(model, dimension, ipSeq, variables);
if (!ObjectUtils.isEmpty(sql)) insertSql.append(sql);
}
}
......@@ -196,46 +195,27 @@ public class StudioResourceService extends BaseService<StudioResourceModel, Stud
JSONObject selectAllSql = dimensionData.getJSONObject(dimension);
DataBaseLinkModel dataBaseLinkModel = dataBaseLinkService.queryBySeq(ipSeq);
for (String tableName : selectAllSql.keySet()) {
List<TableColumn> columns = null;
List<Map<String, Object>> dataList = null;
String selectsql = format(selectAllSql.getString(tableName), variables);
if (SourceEnum.IDX.getSource().equals(resource.getResourceCode().toLowerCase())) {
// String sql = sqlHelper.getNamespaceSql("com.yeejoin.amos.api.studio.face.orm.dao.StudioResourceMapper.queryForListByTableName", tableName);
// Query query = new Query();
// query.setSql(sql);
// List result = IndicatorsManager.indicatorClient.queryBySql(query).getResult();
// List<TableColumn> finalColumns = new ArrayList<>();
// result.stream().forEach(x -> {
// TableColumn column = JsonUtils.jsonToBean(JSON.toJSONString(x), TableColumn.class);
// finalColumns.add(column);
// });
// columns = finalColumns;
//
// query.setSql(selectsql);
// dataList = IndicatorsManager.indicatorClient.queryBySql(query).getResult();
} else {
if (dimension.equals("appSeq")) {
dataBaseLinkModel.setDbName("amos_studio");
dataBaseLinkModel.setDbName(dataBaseLinkModel.getDbName().replace("project", "studio"));
} else if (dimension.equals("projectSeq")) {
dataBaseLinkModel.setDbName("amos_idx");
dataBaseLinkModel.setDbName(dataBaseLinkModel.getDbName().replace("project", "idx"));
}
Connection connection = dataBaseLinkService.connectNewDatabase(dataBaseLinkModel);
if (ObjectUtils.isEmpty(selectAllSql.keySet())) {
return "";
}
columns = DataBaseUtils.getTableColumn(tableName,connection);
dataList = DataBaseUtils.getMaps(selectsql,connection);
sbsql.append(DataBaseUtils.getInsertSQL(dataList,columns,tableName));
List<TableColumn> columns = DataBaseUtils.getTableColumn(tableName, connection);
List<Map<String, Object>> dataList = DataBaseUtils.getMaps(selectsql, connection);
sbsql.append(DataBaseUtils.getInsertSQL(dataList, columns, tableName));
connection.close();
}
}
return sbsql.toString();
}
public static String format(String sqlTemplate, Map<String, Object> parameter) {
StringSubstitutor ss = new StringSubstitutor(parameter);
String newTemplateStr = ss.replace(sqlTemplate);
return newTemplateStr;
return ss.replace(sqlTemplate);
}
public void download(HttpServletResponse response, String fileName, String sqlFilePath) throws IOException {
......@@ -273,19 +253,19 @@ public class StudioResourceService extends BaseService<StudioResourceModel, Stud
* 获取项目列表
*/
public List<ProjectModel> getProjectList(Long ipSeq, String agencyCode) throws SQLException {
DataBaseLinkModel model= dataBaseLinkService.queryBySeq(ipSeq);
DataBaseLinkModel model = dataBaseLinkService.queryBySeq(ipSeq);
model.setDbName("amos_studio");
Connection connection = dataBaseLinkService.connectNewDatabase(model);
Statement sql = connection.createStatement();
String sqlStr = "select SEQUENCE_NBR,PROJECT_NAME,AGENCY_CODE from amos_studio.studio_project " +
"where AGENCY_CODE = " + "\'" + agencyCode +"\'";
"where AGENCY_CODE = " + "'" + agencyCode + "'";
// System.out.println(sqlStr);
ResultSet resultSet = sql.executeQuery(sqlStr);
ResultSetMetaData md = resultSet.getMetaData(); //获得结果集结构信息,元数据
List<ProjectModel> listPm = new ArrayList<>(); //实例化一个list作为容器
try {
//循环赋值 添加ProjectMode到list
while (resultSet.next()){
while (resultSet.next()) {
//每次循环都实例化一个user 用来储存属性
ProjectModel pm = new ProjectModel();
pm.setName(resultSet.getString("PROJECT_NAME"));
......@@ -304,20 +284,20 @@ public class StudioResourceService extends BaseService<StudioResourceModel, Stud
}
public List<ProjectModel> getAppList(Long ipSeq, Long projectNbr ) throws SQLException {
DataBaseLinkModel model= dataBaseLinkService.queryBySeq(ipSeq);
public List<ProjectModel> getAppList(Long ipSeq, Long projectNbr) throws SQLException {
DataBaseLinkModel model = dataBaseLinkService.queryBySeq(ipSeq);
model.setDbName("amos_studio");
Connection connection = dataBaseLinkService.connectNewDatabase(model);
Statement sql = connection.createStatement();
String sqlStr = "select SEQUENCE_NBR,APP_NAME from amos_studio.studio_application " +
"where PROJECT_SEQ = " + "\'" + projectNbr +"\'";
"where PROJECT_SEQ = " + "'" + projectNbr + "'";
// System.out.println(sqlStr);
ResultSet resultSet = sql.executeQuery(sqlStr);
ResultSetMetaData md = resultSet.getMetaData(); //获得结果集结构信息,元数据
List<ProjectModel> listPm = new ArrayList<>(); //实例化一个list作为容器
try {
//循环赋值 添加ProjectMode到list
while (resultSet.next()){
while (resultSet.next()) {
//每次循环都实例化一个user 用来储存属性
ProjectModel pm = new ProjectModel();
pm.setName(resultSet.getString("APP_NAME"));
......@@ -334,20 +314,20 @@ public class StudioResourceService extends BaseService<StudioResourceModel, Stud
return listPm;
}
public List<ProjectModel> getIdx(Long ipSeq, String agencyCode ) throws SQLException {
DataBaseLinkModel model= dataBaseLinkService.queryBySeq(ipSeq);
public List<ProjectModel> getIdx(Long ipSeq, String agencyCode) throws SQLException {
DataBaseLinkModel model = dataBaseLinkService.queryBySeq(ipSeq);
model.setDbName("amos_idx");
Connection connection = dataBaseLinkService.connectNewDatabase(model);
Statement sql = connection.createStatement();
String sqlStr = "select id,agencyCode,name,type from amos_idx.idx_explorer " +
"where agencyCode = '" + agencyCode + "' and type = 'project'" ;
"where agencyCode = '" + agencyCode + "' and type = 'project'";
// System.out.println(sqlStr);
ResultSet resultSet = sql.executeQuery(sqlStr);
ResultSetMetaData md = resultSet.getMetaData(); //获得结果集结构信息,元数据
List<ProjectModel> listPm = new ArrayList<>(); //实例化一个list作为容器
try {
//循环赋值 添加ProjectMode到list
while (resultSet.next()){
while (resultSet.next()) {
//每次循环都实例化一个user 用来储存属性
ProjectModel pm = new ProjectModel();
pm.setName(resultSet.getString("name"));
......
src/main/java/com/yeejoin/amos/api/tool/face/service/TemplateCategoryService.java
View file @ 8144ce93
......@@ -2,16 +2,13 @@ package com.yeejoin.amos.api.tool.face.service;
import com.yeejoin.amos.api.tool.face.model.TemplateCategoryModel;
import com.yeejoin.amos.api.tool.face.model.TemplateCategoryTreeModel;
import com.yeejoin.amos.api.tool.face.model.TemplateModel;
import com.yeejoin.amos.api.tool.face.orm.dao.TemplateCategoryMapper;
import com.yeejoin.amos.api.tool.face.orm.entity.TemplateCategory;
import org.springframework.beans.factory.annotation.Autowired;
import org.typroject.tyboot.core.foundation.utils.StringUtil;
import org.typroject.tyboot.core.rdbms.service.BaseService;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
......
src/main/java/com/yeejoin/amos/api/tool/face/service/TransferDataService.java
View file @ 8144ce93
......@@ -14,10 +14,10 @@ import java.util.Map;
@Service
public class TransferDataService {
private static String TABLE_DES = "mcb_warning_base_source_attribution";
private static String TABLE_ORI = "qms_explorer";
private static String DBNAME_DES = "amos_mcb";
private static String DBNAME_ORI = "amos_studio";
private static final String TABLE_DES = "mcb_warning_base_source_attribution";
private static final String TABLE_ORI = "qms_explorer";
private static final String DBNAME_DES = "amos_mcb";
private static final String DBNAME_ORI = "amos_studio";
public Connection connectDataBase(String dataBaseName) throws ClassNotFoundException, SQLException {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment