mongo入库测试java

 
import java.net.UnknownHostException;  
import java.util.ArrayList;  
import java.util.Date;  
import java.util.List;  
import java.util.Set;  
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;  

/**
*
* @author lt
* modity by 47160999
* 两种测试插入数据的时间
*/


public class MongoDB {  
    String collectionsName = "mydb";  
    String dbName = "test";  
    DBCollection coll = null;  
   
   
   
    Mongo m = null;  

   
    public static void main(String[] ariv){
   
    MongoDB mDb= new MongoDB();
   
    mDb.getAllCollections();
    int i=0;long ls=0,es=0;
    System.out.println("save方式 ");
       
        
       System.out.println("---------------------start-------------------- ");
    ls=0;
    es=0;
   
      ls=System.currentTimeMillis();
   for (i=0;i<100;i++){
   mDb.save(i);
   }
   es=System.currentTimeMillis();
   System.out.println("插入100数据，耗时 (毫秒):"+(es-ls));
   ls=0;
   es=0;
   ls=System.currentTimeMillis();
   for (i=0;i<1000;i++){
   mDb.save(i);
   }
   es=System.currentTimeMillis();
   System.out.println("插入1000数据，耗时 (毫秒):"+(es-ls));
   ls=0;
   es=0;
    
    
    
   ls=System.currentTimeMillis();
   for (i=0;i<10000;i++){
   mDb.save(i);
   }
   es=System.currentTimeMillis();
   System.out.println("插入10000数据，耗时 (毫秒):"+(es-ls));
   ls=0;
   es=0;
   
   ls=System.currentTimeMillis();
   for (i=0;i<100000;i++){
   mDb.save(i);
   }
   es=System.currentTimeMillis();
   System.out.println("插入100000数据，耗时 (毫秒):"+(es-ls));
   ls=0;
   es=0;

    
    
    
     ls=System.currentTimeMillis();
     for (i=0;i<1000000;i++){
     mDb.save(i);
     }
     es=System.currentTimeMillis();
     System.out.println("插入1000000数据，耗时 (毫秒):"+(es-ls));
    
    System.out.println("----------------------end--------------------- ");
   
    System.out.println("insert方式 ");
    System.out.println("---------------------start-------------------- ");
    ls=0;
    es=0;
   
      ls=System.currentTimeMillis();
   for (i=0;i<100;i++){
   mDb.insert(i);
   }
   es=System.currentTimeMillis();
   System.out.println("插入100数据，耗时 (毫秒):"+(es-ls));
   ls=0;
   es=0;
   ls=System.currentTimeMillis();
   for (i=0;i<1000;i++){
   mDb.insert(i);
   }
   es=System.currentTimeMillis();
   System.out.println("插入1000数据，耗时 (毫秒):"+(es-ls));
   ls=0;
   es=0;
    
    
    
   ls=System.currentTimeMillis();
   for (i=0;i<10000;i++){
   mDb.insert(i);
   }
   es=System.currentTimeMillis();
   System.out.println("插入10000数据，耗时 (毫秒):"+(es-ls));
   ls=0;
   es=0;
   
   ls=System.currentTimeMillis();
   for (i=0;i<100000;i++){
   mDb.insert(i);
   }
   es=System.currentTimeMillis();
   System.out.println("插入100000数据，耗时 (毫秒):"+(es-ls));
   ls=0;
   es=0;
    
     ls=System.currentTimeMillis();
     for (i=0;i<1000000;i++){
     mDb.insert(i);
     }
     es=System.currentTimeMillis();
     System.out.println("插入1000000数据，耗时 (毫秒):"+(es-ls));
    
    System.out.println("----------------------end--------------------- ");
   
   
    //mDb.findOne();
   
    }
   
