首页 > 数据库技术 > 详细

java连接 MongoDB

时间:2020-04-30 17:12:44      阅读:35      评论:0      收藏:0      [点我收藏+]
import java.util.ArrayList;
import java.util.List;
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 org.bson.Document;

public class test {
    public static void main(String[] args){
        try {
            //连接到MongoDB服务 如果是远程连接可以替换“localhost”为服务器所在IP地址
            //ServerAddress()两个参数分别为 服务器地址 和 端口
            ServerAddress serverAddress = new ServerAddress("192.168.64.129",27017);
            List<ServerAddress> addrs = new ArrayList<ServerAddress>();
            addrs.add(serverAddress);

            //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码  数据库的用户需要提前授权 需要先从admin进入,认证进入后切换数据库后添加用户授权
            MongoCredential credential = MongoCredential.createScramSha1Credential("test", "runoob", "test".toCharArray());
            List<MongoCredential> credentials = new ArrayList<MongoCredential>();
            credentials.add(credential);

            //通过连接认证获取MongoDB连接
            MongoClient mongoClient = new MongoClient(addrs,credentials);

            //连接到数据库
            MongoDatabase mongoDatabase = mongoClient.getDatabase("runoob");
            System.out.println("Connect to database successfully");


            MongoCollection<org.bson.Document> collection = mongoDatabase.getCollection("col");
            System.out.println("集合 **** 选择成功");

            //检索所有文档
            /**
             * 1. 获取迭代器FindIterable<Document>
             * 2. 获取游标MongoCursor<Document>
             * 3. 通过游标遍历检索出的文档集合
             * */
            FindIterable<org.bson.Document> findIterable = collection.find();
            MongoCursor<Document> mongoCursor = findIterable.iterator();
            
            while(mongoCursor.hasNext()){
                System.out.println(mongoCursor.next());
            }



        } catch (Exception e) {
            System.err.println( e.getClass().getName() + ": " + e.getMessage() );
        }
    }
}

 

java连接 MongoDB

原文:https://www.cnblogs.com/Tian-J-Shuai/p/12809688.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!