首页 > 数据库> > jmeter连接MongoDB数据库，并且将查询的数据作为下一个接口的请求参数

jmeter连接MongoDB数据库，并且将查询的数据作为下一个接口的请求参数

2021-12-14 17:34:17 作者：互联网

jmeter下载地址
Tip:本文演示的版本为5.1.1

导入驱动包
1.下载MongoDB的驱动包mongo-java-driver-2.11.3.jar（jmeter5.4.1自带这个包），并放入jmeter安装目录lib目录下
2.启动jmeter
3.在测试计划下创建一个线程组

添加用户定义变量
4.右击线程组，添加自定义变量【线程组->配置原件->用户定义变量】

5.这里定义3个变量（数据库名、集合、查询条件），因为数据库地址和端口变化的可能性不大，后面可以直接写死，这里不做变量设置

添加JSR223 Sampler
6.右击线程组，添加JSR223 Sampler【线程组->取样器->JSR223 Sampler】

7.复制并粘贴如下脚本，注意IP地址这里需要更换成自己的

import com.mongodb.*;
import java.util.Set;

vars.get("db_name");
vars.get("collections");

MongoClient mongoClient = new MongoClient("IP地址",27017); //根据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("thread_id");
searchObj.put("thread_id", "${thread_id}");
DBObject result = dbCollection.findOne(searchObj);
log.info("==============================>>>");
log.info(result.toString());
vars.putObject("result", result);