Java 连接 MongoDB

2021-03-03  本文已影响0人  西贝巴巴
package com.company;

import com.mongodb.MongoClient;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCursor;

/*

传统原始的方法,不使用框架和 maven 框架和maven 后期会单独出一个
这里我们需要加载3个包 加载驱动
bson-3.12.8.jar mongo-java-driver-3.12.8.jar mongodb-driver-core-3.12.8.jar

连接数据库
连接数据库,你需要指定数据库名称,如果指定的数据库不存在,mongo会自动创建数据库。



 */


public class Mongodbc {

    public static void main(String args[]) {
        try {
            // 连接到 mongodb 服务
            MongoClient mongoClient = new MongoClient("localhost", 27017);

            // 连接到数据库
            MongoDatabase mongoDatabase = mongoClient.getDatabase("db_tiktok");
            System.out.println("Connect to database successfully");
            //获取集合
            MongoCollection<Document> collection = mongoDatabase.getCollection("musicId_A");
            System.out.println("集合 user 选择成功");
            //检索所有文档
            /**
             * 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());
            }
        } catch (Exception e) {
            System.err.println(e.getClass().getName() + ": " + e.getMessage());
        }
    }
}
上一篇下一篇

猜你喜欢

热点阅读