hadoop视频教程java操作mongodb

1、Java 操作 mongodb 简单介绍MONGODB 的官网：MONGODB 的MONGODB：的驱动：java/mongodb/mongo-java-driver/downloads针对的文档：MONGODBjavaapi一Java 与 mongodb 的连接1.1 连单台 mongodbnew Mongo();/默认连本机 端口为 27017Mongomg=Mongomg=new Mongo(ip);/可以指定ip 端口默认为 27017Mongomg=new Mongo(ip,port);/也可以指定ip 及端1.2 连双台 mongodb/ip 为主机ip 地址，p

2、ort 为端，dataBaseName 相当于数据库名DBAddress left = new DBAddress(ip:port/dataBaseName); DBAddress right = new DBAddress(ip:port/dataBaseName );/若一个mongodb 出现问题，会自动连另外一台Mongo mongo = new Mongo(left, right);1.3 连多台 mongodbList mongoHostList = newArrayList();mongoHostList.add(new mongoHostList.add(new mongoHo

3、stList.add(newServerAddress(ip,port); ServerAddress(ip,port); ServerAddress(ip,port);Mongo mg = new Mongo(mongoHostList);二Java 获取 mongodb 的数据库名2.1 获取 mongodb 的 db/dataBaseName 相当于关系数据库里的数据库名，mongodb 中若没有该数据库名也/不会报错，默认 mongodb 会建立这个数据库名，为空。DB db = mg.getDB(dataBaseName);注意：mongodb 区分大小写，程序中一定要注意2.2mo

4、ngodb 的 db 安全认证/如果mongodb 服务器运行时加了用户名及安全认证 如下图若这个时候要想db 中的collection（相当于关系数据库里的表），就必须通过安全认证才可以，否则会报您没有通过安全认证。/安全认证java 代码 返回true 表示通过，false 表示没通过不能进行操作auth=db.authenticate(userName,password.toCharArray(); if(auth)三Java 对 mongodb 的 collection 进行 crud 操作3.1 得到 mongodb 中的 db 的 collection/参数tableName 相当

5、于关系数据库里的表名,/若mongodb 中没有该tableName，默认会创建该tableName,为空DBCollection users = db.getCollection(tableName);3.2mongodb 中的 db 的 collection 自增长主键Mongodb 中也像传统的关系数据库里表一样，有主键（_id）概念，用来唯一标识他们。当用户往 collection 中一条新的时候，如果没有指定_id 属性，那么 mongodb 会自动生成一个 ObjectId 类型的值，保存为_id的值。_id 的值可以为任何类型，除了数组，在实际应用中，鼓励用户自己定义_id值，但

6、是要保证他的唯一性。传统的数据库中，通常用一个递增的序列来提供主键，在 Mongodb 中用ObjectId 来代替，可以通过如下的方法来得到主键。public class Tools /* 实现mongodb主键自增长的功能*param usersparam tableNamereturn*/public sic long getNext(DBCollection users,String tableName)long incId = 0;try DBObject ret = users.findAndModify(new BasicDBObject(_id, tableName), nul

7、l, null, false, new BasicDBObject($inc, new BasicDBObject(next, 1), true, true);incId = Long.valueOf(ret.get(next).toString(); catch (Exception e) e.prStackTrace();return incId;3.3java 对 collection 进行操作/第一种方式DBObject data1 = new BasicDBObject(); data1.put(_id, Tools.getNext(users, webcall_notice_gx)

8、; data1.put(cust_Id, 123456); data1.put(cust_Name, ); data1.put(cust_BranchNo, 12345);data1.put(notice_Id, 2);data1.put(is_Show, 1); data1.put(start_time, new Date(); data1.put(end_time, new Date(); data1.put(province_Id, 22);data1.put(notice_time_number, 20110616);users.insert(data1);/等同于users.save

9、(data1);/第二中方式BasicDBObjectBuilder data1 = BasicDBObjectBuilder.start().add(_id, webcall_notice_gx).add( );Tools.getNext(users,users.insert(data1.get();/等同于users.save(data1.get();/第三种方式Map data1 = new HashMap(); data1.put(_id, Tools.getNext(users, webcall_notice_gx);users.insert(new BasicDBObject(da

10、ta1);/等同于users.save(new BasicDBObject(data1);/第四中方式String json = database : mkyongDB,table : hosting,+detail : records : 99, index : vps_index1, active : true;DBObject data1 = (DBObject)JSON.parse(json);users.insert(data1);/等同于users.save(data1);3.4java 对 collection 的查询操作/查询所有的数据 find() 注意他返回的是DBCurs

11、orDBCursor cur = users.find();while(cur.hasNext()System.out.prln(cur.next();Find()里面可以加很多参数，相当于关系数据库里where 条件一样如：/查询 id 的值为 30000 的相当于where _id=30000DBCursor cur = users.find(new BasicDBObject(_id,30000);while(cur.hasNext()System.out.prln(cur.next();/查询id 大于等于 30000 的相当于where _id=30000DBCursor cur =

12、 users.find(new BasicDBObject(_id,new BasicDBObject($gte,30000);while(cur.hasNext()System.out.prln(cur.next();/查询id 大于等于 1 的，并且只取 10 条DBCursor cur = users.find(new BasicDBObject(_id,new BasicDBObject($gte,1).limit(10);while(cur.hasNext()System.out.prln(cur.next();/查询id 大于等于 1 的，并按id 进行降序 -1 表示降序，1 升序。DBCursorcur=users.find(newBasicDBObject(_id,newBasicDBObject($gte,1).sort(new BasicDBObject(_id,-1);while(cur.hasNext()System.out.prln(cur.next();/查询id 大于等于 1 的，并跳过前 10 条显示 相当于id10DBCursor cur = users.find(new BasicDBObject(_id,new BasicDBObject($gte,1).skip(10);while(cur.hasNe