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());
}
}
}
网友评论