mongodb实现简单的增删改查
package mongoDB;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.List;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
public class test{
private static Mongo m = null;
private static DB db = null;
private static final String COLLECTION_NAME = "mcpang";
public static void main(String[] args) {
startMongoDBConn();
createColData();
readColData();
updateColData();
readColData();
deleteColData();
readColData();
db.getCollection(COLLECTION_NAME).drop();
stopMondoDBConn();
}
private static void createColData(){
DBCollection dbCol = db.getCollection(COLLECTION_NAME);
System.out.println("向数据集中插入数据开始：");
List<DBObject> dbList = new ArrayList<DBObject>();
BasicDBObject doc1 = new BasicDBObject();
doc1.put("name", "小李");
doc1.put("age", 30);
doc1.put("address", "北京");
dbList.add(doc1);
BasicDBObject doc2 = new BasicDBObject();
doc2.put("name", "小张");
doc2.put("age", 25);
doc2.put("address", "天津");
dbList.add(doc2);
dbCol.insert(dbList);
System.out.println("向数据集中插入数据完成！");
System.out.println("------------------------------");
}
private static void readColData(){
DBCollection dbCol = db.getCollection(COLLECTION_NAME);
DBCursor ret = dbCol.find();
System.out.println("从数据集中读取数据：");
while(ret.hasNext()){
BasicDBObject bdbObj = (BasicDBObject) ret.next();
if(bdbObj != null){
System.out.println("name:"+bdbObj.getString("name"));
System.out.println("age:"+bdbObj.getInt("age"));
System.out.println("address:"+bdbObj.getString("address"));
}
}
}
private static void updateColData(){
System.out.println("------------------------------");
DBCollection dbCol = db.getCollection(COLLECTION_NAME);
DBCursor ret = dbCol.find();
BasicDBObject doc = new BasicDBObject();
BasicDBObject res = new BasicDBObject();
res.put("age", 40);
System.out.println("将数据集中的所有文档的age修改成40！");
doc.put("$set", res);
dbCol.update(new BasicDBObject(),doc,false,true);
System.out.println("更新数据完成！");
System.out.println("------------------------------");
}
private static void deleteColData(){
System.out.println("------------------------------");
DBCollection dbCol = db.getCollection(COLLECTION_NAME);
System.out.println("删除【小李】！");
BasicDBObject doc = new BasicDBObject();
doc.put("name", "小李");
dbCol.remove(doc);
System.out.println("------------------------------");
}
private static void stopMondoDBConn(){
if (null != m) {
if (null != db) {
try {
db.requestDone();
} catch(Exception e) {
e.printStackTrace();
}
}
try
{
m.close();
} catch(Exception e) {
e.printStackTrace();
}
m = null;
db = null;
}
}
private static void startMongoDBConn(){
try {
m = new Mongo("127.0.0.1", 27017);
db = m.getDB("yyl");
if (!db.authenticate("yyl", "yyl123".toCharArray())){
System.out.println("连接MongoDB数据库,校验失败！");
}else{
System.out.println("连接MongoDB数据库,校验成功！");
}
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (MongoException e) {
e.printStackTrace();
}
}
}
MongoDB技术学习,更多资源请访问 https://www.itkc8.com
