MongoDB的CRUD操作（java Util）

日期：2023-10-07 05:29

-->

1。保存插入操作：

公共静态同步字符串插入（DBObject记录）{
DBCollection col = MongoDB.getDBCollection(TABLE_NAME);
record.put("时间", new Date().getTime());
WriteResult 结果 = col.insert(record);
//_id
当前插入表中 return record.get("_id").toString();
}

注：col.insert(record)执行成功后，record可以获得_id。可以通过record.get("_id")是否为空来判断保存是否为空！

2。更新编辑操作：

公共静态同步int编辑（DBObject记录）{
DBCollection col = MongoDB.getDBCollection(TABLE_NAME);
// 检查对应的obj_id是否存在
BasicDBObject queryObj = new BasicDBObject();
queryObj.put("_id", record.get("_id"));
DBCursor dc = col.find(queryObj);
if (dc.count() < 1) {
返回NO_RECORD_EXIST;
}
//保存数据
record.removeField("_id");
WriteResult 结果 = col.update(queryObj, new BasicDBObject("$set", record));
返回结果.getN();
}

注意：更新数据前，必须将更新数据中的_id去掉，否则会报错。 queryObj为更新后的查询条件，record为更新后的记录，record不能包含_id...

3。删除操作：

公共静态同步 int del(DBObject 记录, OlaCloudContent olaCloudContent) {
DBCollection col = MongoDB.getDBCollection(TABLE_NAME);
// 检查对应的obj_id是否存在
DBCursor dc = col.find(记录);
if (dc.count() < 1) {
返回NO_RECORD_EXIST;
}//删除数据
WriteResult 结果 = col.remove(record);
OpLog.AddOpLog(olaCloudContent.getUserName(), TABLE_NAME, "del_key", record.toString());
返回结果.getN();
}

4。查询操作：

公共静态同步 CorpusAnswerWrap find(DBObject 记录,DBObject 排序,int limit){
CorpusAnswerWrap answerWrap = new CorpusAnswerWrap();
List answerList = new ArrayList();
DBCollection col = MongoDB.getDBCollection(TABLE_NAME);
DBCursor dc = col.find(记录).sort(排序);
if(限制 > 0){
dc.limit(限制);
}
answerWrap.setTotalCount(dc.count());
while(dc.hasNext()){
AnswerEntity实体=www.introzo.com AnswerEntity();
entity.setRecord(www.introzo.com());
answerList.add(实体);
}
answerWrap.setDatas(answerList.toArray(new AnswerEntity[answerList.size()]));
返回答案换行；
} -->

最近发表

猜你喜欢

关灯

MongoDB的CRUD操作（java Util）

相关文章