【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);

     }

 }