|
@ -1,13 +1,7 @@
|
|
|
package com.yihu.hos.standard.service.adapter;
|
|
|
|
|
|
import com.yihu.hos.web.framework.dao.SQLGeneralDAO;
|
|
|
import com.yihu.hos.web.framework.constant.ErrorCode;
|
|
|
import com.yihu.hos.web.framework.constant.SqlConstants;
|
|
|
import com.yihu.hos.web.framework.exception.ApiException;
|
|
|
import com.yihu.hos.web.framework.model.*;
|
|
|
import com.yihu.hos.core.datatype.CollectionUtil;
|
|
|
import com.yihu.hos.core.datatype.StringUtil;
|
|
|
import com.yihu.hos.web.framework.util.sql.SqlCreator;
|
|
|
import com.yihu.hos.standard.model.adapter.AdapterSchemeModel;
|
|
|
import com.yihu.hos.standard.model.adapter.AdapterSchemeVersionModel;
|
|
|
import com.yihu.hos.standard.model.adapter.resultModel.AdapterSchemeVersionResultDetailModel;
|
|
@ -15,6 +9,12 @@ import com.yihu.hos.standard.model.standard.StandardModel;
|
|
|
import com.yihu.hos.standard.model.standard.StdMetaDataModel;
|
|
|
import com.yihu.hos.standard.service.bo.AdapterVersion;
|
|
|
import com.yihu.hos.standard.service.bo.StandardVersion;
|
|
|
import com.yihu.hos.web.framework.constant.ErrorCode;
|
|
|
import com.yihu.hos.web.framework.constant.SqlConstants;
|
|
|
import com.yihu.hos.web.framework.dao.SQLGeneralDAO;
|
|
|
import com.yihu.hos.web.framework.exception.ApiException;
|
|
|
import com.yihu.hos.web.framework.model.*;
|
|
|
import com.yihu.hos.web.framework.util.sql.SqlCreator;
|
|
|
import org.hibernate.Criteria;
|
|
|
import org.hibernate.Query;
|
|
|
import org.hibernate.Session;
|
|
@ -387,9 +387,13 @@ public class AdapterSchemeVersionService extends SQLGeneralDAO {
|
|
|
version.getDictEntryTableName(),
|
|
|
version.getDatasetRelationTableName()};
|
|
|
List<String> deleteSqlList = new ArrayList<>();
|
|
|
boolean temp = false;
|
|
|
for (int i = 0; i < tables.length; ++i) {
|
|
|
String table = tables[i];
|
|
|
deleteSqlList.add(SqlConstants.DROP_TABLE + table);
|
|
|
temp = tableIsExist("SELECT COUNT(*) FROM information_schema.TABLES WHERE table_name ='"+table+"'");
|
|
|
if(temp){
|
|
|
deleteSqlList.add(SqlConstants.DROP_TABLE + table);
|
|
|
}
|
|
|
}
|
|
|
insertBatch(deleteSqlList);
|
|
|
}
|