Java使用MongoDB简单操作

原创
2017/06/06 11:01
阅读数 211

一、启动MongoDB服务

1、进入安装目录下的bin目录(data为数据库文件目录)    

mongod --dbpath=E:\mongodb\data

显示 NETWORK  [thread1] waiting for connections on port 27017表示启动成功

2、使用 Robomongo 可视化工具连接MongoDB

3、下载 mongo-java-driver-3.4.2.jar 并导入到项目里  (我本地安装的是3.4.4版本的)

4、用 Robomongo 创建一个名为 “userMEssagesList”的集合

使用以下代码连接数据库和打印出该集合所有记录以及所用时间

            // 连接到 mongodb 服务
			@SuppressWarnings("resource")
			MongoClient mongoClient = new MongoClient("localhost", 27017);

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

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

			long beginTime=System.currentTimeMillis(); FindIterable<Document>
			queryAll=collection.find(); System.out.println("所有记录:");
			for(Iterator<Document> iter=queryAll.iterator();iter.hasNext();){
			System.out.println(iter.next()); } long
			endTime=System.currentTimeMillis();
			System.out.println("查询所有记录用时:"+(endTime-beginTime)+" ms");

输出结果:

Connect to MongoDatabase successfully
集合 userMessagesList 选择成功
所有记录:

Document{{_id=593618e716516f81fa0a293b, name=kobe, age=08}}
查询所有记录用时:105 ms

5、更新集合数据

            // 更新文档
			collection.updateMany(Filters.eq("name", "kobe"), new Document(
					"$set", new Document("name", "KobeBryant")));
			// 检索查看结果
			FindIterable<Document> findIterable = collection.find();
			MongoCursor<Document> mongoCursor = findIterable.iterator();
			while (mongoCursor.hasNext()) {
				System.out.println(mongoCursor.next());
			}

输出结果:

Document{{_id=593618e716516f81fa0a293b, name=KobeBryant, age=08}}

6、插入文档

             //插入文档  
	         Document document = new Document("title", "MongoDB").  
	         append("description", "database").  
	         append("age", 100).  
	         append("test", "kobe");  
	         List<Document> documents = new ArrayList<Document>();  
	         documents.add(document);  
	         collection.insertMany(documents);  
	         System.out.println("文档插入成功");

查看结果如下:

展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部