java连接Mongodb实现增删改查

4.修改

package com.czxy.mongodb;
 
import com.mongodb.BasicDBObject;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
 
import java.awt.*;
 
public class Update {
  public static void main(String[] args) {
    // 获取连接
    MongoClient mongoClient = new MongoClient();
    // 连接数据库
    MongoDatabase database = mongoClient.getDatabase("text");
    // 得到集合封装队象
    MongoCollection<Document> stuo = database.getCollection("stus");
    // 查询条件
     BasicDBObject upFind = new BasicDBObject("name", "wangwu");
    // 修改的值
    BasicDBObject upNew = new BasicDBObject("$set", new BasicDBObject("address", "高老庄"));
    // 修改符合条件的第一个值
    stuo.updateOne(upFind, upNew);
    //修改符合条件的全部
//    stuo.updateMany(upFind, upNew);
  }
}

5.条件查询

package com.czxy.mongodb;
 
import com.alibaba.fastjson.JSON;
import com.mongodb.BasicDBObject;
import com.mongodb.MongoClient;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
 
public class FindEq {
  public static void main(String[] args) {
    // 获取连接
    MongoClient mongoClient = new MongoClient();
    // 连接数据库
    MongoDatabase database = mongoClient.getDatabase("text");
    // 得到集合封装队象
    MongoCollection<Document> stus = database.getCollection("stus");
    // 查询条件
    BasicDBObject find = new BasicDBObject("name", "wangwu");
    // 得到查询结果
    FindIterable<Document> results = stus.find(find);
    // 集合遍历
    for (Document result : results) {
      // 格式转换
      String s = JSON.toJSONString(result);
      // 查询结果输出
      System.out.println(JSON.parseObject(s,Stus.class));
    }
  }
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持易采站长站。