Jmeter24：java请求-jmeter_jdbc脚本实战

一，导入

使用Jmeter运行Java脚本，需要用到Jmeter的提供的框架jar包（分别在jmeter目录下的lib和ext目录下）
1.ApacheJMeter_core.jar
2.ApacheJMeter_java.jar
3.slf4j-api-1.7.25.jar
4.jorphan.jar

5.导入sql驱动器.jar

注：导入之后要记得，右键 build pats -> add..引入jar包

二，创建类导入

javaSamplerClient方法 jmeter 中 java请求框架

三，写脚本

getDefaultParameters：获取参数，设置的参数会在Jmeter的参数面板上显示出来
setupTest：初始化方法，只执行一次，跟LR里的init方法一样的，用于建立链接
runTest：执行N次，处理业务
teardownTest：结束方法，只执行一次，LR里的end方法是一样的，用于释放资源
四，导出jmeter jar 包

java_jdbc 脚本由loadrunner脚本转化而来

package com.test.jmeter;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import org.apache.jmeter.config.Arguments;
import org.apache.jmeter.protocol.java.sampler.JavaSamplerClient;
import org.apache.jmeter.protocol.java.sampler.JavaSamplerContext;
import org.apache.jmeter.samplers.SampleResult;

public class jdbc_jmeter_insert implements JavaSamplerClient {
    // 全局变量
        PreparedStatement statement;
        Connection conn;
        
    @Override
    public Arguments getDefaultParameters() {
        Arguments arguments = new Arguments();
        arguments.addArgument("sql", "insert into itcast_role (name,description) values (?,?)");
        arguments.addArgument("url", "jdbc:mysql://localhost:3306/oa?useUnicode=true&characterEncoding=utf8");
        arguments.addArgument("user", "root");
        arguments.addArgument("password", "123456");
        
        arguments.addArgument("name", "lisi");
        arguments.addArgument("desc", "test");
        return arguments;
    }

    // 初始化方法，类似于LR里的init方法，特点是每个用户只执行一次
    @Override
    public void setupTest(JavaSamplerContext context) {
        // 注册驱动，告诉Java接下来要链接哪个数据库
                try {
                    Class.forName("com.mysql.jdbc.Driver");
                    // 建立mysql数据库链接
                    conn = DriverManager.getConnection(context.getParameter("url"),context.getParameter("user"),context.getParameter("password"));
                    // 把sql进行编译
                    statement =  conn.prepareStatement(context.getParameter("sql"));
                } catch (Exception e) {
                    e.printStackTrace();
                }
                
    }

    // runTest方法，类似LR里的actions方法，特点是每个用户执行多次（循环次数或者持续时间s）
    @Override
    public SampleResult runTest(JavaSamplerContext context) {
        SampleResult result = new SampleResult();
        // 定义一个事务名称
        result.setSampleLabel("insert");
        // 事务开始
        result.sampleStart();
        // 执行sql之前，先进行参数化
                try {
                    statement.setString(1, context.getParameter("name"));
                    statement.setString(2, context.getParameter("desc"));
                    int rows = statement.executeUpdate();
                    if (rows == 1){
                        // 事务成功
                        result.setSuccessful(true);
                    }else{
                        // 事务失败
                        result.setSuccessful(false);
                    }
                    System.out.println("=============================:"+rows);
                } catch (SQLException e) {
                    e.printStackTrace();
                }
        // 事务结束
        result.sampleEnd();
        return result;
    }

    // 结束方法，类似于LR里的end方法，特点是每个用户只执行一次
    @Override
    public void teardownTest(JavaSamplerContext context) {
        // 关闭链接
        try {
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        jdbc_jmeter_insert jmeter = new jdbc_jmeter_insert();
        JavaSamplerContext context = new JavaSamplerContext(jmeter.getDefaultParameters());
        jmeter.setupTest(context);
        jmeter.runTest(context);
        jmeter.teardownTest(context);
    }

}

loadrunner-JDBC 脚本 https://www.cnblogs.com/zhenyu1/p/10620524.html