Commit 04ba9957 authored by pengxin's avatar pengxin

数据集详情优化版本。

parent c63a6b3e
package com.yice.webadmin.app.constant; package com.yice.webadmin.app.constant;
/**
* MonogoDB常量类
*/
public final class MongoConstant { public final class MongoConstant {
/**
*数据集名称
*/
public static final String COLLECT_NAME = "DATASET-DATA-"; public static final String COLLECT_NAME = "DATASET-DATA-";
/**
* 数据集
*/
public static final String DATA = "data"; public static final String DATA = "data";
/**
* 版本标识
*/
public static final String VERSION = "versionId"; public static final String VERSION = "versionId";
/**
* 创建时间
*/
public static final String CREATE_TIME = "createTime"; public static final String CREATE_TIME = "createTime";
/**
* 主键id
*/
public static final String ID = "_id";
} }
...@@ -40,7 +40,6 @@ public class DatasetDataServiceImpl implements DatasetDataService { ...@@ -40,7 +40,6 @@ public class DatasetDataServiceImpl implements DatasetDataService {
if (StringUtils.isNotBlank(datasetData.getData())) { if (StringUtils.isNotBlank(datasetData.getData())) {
List<Document> documents = new ArrayList<>(); List<Document> documents = new ArrayList<>();
JSONArray jsonArray = JSONArray.parseArray(datasetData.getData()); JSONArray jsonArray = JSONArray.parseArray(datasetData.getData());
if (null != jsonArray && jsonArray.size() > 0) { if (null != jsonArray && jsonArray.size() > 0) {
for (int i = 0; i < jsonArray.size(); i++) { for (int i = 0; i < jsonArray.size(); i++) {
Document document = new Document(MongoConstant.DATA, jsonArray.getJSONObject(i)) Document document = new Document(MongoConstant.DATA, jsonArray.getJSONObject(i))
...@@ -49,8 +48,8 @@ public class DatasetDataServiceImpl implements DatasetDataService { ...@@ -49,8 +48,8 @@ public class DatasetDataServiceImpl implements DatasetDataService {
documents.add(document); documents.add(document);
} }
} }
mongoTemplate.insert(documents,
mongoTemplate.insert(documents, MongoConstant.COLLECT_NAME + datasetData.getVersionId()); MongoConstant.COLLECT_NAME + datasetData.getVersionId());
} }
} }
...@@ -111,7 +110,7 @@ public class DatasetDataServiceImpl implements DatasetDataService { ...@@ -111,7 +110,7 @@ public class DatasetDataServiceImpl implements DatasetDataService {
* @return 返回受影响的行数。 * @return 返回受影响的行数。
*/ */
public Long remove(String id, Long versionId) { public Long remove(String id, Long versionId) {
Query query = new Query(Criteria.where("_id").is(id)); Query query = new Query(Criteria.where(MongoConstant.ID).is(id));
return mongoTemplate.remove(query, DatasetData.class, return mongoTemplate.remove(query, DatasetData.class,
MongoConstant.COLLECT_NAME + versionId).getDeletedCount(); MongoConstant.COLLECT_NAME + versionId).getDeletedCount();
} }
......
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