Java操作MongoDB

本文涉及的产品
云数据库 MongoDB,独享型 2核8GB
推荐场景:
构建全方位客户视图
简介:

  java驱动程序是Mongodb中的驱动程序之一,也是比较成熟的Mongodb驱动程序之一,下面介绍了使用java连接、操作Mongodb。

          一、安装java驱动程序

                 Mongodb的java驱动程序是一个jar包,可以在:https://github.com/mongodb/mongo-java-driver/downloads 下载,下载的jar导入到eclipse的项目中即可。

          二、java操作Mongodb

                 java操作Mongodb常用的几个类:

                Mongo:连接服务器,执行一些数据库操作的选项,如新建立一个数据库等

                DB:对应一个数据库,可以用来建立集合等操作

                DBCollection:对应一个集合(类似表),可能是我们用得最多的,可以添加删除记录等

                DBObject接口和BasicDBObject对象:表示一个具体的记录,BasicDBObject实现了DBObject,是key-value的数据结构,用起来和HashMap是基本一致的。

                DBCursor:用来遍历取得的数据,实现了Iterable和Iterator

 

private static void mongodbOperating(){ 		try { 			//有多种构造方法,选择一种(IP、port) 			Mongo m = new Mongo( "192.168.21.111" , 27017 ); 			//选择数据库,如果没有这个数据库的话,会自动建立 			DB  db = m.getDB( "mydb" );  			//建立一个集合,和数据库一样,如果没有,会自动建立 			DBCollection collection = db.getCollection("myCollectionTest"); 			 			BasicDBObject doc = new BasicDBObject(); 	        doc.put("name", "MongoDB"); 	        doc.put("type", "database"); 	        doc.put("count", 1);  	        BasicDBObject info = new BasicDBObject(); 	        info.put("x", 203); 	        info.put("y", 102); 	        doc.put("info", info);  	        //插入一条数据,数据如下 	        // { 	        //	   "name" : "MongoDB", 	        //	   "type" : "database", 	        //	   "count" : 1, 	        //	   "info" : { 	        //	               x : 203, 	        //	               y : 102 	        //	             } 	        //	}             // 可以循环插入多条数据 	        collection.insert(doc); 	        //查找第一条数据,显示如下,_id是系统自动帮加上的,全局唯一 	        //{ "_id" : "49902cde5162504500b45c2c" , "name" : "MongoDB" , "type" : "database" , "count" : 1 , "info" : { "x" : 203 , "y" : 102}} 	        DBObject myDoc = collection.findOne(); 	        System.out.println(myDoc); 	         	        //插入多条数据 	        for (int i=0; i < 100; i++) { 	        	collection.insert(new BasicDBObject().append("i", i)); 	        }  	         	        //获取文档条数 	        System.out.println(collection.getCount()); 	         	        //使用Cursor 获取所有文档 	        DBCursor cursor = collection.find(); 	        try { 	            while(cursor.hasNext()) { 	                System.out.println(cursor.next()); 	            } 	        } finally { 	            cursor.close(); 	        } 	         	        //查找操作,获取单条记录 	        //{ "_id" : "49903677516250c1008d624e" , "i" : 71 } 	        BasicDBObject query = new BasicDBObject(); 	        query.put("i", 71); 	        cursor = collection.find(query); 	        try { 	            while(cursor.hasNext()) { 	                System.out.println(cursor.next()); 	            } 	        } finally { 	            cursor.close(); 	        }              //查找 i>50的项 	        query = new BasicDBObject(); 	        query.put("i", new BasicDBObject("$gt", 50));  // e.g. find all where i > 50 	        cursor = collection.find(query); 	        try { 	            while(cursor.hasNext()) { 	                System.out.println(cursor.next()); 	            } 	        } finally { 	            cursor.close(); 	        }   	        //查找 20<i<=30 	        query = new BasicDBObject(); 	        query.put("i", new BasicDBObject("$gt", 20).append("$lte", 30));  // i.e.   20 < i <= 30 	        cursor = collection.find(query); 	        try { 	            while(cursor.hasNext()) { 	                System.out.println(cursor.next()); 	            } 	        } finally { 	            cursor.close(); 	        }  	        //修改 i=71的一项 	        query = new BasicDBObject(); 	        query.put("i", 71); 	        BasicDBObject update = new BasicDBObject(); 	        update.put("i", 710); 	        DBObject dbobj = collection.findAndModify(query, update); 	        System.out.println(dbobj); 	         	        //修改 i=72的一项 	        query = new BasicDBObject(); 	        query.put("i", 72); 	        update = new BasicDBObject(); 	        update.put("i", 720); 	        WriteResult result = collection.update(query, update); 	        System.out.println(result); 	         	        //删除i=61的项 	        query = new BasicDBObject(); 	        query.put("i", 61); 	        collection.findAndRemove(query); 	        //删除i=62的项 	        BasicDBObject remove = new BasicDBObject(); 	        remove.put("i", 62); 	        collection.remove(remove); 	                     //创建索引 1为升序、-1为降序 	        collection.createIndex(new BasicDBObject("i", 1));  // create index on "i", ascending  	        //获取索引列表 	        List<DBObject> list = collection.getIndexInfo(); 	        for (DBObject o : list) { 	            System.out.println(o); 	        }  	        //获取数据库列表 	        for (String s : m.getDatabaseNames()) { 	            System.out.println(s); 	        } 	        //获取集合列表 	        Set<String> colls = db.getCollectionNames(); 	        for (String s : colls) { 	            System.out.println(s); 	        }  	        //删除数据库 	        //m.dropDatabase("my_new_db"); 	          		} catch (UnknownHostException e) { 			// TODO Auto-generated catch block 			e.printStackTrace(); 		} 	}


 

 

 

 

http://www.mongodb.org/display/DOCS/Java+Tutorial



     本文转自xyz_lmn51CTO博客,原文链接:http://blog.51cto.com/xyzlmn/1230770,如需转载请自行联系原作者

相关实践学习
MongoDB数据库入门
MongoDB数据库入门实验。
快速掌握 MongoDB 数据库
本课程主要讲解MongoDB数据库的基本知识,包括MongoDB数据库的安装、配置、服务的启动、数据的CRUD操作函数使用、MongoDB索引的使用(唯一索引、地理索引、过期索引、全文索引等)、MapReduce操作实现、用户管理、Java对MongoDB的操作支持(基于2.x驱动与3.x驱动的完全讲解)。 通过学习此课程,读者将具备MongoDB数据库的开发能力,并且能够使用MongoDB进行项目开发。 &nbsp; 相关的阿里云产品:云数据库 MongoDB版 云数据库MongoDB版支持ReplicaSet和Sharding两种部署架构,具备安全审计,时间点备份等多项企业能力。在互联网、物联网、游戏、金融等领域被广泛采用。 云数据库MongoDB版(ApsaraDB for MongoDB)完全兼容MongoDB协议,基于飞天分布式系统和高可靠存储引擎,提供多节点高可用架构、弹性扩容、容灾、备份回滚、性能优化等解决方案。 产品详情: https://www.aliyun.com/product/mongodb
相关文章
|
4月前
|
Java BI 数据处理
如何在Java中实现Excel操作
如何在Java中实现Excel操作
|
6天前
|
NoSQL Java 数据库连接
MongoDB Java
10月更文挑战第18天
11 3
|
20天前
|
存储 JSON NoSQL
Java 中MongoDB的使用
Java 中MongoDB的使用
14 2
|
2月前
|
NoSQL JavaScript Java
Java Python访问MongoDB
Java Python访问MongoDB
22 4
|
4月前
|
存储 Java 索引
Java ArrayList操作指南:如何移除并返回第一个元素
通过上述方法,你可以方便地从Java的 `ArrayList` 中移除并返回第一个元素。这种操作在日常编程中非常常见,是处理列表时的基本技能之一。希望这篇指南能帮助你更好地理解和运用Java的 `ArrayList`。
46 4
|
4月前
|
DataWorks NoSQL fastjson
DataWorks操作报错合集之DataX进行MongoDB全量迁移的过程中,DataX的MongoDB Reader插件在初始化阶段找不到Fastjson 2.x版本的类库,该怎么办
DataWorks是阿里云提供的一站式大数据开发与治理平台,支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
|
4月前
|
分布式计算 DataWorks Java
DataWorks操作报错合集之使用ODPS Tunnel Upload功能时,遇到报错:Java 堆内存不足,该如何解决
DataWorks是阿里云提供的一站式大数据开发与治理平台,支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
|
4月前
|
SQL 缓存 Java
使用MyBatis优化Java持久层操作
使用MyBatis优化Java持久层操作
|
3月前
|
NoSQL Java 关系型数据库
MongoDB保姆级指南(下):无缝集成SpringData框架,一篇最全面的Java接入指南!
前面的两篇文章已经将MongoDB大多数知识进行了阐述,不过其中的所有内容,都基于原生的MongoDB语法在操作。可是,在实际的日常开发过程中,我们并不会直接去接触MongoDB,毕竟MongoDB只能算作是系统内的一个组件,无法仅依靠它来搭建出一整套系统。
|
4月前
|
Java API 开发者
Java中的文件I/O操作详解
Java中的文件I/O操作详解