jmeter连接数据库--mongoDB

 import com.mongodb.*;

    
 import java.util.Set;
    
 import org.bson.types.ObjectId;
    
  
    
 vars.get("db_name");
    
 vars.get("collections");
    
  
    
 MongoClient mongoClient = new MongoClient("192.168.254.111",31000);  //根据IP、端口连mongo
    
 DB db = mongoClient.getDB("${db_name}");   //选择数据库 Set <String> 
    
 Set<String> collectionNames = db.getCollectionNames();
    
 log.info(db.getName() + "包含如下集合：" + collectionNames.size());
    
 for (String collectionName : collectionNames) {
    
     log.info(collectionName);}
    
 log.info("数据库连接成功");
    
 DBCollection dbCollection = db.getCollection("${collections}");  //选择集合
    
 log.info("集合连接成功");
    
 //根据条件进行查询
    
 BasicDBObject searchObj = new BasicDBObject();
    
 vars.get("status");
    
 searchObj.put("status","${status}"); //value为文本格式
    
 //searchObj.put("status",${status}); //value为数字
    
 //searchObj.put("status",new ObjectId("${status}")); //value为对象id
    
 def result = dbCollection.find(searchObj); 
    
  
    
 log.info("==============================>>>");
    
  
    
 //输出查询结果
    
 def RpData="";
    
  
    
 result.each
    
 {
    
     RpData=RpData+it.toString();
    
     log.info(it.toString());
    
 }
    
  
    
 vars.putObject("RpData", RpData);