Jmeter接口测试（十二）BeanShell断言数据库记录对比

ps：添加gson jar包到jmeter的lib目录下

gson-2.8.2.jar 链接: https://pan.baidu.com/s/1ZUBcVl6jpqciTk4YXdgWPw 提取码: f6d4

1、用户变量添加对应变量

自定义变量

2、http请求添加BeanShell断言：

BeanShell断言

编写执行脚本

BeanShell断言

BeanShell断言内容：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
 
//数据库连接字段
String drive = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://10.40.2.131:3306/数据库名?allowMultiQueries=true";
String user = "testtest";
String pass = "123456";
String history = "";
String response = "";
String failuer = "";
//vars.get是Jmeter提供的方法，可以取到变量值，这个caseno是用来关联用例和数据库中结果的
 
//下面是查询的SQL
//String query = "SELECT goods_status from goods_info_extend_s_53 WHERE good_sn ='260612501' AND platform=1";
String query = "${test_sql}";  //请求sql
//JDBC声明
Connection Mycon = null;
Statement Mystmt = null;
ResultSet Myrset = null;
//try中获取数据库连接
try{
   //prev.getResponseDataAsString是Jmeter提供的方法，可以调取上次请求的响应字符串
    response = prev.getResponseDataAsString();
    System.out.println(response);
    String CaseNo = vars.get("test_id"); //取用户变量的预期结果值
    String CaseNo1 = vars.get("test_code"); //取用户变量的预期结果值
    System.out.println(CaseNo); //打印结果到控制台
    System.out.println(CaseNo1); //打印结果到控制台
    System.out.println(query); //打印结果到控制台
    //Gson提供的方法，效果是把字符串生成Json对象
    JsonParser parser = new JsonParser();
    JsonObject responseObj = (JsonObject) parser.parse(response);
     
     
    Mycon = DriverManager.getConnection(url, user, pass);
    Mystmt = Mycon.createStatement();
    Myrset = Mystmt.executeQuery(query);
    while (Myrset.next()){
            history = Myrset.getString("goods_status"); //取数据库查询的goods_status值
            String history1 = Myrset.getString("site_code"); //取数据库查询的site_code值
        System.out.println(history);  //打印数据库查询结果到控制台
        System.out.println(history1);  //打印数据库查询结果到控制台
        if(history == "")
        {
            Failure = true;
            FailureMessage = "连接数据库失败或者数据库内没有历史数据";
        //调用Gson提供的Json对象euqals方法判断是否一致
        }else if(!history.equals(CaseNo) || !history1.equals(CaseNo1))  //判断查询条件是否为真，如果有多条件，可以继续增加
        {
        //把断言失败置为真
        Failure = true;
        FailureMessage = "和历史数据不匹配";
        }
    }
     
 }catch(SQLException e){
    e.printStackTrace();
}

3、察看结果树结果

返回请求结果是成功的

察看结果树结果

4、查看控制台打印结果

预期结果与查询结果一致

控制台返回结果