mongoDB小记

时间：2022-03-14 21:00

mongodb的一个简单使用。

  
    
    package 
com.chuntent.mongo;
 
import java.util.Map;
import java.util.Map.Entry;
 
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.Mongo;
 
public 
class MongoTool {
    private 
Mongo mg = null;
    public 
MongoTool(){
        try{
            mg = new 
Mongo("192.168.93.99", 10001);         
        }catch(Exception e){
            e.printStackTrace();
        }
    }
    public 
boolean initConnection(String url , int 
port){
        try{
            mg = new 
Mongo(url, port);
            return 
true;
        }catch(Exception e){
            e.printStackTrace();
            return 
false;
        }
    }
    /**
     * @Description 向mongodb中插入数据
     * @param dbname db名称
     * @param collectonname 表名
     * @param map 要插入的数据
     * @return
     */
    public 
boolean insert(String dbname , String collectonname , Map<String , String> map){
        try{
            DB db = mg.getDB(dbname);
            DBCollection conn = db.getCollection(collectonname);
            for(Entry<String , String> en : map.entrySet()){
                BasicDBObject objDB = new 
BasicDBObject();
                objDB.put(en.getKey() , en.getValue());
                conn.save(objDB);
            }
            return 
true;
        }catch(Exception e){
            e.printStackTrace();
            return 
false;
        }
    }
    /**
     * @Description 关闭链接
     */
    public 
void closeConnection(){
        mg.close();
    }
    public 
static void main(String[] args) {
        try{
             
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}