|
@ -309,6 +309,12 @@ public class AdapterSchemeService extends SQLGeneralDAO {
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 根据适配版本 获取数据集列表
|
|
|
|
* @param schemeId
|
|
|
|
* @param version
|
|
|
|
* @return
|
|
|
|
*/
|
|
public List<AdapterDatasetModel> getAdapterDataSets(Integer schemeId,String version){
|
|
public List<AdapterDatasetModel> getAdapterDataSets(Integer schemeId,String version){
|
|
List<AdapterDatasetModel> list=new ArrayList<>();
|
|
List<AdapterDatasetModel> list=new ArrayList<>();
|
|
String adapterVersionHql = "FROM AdapterSchemeVersionModel WHERE schemeId = :schemeId and version = :version";
|
|
String adapterVersionHql = "FROM AdapterSchemeVersionModel WHERE schemeId = :schemeId and version = :version";
|
|
@ -318,11 +324,12 @@ public class AdapterSchemeService extends SQLGeneralDAO {
|
|
AdapterSchemeVersionModel versionModel =(AdapterSchemeVersionModel) query.uniqueResult();
|
|
AdapterSchemeVersionModel versionModel =(AdapterSchemeVersionModel) query.uniqueResult();
|
|
String tableName="adapter_dataset_"+versionModel.getVersion();
|
|
String tableName="adapter_dataset_"+versionModel.getVersion();
|
|
String adapterDataSetSql = "select * FROM "+tableName+" WHERE scheme_id = :schemeId";
|
|
String adapterDataSetSql = "select * FROM "+tableName+" WHERE scheme_id = :schemeId";
|
|
Query dataSetQuery = getCurrentSession().createSQLQuery(adapterDataSetSql);
|
|
|
|
|
|
Query dataSetQuery = getCurrentSession().createSQLQuery(adapterDataSetSql).addEntity(AdapterDatasetModel.class);
|
|
dataSetQuery.setParameter("schemeId", schemeId);
|
|
dataSetQuery.setParameter("schemeId", schemeId);
|
|
List<AdapterDatasetModel> adapterDataSet=dataSetQuery.list();
|
|
List<AdapterDatasetModel> adapterDataSet=dataSetQuery.list();
|
|
//TODO 数据据获取
|
|
|
|
return adapterDataSet;
|
|
return adapterDataSet;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
}
|