未使用mongojackson删除java文档
我正在跟踪应用程序中的一个严重错误,经过一些挖掘,我将其分解为这个示例。使用jackson集合,我无法删除文档。通常它适用于我刚刚插入的单个文档。在下面的示例中,我只是尝试清除unittest集合
import java.net.UnknownHostException;
import net.vz.mongodb.jackson.DBCursor;
import net.vz.mongodb.jackson.JacksonDBCollection;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.test.model.Account;
public class MongoTest {
public static void main(String[] args) {
try {
Mongo mongo = new Mongo("localhost", 27017);
DB db = mongo.getDB("orion-unittest");
// get a single collection
DBCollection collection = db.getCollection("account");
JacksonDBCollection<Account, String> jacksonCollection = JacksonDBCollection.wrap(collection, Account.class, String.class);
// doesn't work
DBCursor<Account> jacksonCursor = jacksonCollection.find();
while (jacksonCursor.hasNext()) {
jacksonCollection.remove(jacksonCursor.next());
}
System.out.println(jacksonCollection.getCount());
// works!
com.mongodb.DBCursor cursor = collection.find();
while (cursor.hasNext()) {
collection.remove(cursor.next());
}
System.out.println(collection.getCount());
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (MongoException e) {
e.printStackTrace();
}
}
}
控制台输出:
6
0
奇怪的是,当我监视mongo服务器活动时,我看到正在传递delete命令。我是错过了什么,还是这是jackson mapper的错误
这里是Account类,那里没什么。id由_id键填充:
import net.vz.mongodb.jackson.Id;
public class Account {
@Id
String id;
String nickname = null;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getNickname() {
return nickname;
}
public void setNickname(String nickname) {
this.nickname = nickname;
}
}
# 1 楼答案
我没有使用mongo-jackson映射器,但正如我在source code中看到的,它只调用
dbCollection.remove
方法本身。所以我猜你的问题在于WriteConcern。试试这个:测试2是单独删除的(不是一个接一个的),所以您可以真正了解它是否删除(它也可能有删除延迟)
# 2 楼答案
我通过使用@ObjectId而不是@Id找到了解决方案。问题是,在我的Id被序列化到之前
而不是像这样:
。。。由于尝试查找匹配的对象,删除操作导致查询失败。@ObjectId注释现在等于序列化的结果