温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Java操作MongoDB

发布时间:2020-04-04 21:48:06 来源:网络 阅读:2387 作者:兴趣e族 栏目:MongoDB数据库

先引入mongo-java-dirver驱动

<!-- mongo-java-dirver -->
<dependency>
	<groupId>org.mongodb</groupId>
	<artifactId>mongo-java-driver</artifactId>
	<version>3.4.2</version>
</dependency>

代码操作演示:

package com.simple.database.test;

import java.util.ArrayList;
import java.util.List;

import org.bson.Document;
import org.bson.conversions.Bson;

import com.mongodb.MongoClient;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;

/**
 * java操作MongoDB
 * @author root
 */
public class HelloMongoDB {

	public static void main(String[] args) {
		try {
//			1、连接到MongoDB服务
			MongoClient mc = new MongoClient("127.0.0.1", 27017);

//			2、连接到指定数据库
			MongoDatabase db = mc.getDatabase("demodb");
			
//			3、创建集合
//			db.createCollection("simplelife");
			
//			4、获取集合
			MongoCollection<Document> collection = db.getCollection("users");

//			5、插入文档数据
//			insertCollectionData(collection);
			
//			6、查询文档数据
			findCollectionData(collection);
			
//			7、更新文档数据
//			将文档中likes=100的文档修改为likes=200   
			updateCollectionData(collection);
			
//			8、删除第一个文档数据
			collection.deleteMany(Filters.eq("likes",200));
			collection.deleteOne(Filters.eq("likes",100));
		} catch (Exception e) {
			e.printStackTrace();
			System.out.println(e.getClass().getName() + "……" + e.getMessage());
		}

	}

	private static void updateCollectionData(
			MongoCollection<Document> collection) {
		Bson filter = Filters.eq("likes", 100);
		Document update = new Document("$set", new Document("likes", 200));
		collection.updateMany(filter, update);
	}

	private static void findCollectionData(MongoCollection<Document> collection) {
		FindIterable<Document> findIterable = collection.find();
		MongoCursor<Document> mongoCursor = findIterable.iterator();
		while(mongoCursor.hasNext()){
			System.out.println(mongoCursor.next());
		}
	}

	/**
	 * 插入文档 1、创建文档org.bson.Document参数为key-value的格式
	 * 2、创建文档集合List<Document>
	 * 3、将文档集合插入数据库集合:mongoCollection.insertMany(List<Document>)
	 * 插入单个文档可以用 :mongoCollection.insertOne(Document)
	 */
	private static void insertCollectionData(
			MongoCollection<Document> collection) {
		Document document = new Document("title", "MongoDB");
		document.append("description", "database").append("likes", 100)
				.append("by", "Fly");
		List<Document> documents = new ArrayList<>();
		documents.add(document);
		collection.insertMany(documents);
		System.out.println("文档插入成功!");
	}
}


向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI