mongo 安装与CRUD操作

trssc

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

}
}