mongodb

4dkankan-utils-mongodb/src/main/java/com/fdkankan/mongodb/service/MongodbBaseService.java

@@ -3,9 +3,11 @@ package com.fdkankan.mongodb.service;
 import com.fdkankan.mongodb.base.MongoPageResult;
 import com.fdkankan.mongodb.base.BaseRequestMongo;
 import com.mongodb.client.result.DeleteResult;
+import com.mongodb.client.result.UpdateResult;
 import org.springframework.data.geo.GeoResults;
 import org.springframework.data.mongodb.core.query.NearQuery;
 import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.data.util.Pair;
 
 import java.util.List;
@@ -57,4 +59,6 @@ import java.util.List;
 
      Query getIdQueryFor(Object object);
 
+     UpdateResult updateFirst(Query query, Update update);
+
 }

4dkankan-utils-mongodb/src/main/java/com/fdkankan/mongodb/service/impl/MongodbBaseServiceImpl.java

@@ -6,6 +6,7 @@ import com.fdkankan.mongodb.base.BaseRequestMongo;
 import com.fdkankan.mongodb.base.MongoPageResult;
 import com.fdkankan.mongodb.service.MongodbBaseService;
 import com.mongodb.client.result.DeleteResult;
+import com.mongodb.client.result.UpdateResult;
 import org.apache.commons.lang3.StringUtils;
 import org.bson.Document;
 import org.bson.types.ObjectId;
@@ -19,6 +20,7 @@ import org.springframework.data.mongodb.core.mapping.MongoPersistentProperty;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.NearQuery;
 import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.data.util.Pair;
 import org.springframework.stereotype.Component;
 import org.springframework.util.Assert;
@@ -219,4 +221,10 @@ public class MongodbBaseServiceImpl<T> implements MongodbBaseService<T> {
         return new Query(Criteria.where((String) id.getFirst()).is(id.getSecond()));
     }
 
+    @Override
+    public UpdateResult updateFirst(Query query, Update update){
+        return mongoTemplate.updateFirst(query, update, getTClass());
+    }
+
+
 }