浏览代码

rwd: 修改分表实现

yaoll 4 年之前
父节点
当前提交
102fc1eace
共有 1 个文件被更改,包括 3 次插入0 次删除
  1. 3 0
      dmp-rwd/src/main/java/com/persagy/dmp/rwd/service/InitService.java

+ 3 - 0
dmp-rwd/src/main/java/com/persagy/dmp/rwd/service/InitService.java

@@ -3,6 +3,7 @@ package com.persagy.dmp.rwd.service;
 import com.fasterxml.jackson.databind.node.JsonNodeFactory;
 import com.fasterxml.jackson.databind.node.JsonNodeFactory;
 import com.persagy.common.web.MapResponse;
 import com.persagy.common.web.MapResponse;
 import com.persagy.dmp.config.DmpParameterStorage;
 import com.persagy.dmp.config.DmpParameterStorage;
+import com.persagy.dmp.rwd.config.JpaSqlExecuteContext;
 import com.persagy.dmp.rwd.entity.GraphDef;
 import com.persagy.dmp.rwd.entity.GraphDef;
 import com.persagy.dmp.rwd.entity.GraphInstance;
 import com.persagy.dmp.rwd.entity.GraphInstance;
 import com.persagy.dmp.rwd.entity.ObjectInstance;
 import com.persagy.dmp.rwd.entity.ObjectInstance;
@@ -106,6 +107,8 @@ public class InitService extends BaseService {
 			System.out.println(sql);
 			System.out.println(sql);
 			statement.executeUpdate(sql);
 			statement.executeUpdate(sql);
 
 
+			JpaSqlExecuteContext.init(groupCode, projectId);
+
 			// 插入项目对象
 			// 插入项目对象
 			ObjectInstance pro = new ObjectInstance();
 			ObjectInstance pro = new ObjectInstance();
 			pro.setId(projectId);
 			pro.setId(projectId);