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(); }}