|
@@ -1,4 +1,4 @@
|
|
|
-package org.springblade.flow.visual.onlinedev.common.formdata;
|
|
|
+package org.springblade.flow.visual.onlinedev.formdata.opt;
|
|
|
|
|
|
import java.io.File;
|
|
|
import java.sql.SQLException;
|
|
@@ -24,18 +24,19 @@ import org.springblade.flow.util.JsonUtil;
|
|
|
import org.springblade.flow.util.StringUtil;
|
|
|
import org.springblade.flow.visual.base.entity.VisualdevEntity;
|
|
|
import org.springblade.flow.visual.base.service.VisualdevService;
|
|
|
-import org.springblade.flow.visual.onlinedev.common.dynamic.DataSourceService;
|
|
|
-import org.springblade.flow.visual.onlinedev.common.dynamic.DynamicDataService;
|
|
|
-import org.springblade.flow.visual.onlinedev.common.enums.DsType;
|
|
|
-import org.springblade.flow.visual.onlinedev.common.enums.SearchType;
|
|
|
-import org.springblade.flow.visual.onlinedev.common.excel.ExcelFormParam.ExcelFieldIndex;
|
|
|
-import org.springblade.flow.visual.onlinedev.common.excel.ExcelRead4MultipleTableListener;
|
|
|
-import org.springblade.flow.visual.onlinedev.common.excel.ExcelRead4SingleTableListener;
|
|
|
-import org.springblade.flow.visual.onlinedev.common.formdata.UpdateBean.UpdateColumn;
|
|
|
-import org.springblade.flow.visual.onlinedev.common.relation.RelationBean;
|
|
|
-import org.springblade.flow.visual.onlinedev.common.relation.RelationField;
|
|
|
-import org.springblade.flow.visual.onlinedev.common.relation.RelationKey;
|
|
|
-import org.springblade.flow.visual.onlinedev.common.relation.RelationUtil;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.dynamic.DataSourceService;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.dynamic.DynamicDataService;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.enums.DsType;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.enums.SearchType;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.excel.ExcelFormParam.ExcelFieldIndex;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.excel.ExcelRead4MultipleTableListener;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.excel.ExcelRead4SingleTableListener;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.param.UpdateBean;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.param.UpdateBean.UpdateColumn;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.relation.RelationBean;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.relation.RelationField;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.relation.RelationKey;
|
|
|
+import org.springblade.flow.visual.onlinedev.formdata.relation.RelationUtil;
|
|
|
import org.springblade.flow.visual.onlinedev.model.PaginationModel;
|
|
|
import org.springblade.flow.visual.onlinedev.model.VisualdevModelDataCrForm;
|
|
|
import org.springblade.flow.visual.onlinedev.model.VisualdevModelDataUpForm;
|
|
@@ -351,7 +352,7 @@ public class FormDataWithTableService {
|
|
|
if (CollUtil.isNotEmpty(tableList)) {
|
|
|
DataSourceModel ds = dataSourceService.getReportDatasource(String.valueOf(cubeData.getId()));
|
|
|
tableList.forEach(table -> {
|
|
|
- String sql = "TRUNCATE TABLE "+table;
|
|
|
+ String sql = "TRUNCATE TABLE " + table;
|
|
|
dynamicDataService.executeSql(ds, sql);
|
|
|
});
|
|
|
}
|
|
@@ -617,8 +618,8 @@ public class FormDataWithTableService {
|
|
|
String idsStr = idList.stream().collect(Collectors.joining(","));
|
|
|
if (primaryColumn.getJavaType().equalsIgnoreCase("String")) {
|
|
|
// 主键为字符串类型
|
|
|
- idsStr = idList.stream().collect(Collectors.joining("\", \""));
|
|
|
- idsStr = "\"" + idsStr + "\"";
|
|
|
+ idsStr = idList.stream().collect(Collectors.joining("', '"));
|
|
|
+ idsStr = "'" + idsStr + "'";
|
|
|
}
|
|
|
sqlBuffer.append("delete from " + tableName + " ");
|
|
|
sqlBuffer.append("where " + primaryColumn.getColumnName() + " ");
|
|
@@ -664,19 +665,19 @@ public class FormDataWithTableService {
|
|
|
String idsStr = idList.stream().collect(Collectors.joining(","));
|
|
|
if (primaryColumn.getJavaType().equalsIgnoreCase("String")) {
|
|
|
// 主键为字符串类型
|
|
|
- idsStr = idList.stream().collect(Collectors.joining("\", \""));
|
|
|
- idsStr = "\"" + idsStr + "\"";
|
|
|
+ idsStr = idList.stream().collect(Collectors.joining("', '"));
|
|
|
+ idsStr = "'" + idsStr + "'";
|
|
|
}
|
|
|
whereBuffer.append(" in (" + idsStr + ")");
|
|
|
sqlBuffer.append(whereBuffer);
|
|
|
String sql = sqlBuffer.toString();
|
|
|
log.info("batch delete sql is : " + sql);
|
|
|
dynamicDataService.executeSql(ds, sql);
|
|
|
- return ActionResult.success("批量删除成功");
|
|
|
+ return ActionResult.success("删除成功");
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
- return ActionResult.fail("批量删除失败");
|
|
|
+ return ActionResult.fail("删除失败");
|
|
|
}
|
|
|
|
|
|
private void buildDeleteStringBuffer(String parentTableAlias, List<RelationBean> relationTree,
|
|
@@ -900,62 +901,6 @@ public class FormDataWithTableService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- // private ActionResult<String> updateForSingleTable(Column primaryColumn,
|
|
|
- // String tableName, DataSourceModel ds,
|
|
|
- // Map<String, Object> formDataMap, String id) {
|
|
|
- // try {
|
|
|
- // DsType dsType = DsType.reslove(ds.getDsType());
|
|
|
- // StringBuffer sqlBuffer = new StringBuffer();
|
|
|
- // sqlBuffer.append("update " + tableName + " ");
|
|
|
- //
|
|
|
- // StringBuffer valueSql = new StringBuffer("set ");
|
|
|
- // formDataMap.forEach((key, object) -> {
|
|
|
- // String value = object == null || object.toString().equalsIgnoreCase("[]") ?
|
|
|
- // null : object.toString();
|
|
|
- // CubeTableColumnModel field =
|
|
|
- // dataSourceService.getFieldInfo(Integer.parseInt(key));
|
|
|
- // String fieldName = field.getColumnName();
|
|
|
- //
|
|
|
- // if (value != null) {
|
|
|
- // ViewColumnTypeEnum dataType =
|
|
|
- // ViewColumnTypeEnum.resolve(field.getViewDataType());
|
|
|
- // if (dataType == ViewColumnTypeEnum.STRING) {
|
|
|
- // value = "'" + value + "'";
|
|
|
- // } else if (dataType == ViewColumnTypeEnum.DATETIME) {
|
|
|
- // // 时间日期类型
|
|
|
- // value = "'" + value + "'";
|
|
|
- // if (dsType == DsType.Oracle) {
|
|
|
- // value = "to_date(" + value + ",'yyyy-mm-dd HH24:mi:ss')";
|
|
|
- // }
|
|
|
- // }
|
|
|
- // }
|
|
|
- // if (!primaryColumn.getColumnName().equalsIgnoreCase(fieldName)) {
|
|
|
- // // 不是主键
|
|
|
- // valueSql.append(fieldName + "=" + value);
|
|
|
- // valueSql.append(",");
|
|
|
- // }
|
|
|
- // });
|
|
|
- //
|
|
|
- // String vsql = valueSql.toString();
|
|
|
- // vsql = vsql.substring(0, vsql.length() - 1);
|
|
|
- // sqlBuffer.append(vsql);
|
|
|
- // sqlBuffer.append(" where " + primaryColumn.getColumnName() + "=");
|
|
|
- // String symbol = "";
|
|
|
- // if (primaryColumn.getJavaType().equalsIgnoreCase("String")) {
|
|
|
- // // 主键是字符串
|
|
|
- // symbol = "'";
|
|
|
- // }
|
|
|
- // sqlBuffer.append(symbol + id + symbol + " ");
|
|
|
- //
|
|
|
- // String sql = sqlBuffer.toString();
|
|
|
- // log.info("update sql of single table is " + sql);
|
|
|
- // dynamicDataService.executeSql(ds, sql);
|
|
|
- // return ActionResult.success("更新成功");
|
|
|
- // } catch (Exception e) {
|
|
|
- // }
|
|
|
- // return ActionResult.fail("更新失败");
|
|
|
- // }
|
|
|
-
|
|
|
/**
|
|
|
* 获取某个表的主键字段
|
|
|
*
|