首页 > 代码库 > Java操作MongoDB
Java操作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("文档插入成功!"); } }
本文出自 “SimpleLife” 博客,请务必保留此出处http://simplelife.blog.51cto.com/9954761/1929886
Java操作MongoDB
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。