你的位置:首页 > 数据库

[数据库]MONGODB(三)——Java操作Mongo


相比于java调用MySqlApI来操作数据库,调用Mongo要简洁容易的多。通过一个简单的样例,很容易地就可以上手

一、导入Jar包

添加Monog支持Java的jar包,这里使用的是2.9.3

<dependency>		<groupId>org.mongodb</groupId>		<artifactId>mongo-java-driver</artifactId>		<version>2.9.3</version></dependency>

 

二、一个简单的样例

// 连接到mongodbMongo mongo = new Mongo("localhost", 27017); // 打开数据库testDB db = mongo.getDB("test");//获取表,emp为表的名字,若表不存在则会自行创建DBCollection coll = db.getCollection("emp");//创建记录对象,append的作用是添加属性值BasicDBObject doc = new BasicDBObject("name", "fzj").append("sex",				"man");//在数据库表中添加记录coll.insert(doc);

三、自己写的接口实现类(CURD)

通过上面的简单样例,只要接触过数据库和了解一些Mongo的语法。相信接口实现类很容易看懂

public class DBImpl implements DBTool {	static DB db;	static {		Mongo mongo;		try {			mongo = new Mongo("localhost", 27017);			db = mongo.getDB("test");		} catch (UnknownHostException e) {			e.printStackTrace();		}	}	@Override	public void insert(String tableName, BasicDBObject dbObject)			throws UnknownHostException {		DBCollection coll = db.getCollection(tableName);		coll.insert(dbObject);	}	@Override	public void delete(String tableName, BasicDBObject dbObject)			throws UnknownHostException {		DBCollection coll = db.getCollection(tableName);		coll.remove(dbObject);	}	@Override	public void update(String tableName, BasicDBObject docFind,			BasicDBObject doc) throws UnknownHostException {		DBCollection coll = db.getCollection(tableName);		coll.update(docFind, doc);	}	@Override	public DBObject find(String tableName, BasicDBObject dbObject)			throws UnknownHostException {		DBCollection coll = db.getCollection(tableName);		return (DBObject) coll.find();	}}

参考

[1] 《mongodb-java-driver基本用法》 http://www.cnblogs.com/yjmyzz/p/3865175.html