设为首页 加入收藏

TOP

【MongoDB数据库】JavaMongoDBCRUDExample(一)
2015-07-24 11:09:59 来源: 作者: 【 】 浏览:2
Tags:MongoDB 数据库 JavaMongoDBCRUDExample

上一篇我们讲了MongoDB 的命令入门初探,本篇blog将基于上一篇blog所建立的数据库和表完成一个简单的Java MongoDB CRUD Example,利用Java连接MongoDB数据库,并实现创建数据库、获取表、遍历表中的对象、对表中对象进行CRUD操作等例程。

1、下载MongoDB Java 支持驱动包

【gitHub下载地址】https://github.com/mongodb/mongo-java-driver/downloads

2、建立Java工程,并导入jar包

3、连接本地数据库服务器

在控制面板中开启Mongodb服务,具体操作可参考【MongoDB数据库】如何安装、配置MongoDB

		try {
			mongo = new MongoClient("localhost", 27017);// 保证MongoDB服务已经启动
			db = mongo.getDB("andyDB");// 获取到数据库
		} catch (UnknownHostException e) {
			e.printStackTrace();
		}

3、遍历所有的数据库名

public class DBConnection extends TestCase {

	private MongoClient mongo;
	private DB db ;

	@Override
	protected void setUp() throws Exception {
		// TODO Auto-generated method stub
		super.setUp();
		try {
			mongo = new MongoClient("localhost", 27017);// 保证MongoDB服务已经启动
			db = mongo.getDB("andyDB");// 获取到数据库andyDB
		} catch (UnknownHostException e) {
			e.printStackTrace();
		}
	}

	public void testGetAllDB() {
		List dbs = mongo.getDatabaseNames();// 获取到所有的数据库名
		for (String dbname : dbs) {
			System.out.println(dbname);
		}
	}
}

4、获取到指定数据库

       DB db = mongo.getDB("andyDB");// 获取到数据库

5、遍历数据库中所有的表名

在DBConnection测试类中添加如下测试方法即可:

	public void testGetAllTables() {
		Set tables = db.getCollectionNames();
		for (String coll : tables) {
			System.out.println(coll);
		}
	}

6、获取到指定的表

DBCollection table = db.getCollection("person");

7、遍历表中所有的对象

public void testFindAll(){
		DBCollection table = db.getCollection("person");
		DBCursor dbCursor = table.find();
		while(dbCursor.hasNext()){
			DBObject dbObject = dbCursor.next();
			//打印该对象的特定字段信息
			System.out.println("name:"+	dbObject.get("name")+",age:"+dbObject.get("age"));
			//打印该对象的所有信息
			System.out.println(dbObject);
		}
	}

Console窗口打印消息:

name:jack,age:50.0
{ "_id" : { "$oid" : "537761da2c82bf816b34e6cf"} , "name" : "jack" , "age" : 50.0}
name:小王,age:24
{ "_id" : { "$oid" : "53777096d67d552056ab8916"} , "name" : "小王" , "age" : 24}

8、保存对象

1)保存对象方法一

	public void testSave() {
		DBCollection table = db.getCollection("person");
		BasicDBObject document = new BasicDBObject();
		document.put("name", "小郭");// 能直接插入汉字
		document.put("age", 24);//"age"对应的值是int型
		table.insert(document);
	}
在mongodb shell中使用命令查看数据

> db.person.find()
{ "_id" : ObjectId("537761da2c82bf816b34e6cf"), "name" : "jack", "age" : 50 }
{ "_id" : ObjectId("53777096d67d552056ab8916"), "name" : "小王", "age" : 24 }
{ "_id" : ObjectId("5377712cd67d84f62c65c4f6"), "name" : "小郭", "age" : 24 }

2)保存对象方法二

	public void testSave2() {
		DBCollection table = db.getCollection("person");
		BasicDBObject document = new BasicDBObject();//可以添加多个字段
		document.put("name", "小张");// 能直接插入汉字
		document.put("password", "xiaozhang");// 多添加一个字段也是可以的,因为MongoDB保存的是对象;
		document.put("age", "23");//"age"对应的值是String
		table.insert(document);
	}

在mongodb shell中使用命令查看数据

> db.person.find()
{ "_id" : ObjectId("537761da2c82bf816b34e6cf"), "name" : "jack", "age" : 50 }
{ "_id" : ObjectId("53777096d67d552056ab8916"), "name" : "小王", "age" : 24 }
{ "_id" : ObjectId("5377712cd67d84f62c65c4f6"), "name" : "小郭", "age" : 24 }
{ "_id" : ObjectId("53777230d67dfe576de5079a"), "name" : "小张", "password" : "xiaozhang", "age" : "23" }

3)保存对象方法三通过添加Map集合的方式添

首页 上一页 1 2 下一页 尾页 1/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
分享到: 
上一篇视图 下一篇Hibernate中关联关系的CRUD(增删..

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容:

·Java 学习线路图是怎 (2025-12-25 15:19:15)
·关于 Java 学习,有 (2025-12-25 15:19:12)
·有没有Java swing教 (2025-12-25 15:19:09)
·Start, Stop, and Di (2025-12-25 14:50:57)
·C语言入门教程:零基 (2025-12-25 14:50:54)