MongoDB 之java API

怼烎@ 2023-06-12 09:56 34阅读 0赞

linux安装MongoDB([https://blog.csdn.net/eyeofeagle/article/details/96428363][https_blog.csdn.net_eyeofeagle_article_details_96428363] ), 使用java api测试数据库语法

# 1，maven依赖 #

<dependency>
            <groupId>org.mongodb</groupId>
            <artifactId>mongo-java-driver</artifactId>
            <version>3.6.1</version>
        </dependency>

# 2，MongoDB的Java API #

import com.mongodb.*;
    import com.mongodb.client.FindIterable;
    import com.mongodb.client.MongoCollection;
    import com.mongodb.client.MongoDatabase;
    import org.bson.Document;
    
    import java.util.ArrayList;
    import java.util.Iterator;
    import java.util.Set;
    
    public class MongodbCRUD_insert { 
        public static void main(String[] args) { 
    // insertMany();
            insertOne();
        }
        public static void insertOne() { 
            String user = "test";                   //用户名
            String database = "test";              //数据库
            char[] password = "123456".toCharArray();   //密码
    
            MongoCredential credential = MongoCredential.createCredential(user,database,password);   //验证对象
            MongoClientOptions options = MongoClientOptions.builder().sslEnabled(false).build();     //连接操作对象
            MongoClient mongoClient = new MongoClient(new ServerAddress("218.245.1.135",27017),credential,options);   //连接对象
    
            //插入１条
            MongoDatabase db = mongoClient.getDatabase("test");
            MongoCollection<Document> t1 = db.getCollection("t1");
            Document doc = new Document("id", Double.valueOf(10)).append("name", "lisi10").append("age", Double.valueOf(30));
            t1.insertOne(doc);
    
            //查询结果
            t1.find().forEach((Block<Document>) document -> { 
                System.out.println( document.getString("name") );
            });
        }
        public static void insertMany() { 
            String user = "test";                   //用户名
            String database = "test";              //数据库
            char[] password = "123456".toCharArray();   //密码
    
            MongoCredential credential = MongoCredential.createCredential(user,database,password);   //验证对象
            MongoClientOptions options = MongoClientOptions.builder().sslEnabled(false).build();     //连接操作对象
            MongoClient mongoClient = new MongoClient(new ServerAddress("218.245.1.135",27017),credential,options);   //连接对象
    
            //插入１条
            MongoDatabase db = mongoClient.getDatabase("test");
            MongoCollection<Document> t1 = db.getCollection("t1");
            Document doc = new Document("id", Double.valueOf(11)).append("name", "lisi11").append("age", Double.valueOf(20));
            Document doc2 = new Document("id", Double.valueOf(12)).append("name", "lisi12").append("age", Double.valueOf(30));
            ArrayList<Document> list = new ArrayList<Document>();
            list.add(doc);
            list.add(doc2);
            t1.insertMany(list);
        }
    
        public static void truncate() { 
            String user = "test";                   //用户名
            String database = "test";              //数据库
            char[] password = "123456".toCharArray();   //密码
    
            MongoCredential credential = MongoCredential.createCredential(user,database,password);   //验证对象
            MongoClientOptions options = MongoClientOptions.builder().sslEnabled(false).build();     //连接操作对象
            MongoClient mongoClient = new MongoClient(new ServerAddress("218.245.1.135",27017),credential,options);   //连接对象
    
            //插入１条
            MongoDatabase db = mongoClient.getDatabase("test");
            MongoCollection<Document> t1 = db.getCollection("t1");
    
            Document doc = new Document("id", Double.valueOf(11)).append("name", "lisi11").append("age", Double.valueOf(20));
            Document doc2 = new Document("id", Double.valueOf(12)).append("name", "lisi12").append("age", Double.valueOf(30));
            ArrayList<Document> list = new ArrayList<Document>();
            list.add(doc);
            list.add(doc2);
            t1.insertMany(list);
        }
    }

[https_blog.csdn.net_eyeofeagle_article_details_96428363]: https://blog.csdn.net/eyeofeagle/article/details/96428363