    public MongoDB() {  
        try {  
            coll = getDBCollection(collectionsName);  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
    }  
 
    public DBCollection getDBCollection(String collectionName) {  
        DBCollection coll = null;  
        try {  
            m = new Mongo("127.0.0.1", 27017);  
            DB db = m.getDB(dbName);  
//          if (db.authenticate("ljc", "007".toCharArray())) {  
//              System.out.println("success");  
//          }  
            coll = db.getCollection(collectionName);  
        } catch (UnknownHostException e) {  
            e.printStackTrace();  
        } catch (MongoException e) {  
            e.printStackTrace();  
        }  
        return coll;  
    }  
 
    // mongo db 删除数据库  
    public void dropDatabase() {  
        try {  
            m.dropDatabase(dbName);  
        } catch (MongoException e) {  
            e.printStackTrace();  
        }  
    }  
 
    // mongo db查询所有表名  
    public void getAllCollections() {  
        DB db = m.getDB("mydb");  
        Set<String> colls = db.getCollectionNames();  
        for (String s : colls) {  
            System.out.println(s);  
        }  
    }  
 
    // mongo db 查询索引  
    public void getAllIndex() {  
        List<DBObject> list = coll.getIndexInfo();  
        for (DBObject o : list) {  
            System.out.println(o);  
        }  
    }  
 
    // mongo db 插入 insert  
    public void insert(int i) {  
        BasicDBObject doc = new BasicDBObject();  
        doc.put("name", "cjl" + i);  
        doc.put("age", 20 + i);  
        doc.put("sex", "boy");  
        doc.put("time", new Date());  
        coll.insert(doc);  
    }
   
    public void save(int i) {  
        BasicDBObject doc = new BasicDBObject();  
        doc.put("name", "cjl" + i);  
        doc.put("age", 20 + i);  
        doc.put("sex", "boy");  
        doc.put("time", new Date());  
        coll.save(doc);  
    }  
   
 
    public void batchInsert() {  
        List datas = new ArrayList();  
        for (int i = 0; i < 100; i++) {  
            BasicDBObject bo = new BasicDBObject();  
            bo.put("name", "cjl");  
            bo.append("age", i);  
            datas.add(bo);  
        }  
        coll.insert(datas);
       
       
    }
 
    // 查询单个  
    public void findOne() {  
        BasicDBObject obj = (BasicDBObject) coll.findOne();  
        System.out.println(obj);  
    }  
 
    // mongo db 修改  
    public void update() {  
        BasicDBObject query = new BasicDBObject();  
        query.put("name", "liu");  
        DBObject stuFound = coll.findOne(query);  
        stuFound.put("name", stuFound.get("name") + "update_1");  
        coll.update(query, stuFound);  
    }  
 
    // 查询所有  
    public void queryAll() {  
        BasicDBObject obj = new BasicDBObject();  
        obj.put("sex", "boy");  
        DBCursor cursor = coll.find(obj);  
        while (cursor.hasNext()) {  
            String name = (String) cursor.next().get("name");  
            System.out.println(name);  
        }  
        cursor.close();  
    }  
 
    // 条件删除  
    public void delete(String name) {  
        BasicDBObject query = new BasicDBObject();  
        query.put("name", name);  
        // 找到并且删除，并返回删除的对象  
        DBObject removeObj = coll.findAndRemove(query);  
        System.out.println(removeObj);  
    }  
 
    // 条件查询  
    public void findByName(String name) {  
        BasicDBObject obj = new BasicDBObject();  
        obj.put("name", name);  
        DBCursor cursor = coll.find(obj);  
        while (cursor.hasNext()) {  
            System.out.println(cursor.next());  
        }  
    }  
//条件查询2  
    public void argsFind(){  
        BasicDBObject condition = new BasicDBObject();  
        //condition.put("age", new BasicDBObject("$gt", 20).append("$lte", 30));   
        condition.put("age", new BasicDBObject("$gt", 50));  
        coll.find(condition);  
        //比较符  
        //"$gt"： 大于  
        //"$gte"：大于等于  
        //"$lt"： 小于  
        //"$lte"：小于等于  
        //"$in"： 包含  
        //以下条件查询20<age<=30  
    }  
      
    // 分页查询  
    public void pageQuery() {  
        DBCursor cursor = coll.find().skip(0).limit(10);  
        while (cursor.hasNext()) {  
            System.out.println(cursor.next());  
        }  
    }  
}