读书人

mongo 装配与CRUD操作

发布时间: 2012-12-19 14:13:14 作者: rapoo

mongo 安装与CRUD操作
mongo 安装与CRUD操作
-----》mongo安装
解压安装mongoDB
先创建数据库所在目录 如:D:\mySorftTool\mongo\data\db
启动数据库 D:\mySorftTool\mongo\bin>mongod --dbpath D:\mySorftTool\mongo\data\db

-----》CURD操作

import java.net.UnknownHostException;import com.mongodb.Mongo;import com.mongodb.DBCollection;import com.mongodb.BasicDBObject;import com.mongodb.DBObject;import com.mongodb.DBCursor;import com.mongodb.MongoException;public class TestMongDBCase {/** * @param args * @throws MongoException  * @throws UnknownHostException  *  */private static String host="localhost";private static int port=27017;private static String dbName="test";public static DBCollection getConnection(String host,int port,String dbName)    throws UnknownHostException, MongoException{Mongo db = new Mongo(host, port);DBCollection coll=db.getDB(dbName).getCollection("testCollection");System.out.println(coll );return coll;}public void getOneData () throws  Exception{DBCollection coll=getConnection(host, port, dbName);DBObject myDoc = coll.findOne();System.out.println(myDoc);}public void getAllData () throws  Exception{DBCollection coll=getConnection(host, port, dbName);DBCursor myDoc = coll.find();while(myDoc.hasNext()){System.out.println(myDoc.next());}}public void getDeleteData () throws  Exception{DBCollection coll=getConnection(host, port, dbName);BasicDBObject delete = new BasicDBObject();delete.put("name", "MongoDB"); coll.remove(delete); }public void getQuery () throws  Exception{DBCollection coll=getConnection(host, port, dbName);BasicDBObject query = new BasicDBObject();query.put("name", "MongoDB");DBCursor cur = coll.find(query);while(cur.hasNext()){ System.out.println(cur.next());}}public void addData () throws  Exception{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);DBCollection coll=getConnection(host, port, dbName);coll.insert(doc);}public static void main(String[] args) throws Exception {new TestMongDBCase ().getDeleteData();new TestMongDBCase ().getQuery();new TestMongDBCase ().getAllData();new TestMongDBCase ().getOneData();new TestMongDBCase ().addData(); }}

读书人网 >编程

热点推荐