【MongoDB】5.MongoDB与java的简单结合

坏气十足

package com.mongo.test;　　

　　

　　
import java.text.SimpleDateFormat;
　　
import java.util.ArrayList;
　　
import java.util.List;
　　

　　
import org.bson.Document;
　　
import org.junit.Test;
　　

　　
import com.mongo.util.MongoConnection;
　　
import com.mongodb.client.FindIterable;
　　
import com.mongodb.client.MongoCollection;
　　
import com.mongodb.client.MongoCursor;
　　
import com.mongodb.client.MongoDatabase;
　　
import com.mongodb.client.model.Filters;
　　


　　
public>　　
     
　　
     MongoConnection connection = new MongoConnection();
　　
     //连接到数据库
　　
     MongoDatabase mongoDatabase = connection.getConnectionBasis();
　　
     
　　
     
　　
     @Test
　　
     public void test(){
　　
         //createCollection();//创建   集合 一次就好
　　
         MongoCollection<Document> collection = getCollection();
　　
         insertDomcument(collection);
　　
         findAll(collection);
　　
         //delete(collection);
　　
     }
　　
     
　　
     /**
　　
      * 创建  集合【对应RDBMS 中的数据表】 com.mongodb.client.MongoDatabase.createCollection("集合名")
　　
      */
　　
     public void createCollection(){
　　
         mongoDatabase.createCollection("testConllection");
　　
         System.out.println("创建集合成功");
　　
     }
　　
     
　　
     /**
　　
      * 获取  集合【对应RDBMS 中的数据表】com.mongodb.client.MongoDatabase.getCollection("集合名")
　　
      */
　　
     public MongoCollection<Document> getCollection(){
　　
         MongoCollection<Document>  collection = mongoDatabase.getCollection("testConllection");
　　
         System.out.println("转换到指定集合");
　　
         return collection;
　　
     }
　　
     
　　
     /**
　　
      * 插入  文档【对应RDBMS 中的一条数据】com.mongodb.client.MongoCollection<Document>.insertOne()/insertMany()
　　
      */
　　
     public void insertDomcument(MongoCollection<Document> collection){
　　
         /**
　　
         * 1. 创建文档 org.bson.Document 参数为key-value的格式
　　
         * 2. 创建文档集合List<Document>
　　
         * 3. 将文档集合插入数据库集合中 mongoCollection.insertMany(List<Document>) 插入单个文档可以用 mongoCollection.insertOne(Document)
　　
         * */
　　
         Document document = new Document();
　　
         document.append("name", "走四方");
　　
         document.append("age", 23);
　　
         document.append("url", "www.baidu.com");
　　
         
　　
         List<Document> list = new ArrayList<Document>();
　　
         list.add(document);
　　
         
　　
         collection.insertMany(list);
　　
         System.out.println("插入文档成功");
　　
         
　　
         //插入 单条数据
　　
         Document  t = new Document();
　　
         t.append("name", "走什么");
　　
         t.append("age", 26);
　　
         t.append("url", "www.agen.cn");
　　
         
　　
         collection.insertOne(t);
　　
         System.out.println("插入单条数据成功");
　　
     }
　　
     
　　
     /**
　　
      * 查询  所有文档【表内 数据】com.mongodb.client.MongoCollection<Document>.find()
　　
      * 查询  本条数据的时间节点   _id采用ObjectId格式
　　
      *
　　
      * ObjectId 是一个12字节 BSON 类型数据，有以下格式：
　　
             前4个字节表示时间戳
　　
             接下来的3个字节是机器标识码
　　
             紧接的两个字节由进程id组成（PID）
　　
             最后三个字节是随机数。
　　
      */
　　
     public void findAll(MongoCollection<Document> collection){
　　
         /**
　　
         * 1. 获取迭代器FindIterable<Document>
　　
         * 2. 获取游标MongoCursor<Document>
　　
         * 3. 通过游标遍历检索出的文档集合
　　
         * */
　　
          FindIterable<Document> findIterable = collection.find();
　　
          MongoCursor<Document> mongoCursor = findIterable.iterator();
　　
          while(mongoCursor.hasNext()){
　　
              Document document = mongoCursor.next();
　　
              System.out.println("MongoDB数据："+document);
　　
              System.out.println("本地时间："+new SimpleDateFormat().format(document.getObjectId("_id").getDate()));
　　
          }
　　
     }
　　
     
　　
     /**
　　
      * 更新   所有文档【表内  数据】com.mongodb.client.MongoCollection<Document>.updateMany()
　　
      */
　　
     public void update(MongoCollection<Document> collection){
　　
         
　　
         collection.updateMany(Filters.eq("age", 26), new Document("$set",new Document("age",100)));
　　
         
　　
         FindIterable<Document> findIterable = collection.find();
　　
         MongoCursor<Document> cursor = findIterable.iterator();
　　
         while (cursor.hasNext()) {
　　
             System.out.println("更新后的MongoDB数据："+cursor.next());
　　
         }
　　
     }
　　
     
　　
     
　　
     /**
　　
      * 删除  文档 com.mongodb.client.MongoCollection<Document>.deleteMany()/deleteOne()
　　
      */
　　
     public void delete(MongoCollection<Document> collection){
　　
         // 删除符合条件的 第一个文档
　　
         collection.findOneAndDelete(Filters.eq("age", 26));
　　
         //删除符合条件的  所有文档
　　
         collection.deleteMany(Filters.gte("age", 20));
　　
         
　　
         FindIterable<Document> findIterable = collection.find();
　　
         MongoCursor<Document> cursor = findIterable.iterator();
　　
         while(cursor.hasNext()){
　　
             System.out.println("删除后的MongoDB数据："+cursor.next());
　　
         }
　　
     }
　　
     
　　
     
　　
     
　　
     
　　
     
　　
}