（1）MongoDB的Java应用

末蓝、 2022-07-28 01:17 75阅读 0赞

MongoDB 是一个基于分布式文件存储的数据库。由 C++ 语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。  
关于MongoDB的学习，大家可以参考[http://www.runoob.com/mongodb/mongodb-tutorial.html][http_www.runoob.com_mongodb_mongodb-tutorial.html]这个网站上的教程。

下面是我写的一个基础的应用Mongodb数据库的Java工具类：

import com.mongodb.MongoClient;
    import com.mongodb.MongoCredential;
    import com.mongodb.ServerAddress;
    import com.mongodb.client.FindIterable;
    import com.mongodb.client.MongoCollection;
    import com.mongodb.client.MongoCursor;
    import com.mongodb.client.MongoDatabase;
    import com.mongodb.client.MongoIterable;
    import com.mongodb.client.model.CreateCollectionOptions;
    import com.mongodb.client.model.Filters;
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import org.bson.Document;
    import org.bson.conversions.Bson;
    
    /** * * @author Angela */
    public class MongoDBUtil { 
    
        public static void main(String args[]){
            MongoClient client=connect();
            //listDatabase(client);// 
            MongoDatabase db =getDatabase(client,"mycol");  
            //createCappedCollection(db,"p",10);
            MongoCollection<Document> collection=getCollection(db,"test");
            //dropCollection(collection);
            //listCollection(db);
            //select(collection,"likes",200);
            //update(collection,"likes",200,100,false);
            //delete(collection,"likes",100,false);
            Map<String,Object> map1=new HashMap<String,Object>();
            map1.put("title","MonogD");
            List<Integer> list=new ArrayList<Integer>();
            for(int i=0;i<5;i++){
                list.add(i);
            }
            Map<String,Object> map2=new HashMap<String,Object>();
            map2.put("title",list);
            List<Map<String,Object>> maps=new ArrayList<Map<String,Object>>();
            maps.add(map1);
            maps.add(map2);
            insert(collection,maps);
            select(collection);
            close(client);
        }
    
        /**本地连接mongodb服务器**/
        public static MongoClient connect(){
            MongoClient client = new MongoClient( "localhost" , 27017 ); 
            System.out.println("成功连接到MongoDB服务器");
            return client;
        }
    
        /**远程连接mongodb服务器，带用户名和密码认证**/
        public static MongoClient connect(String IP,String userName,
                String dbName,String password){
            //ServerAddress()两个参数分别为 服务器地址 和 端口 
            ServerAddress serverAddress = new ServerAddress(IP,27017);  
            List<ServerAddress> addrs = new ArrayList<ServerAddress>();  
            addrs.add(serverAddress);  
    
            //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码 
            MongoCredential credential = MongoCredential.createScramSha1Credential(
                    userName, dbName, password.toCharArray());  
            List<MongoCredential> credentials = new ArrayList<MongoCredential>();  
            credentials.add(credential);  
    
            //通过连接认证获取MongoDB连接 
            MongoClient client = new MongoClient(addrs,credentials);  
            System.out.println("成功连接到MongoDB服务器");
            return client;
        }
    
        /**连接到数据库**/
        public static MongoDatabase getDatabase(MongoClient client,String dbName){
            //连接数据库，你需要指定数据库名称，
            //如果指定的数据库不存在，mongo会自动创建数据库。 
            MongoDatabase db = client.getDatabase(dbName);  
            System.out.println("成功连接到 "+dbName+" 数据库");
            return db; 
        }
    
        /**删除数据库**/
        public static void dropDatabase(MongoClient client,String dbName){
            client.dropDatabase(dbName);
            System.out.println("成功删除了 "+dbName+" 数据库");
        }
    
        /**查看服务器内有多少个数据库**/
        public static void listDatabase(MongoClient client){
            MongoIterable<String> dbNames=client.listDatabaseNames();
            int count=0;
            System.out.println("服务器中有");
            for(String dbName: dbNames){
                System.out.println(dbName);
                count++;
            }
            System.out.println("共"+count+"个数据库");
        }
    
        /**在db数据库上创建集合**/
        public static void createCollection(MongoDatabase db,String collectionName){
             //使用 com.mongodb.client.MongoDatabase 类中的createCollection()来创建集合
             db.createCollection(collectionName);
             System.out.println(collectionName+"集合创建成功");
        }
    
        /** * 创建固定集合 * @param db 数据库 * @param collectionName 集合名 * @param sizeInBytes 集合字节大小，一般为10000 */
        public static void createCappedCollection(MongoDatabase db,
                String collectionName,long sizeInBytes){
            //使用 com.mongodb.client.MongoDatabase 类中的
            //createCollection(String collectionName,CreateCollectionOptions cco)来创建集合
            CreateCollectionOptions options=new CreateCollectionOptions();
            options=options.capped(true);   //设置为固定集合
            options=options.sizeInBytes(sizeInBytes); //设置集合的字节大小
            db.createCollection(collectionName,options);
            System.out.println(collectionName+"固定集合创建成功");
        }
    
        /** * 创建固定集合 * @param db 数据库 * @param collectionName 集合名 * @param sizeInBytes 集合字节大小，一般为10000 * @param maxDocuments 集合中文档的个数 */
        public static void createCappedCollection(MongoDatabase db,
                String collectionName,long sizeInBytes,long maxDocuments){
            //使用 com.mongodb.client.MongoDatabase 类中的
            //createCollection(String collectionName,CreateCollectionOptions cco)来创建集合
            CreateCollectionOptions options=new CreateCollectionOptions();
            options.capped(true);//设置为固定集合
            options=options.sizeInBytes(sizeInBytes); //设置集合的字节大小
            options.maxDocuments(maxDocuments); //设置文档个数
            db.createCollection(collectionName);
            System.out.println(collectionName+"固定集合创建成功");
        }
    
        /**获取db数据库的collectionName集合**/
        public static MongoCollection<Document> getCollection(
                MongoDatabase db,String collectionName){
            //使用com.mongodb.client.MongoDatabase类的 getCollection() 方法来获取一个集合
             MongoCollection<Document> collection = db.getCollection(collectionName);
             System.out.println("集合 "+collectionName+" 选择成功");
             return collection;
        }
    
        /**列举db中的集合**/
        public static void listCollection(MongoDatabase db){
            MongoIterable<String> collectionNames=db.listCollectionNames();
            int count=0;
            System.out.println(db+"数据库中有");
            for(String collectionName: collectionNames){
                System.out.println(collectionName);
                count++;
            }
            System.out.println("共"+count+"个集合");
        }
    
        /**删除集合**/
        public static void dropCollection(MongoCollection<Document> collection){
             collection.drop();
             System.out.println(collection.getNamespace().getCollectionName()
                     +"集合删除成功");
        }
    
        /**插入一个文档**/
        public static void insert(MongoCollection<Document> collection,
                Map<String,Object> map){
            //创建文档 org.bson.Document 参数为key-value的格式 
             Document document=new Document(map);
             //使用com.mongodb.client.MongoCollection类的 
             //insertOne(Document) 方法来插入一个文档
             collection.insertOne(document);
             System.out.println("文档插入成功");  
        }
    
        /**插入多个文档**/
        public static void insert(MongoCollection<Document> collection,
                List<Map<String,Object>> maps){
             List<Document> documents = new ArrayList<Document>(); 
             for(Map<String,Object> map: maps){
                 //1. 创建文档 org.bson.Document 参数为key-value的格式
                 Document document=new Document(map);
                 //2. 创建文档集合List<Document> 
                 documents.add(document); 
             }
             // 3. 使用com.mongodb.client.MongoCollection类的 
             //insertMany(List<Document>) 方法来插入多个文档 
             collection.insertMany(documents); 
             System.out.println("文档插入成功");  
        }
    
        /**删除成功**/
        public static void delete(MongoCollection<Document> collection,
                String fieldName,Object value,boolean isAll){
             if(isAll){
                 //删除所有符合条件的文档 
                 collection.deleteMany(Filters.eq(fieldName, value));  
             }else{
                 //删除符合条件的第一个文档 
                 collection.deleteOne(Filters.eq(fieldName, value));  
             }
             System.out.println("文档删除成功");
        }
    
        /**查看所有文档**/
        public static void select(MongoCollection<Document> collection){
            //使用 com.mongodb.client.MongoCollection 类中的 find() 方法来获取集合中的所有文档。
            //此方法返回一个游标，所以你需要遍历这个游标。
             //检索所有文档 
             /** * 1. 获取迭代器FindIterable<Document> * 2. 获取游标MongoCursor<Document> * 3. 通过游标遍历检索出的文档集合 * */  
             FindIterable<Document> findIterable = collection.find();  
             MongoCursor<Document> mongoCursor = findIterable.iterator();  
             while(mongoCursor.hasNext()){  
                System.out.println(mongoCursor.next());  
             }  
        }
    
        /**查看符合查找条件的所有文档**/
        public static void select(MongoCollection<Document> collection,
                String fieldName,Object value){
             Bson bson=Filters.eq(fieldName, value);
             FindIterable<Document> findIterable = collection.find(bson);  
             MongoCursor<Document> mongoCursor = findIterable.iterator();  
             while(mongoCursor.hasNext()){  
                System.out.println(mongoCursor.next());  
             }  
        }
    
        /**更新文档**/
        public static void update(MongoCollection<Document> collection,
                String fieldName,Object oldValue,Object newValue,boolean isAll){
            if(isAll){
                //使用 com.mongodb.client.MongoCollection 类中的 updateMany() 方法来更新集合中的文档。
                collection.updateMany(Filters.eq(fieldName, oldValue), new Document(
                     "$set",new Document(fieldName,newValue)));
            } else{
                collection.updateOne(Filters.eq(fieldName, oldValue), new Document(
                     "$set",new Document(fieldName,newValue)));
            }
            System.out.println("文档更新成功");
        }
    
        /**关闭mongodb连接**/
        public static void close(MongoClient client){
            client.close();
            System.out.println("成功关闭连接！");
        }
    
    }

[http_www.runoob.com_mongodb_mongodb-tutorial.html]: http://www.runoob.com/mongodb/mongodb-tutorial.html