当前位置 博文首页 > 繁华似锦Fighting:『动善时』JMeter基础 — 44、JMeter对数据库
提示:
关于JMeter如何连接MySQL数据库,前面文章已经详解的讲解过了。因为配置数据库连是比较固定的步骤,这里就不重复讲解了。
本篇文章主要详细说明,使用
JDBC Request
组件,如何对数据库进行更新的各种操作。
JMeter中更新语句的操作步骤:
JDBC Connection Configuration
组件,配置数据库连接。JDBC Request
请求,编写SQL语句,进行参数化。说明:更新操作包含
insert
、update
、delete
三种操作,都是一样性质的,所以我们就以insert
操作为例进行说明。
使用JMeter发送一条insert
语句非常的简单。
在JDBC Request
组件中做如下操作:
Query Type
:因为是执行一条insert
语句,所以选择Update Statement
即可。insert
语句,输入到Query
文本框中。如下图所示:
说明:这是最基础的
insert
操作,发送了一条固定的insert
请求。
JMeter中在insert
请求中实现参数化也非常的简单。
在JDBC Request
组件中做如下操作:
Query Type
:因为是执行一条insert
语句,所以选择Update Statement
即可。insert
语句,输入到Query
文本框中。使用函数助手为例进行演示,如下图所示:
说明:其他形式的参数化也都可以,如利用CSV这个元件去做语句的参数化。本例中是用函数助手方便演示。
提示:如果有些字段是自增长的值或者是有默认值,那么就可以不写,让其自动填充。
使用JMeter发送一次执行多条insert
语句非常的简单,就是直接写入多条insert
语句,之间用;
分隔开。
在JDBC Request
组件中做如下操作:
Database URL
后增加一个参数allowMultiQueries=true
,才可以执行多条SQL语句(重点)。Query Type
:我们可以选择Update Statement
、Prepared Update Statement
和Callable Statement
,这三种类型语句都可以。Update Statement
类型,执行一条insert
语句发送一次请求。Prepared Update Statement
和Callable Statement
类型,则全程只发送一起请求。insert
语句,输入到Query
文本框中。如下图所示:
我们在更新数据库的时候,有时候会有部分数据直接插入是不可以的,需要加密处理。
那么就可以使用BeanShell 取样器组件完成对数据的加密操作。
然后把加密好的数据,存储到JMeter的线程变量中,方便进一步的引用。
提示:加密代码,可以找开发要,也可以自己扒源码找。
JMeter中更新有加密数据的操作步骤:
JDBC Connection Configuration
组件,配置数据库连接。JDBC Request
请求,编写SQL语句,使用参数化,并引用加密的线程变量。添加元件操作步骤:
选中“测试计划”右键 —> 添加 —> 线程(用户) —> 线程组
。JDBC连接配置
组件:选中“线程组”右键 —> 添加 —> 配置元件 —> JDBC Connection Configuration
。BeanShell 取样器
组件:选中“线程组”右键 —> 添加 —> 取样器 —> BeanShell 取样器
。JDBC Request
组件:选中“线程组”右键 —> 添加 —> 取样器 —> JDBC Request
。选中“线程组”右键 —> 添加 —> 监听器 —> 察看结果树
。最终测试计划中的元件如下:
点击运行按钮,会提示你先保存该脚本,脚本保存完成后会直接自动运行该脚本。
基本的JDBC连接配置,界面内容详解可以看前面的文章【JMeter连接数据库】。
主要是定义数据库连接池的名称,还有最下方关于数据库的基本信息配置。
如下图所示:
把生成加密内容的BeanShell代码,写入到界面的脚本输入框中。
如下图所示:
完整代码放在下面:
import java.io.PrintStream;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Arrays;
public class PWDEncryptionUtils {
// 静态方法,类直接调用
// 对明文密码进行加密
public static String encryptPwd(String pwd) {
return stringMD5(pwd);
}
public static String stringMD5(String input) {
try {
MessageDigest messageDigest = MessageDigest.getInstance("MD5");
byte[] inputByteArray = input.getBytes();
messageDigest.update(inputByteArray);
byte[] resultByteArray = messageDigest.digest();
return byteArrayToHex(resultByteArray);
} catch (NoSuchAlgorithmException localNoSuchAlgorithmException) {
localNoSuchAlgorithmException.printStackTrace();
}
return null;
}
public static String byteArrayToHex(byte[] byteArray) {
char[] hexDigits = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F'};
char[] resultCharArray = new char[byteArray.length * 2];
int index = 0;
byte[] arrayofByte = byteArray;
int j = byteArray.length;
for (int i = 0; i < j; i++) {
byte b = arrayofByte[i];
resultCharArray[(index++)] = hexDigits[(b >>> 4 & 0xF)];
resultCharArray[(index++)] = hexDigits[(b & 0xF)];
}
return new String(resultCharArray);
}
// public static void main(String[] args) {
// PWDEncryptionUtils test = new PWDEncryptionUtils();
// String result = test.encryptPwd("12345678");
// System.out.println("result = " + result);
// }
}
//调用执行步骤
// 1.创建实例
PWDEncryptionUtils test = new PWDEncryptionUtils();
// 2.调用加密函数
String pwd=test.encryptPwd("${__RandomString(8,0123456789,)}");
// 3.存储数据到JMeter线程变量中
vars.put("new_pwd",pwd);
说明一下:
new_pwd
。提示:在调试BeanShell代码的时候,可以添加
Debug Sampler
组件来查看获取结果。如下图所示:
填写应用的数据库连接池名称,然后编写insert
语句,最后加入参数化和加密数据的引用。
我把加密后的数据放在了slogan
字段中了,如下图所示:
我把线程组中的线程数设置为3,也就是执行三次该请求。
结果如下图所示,执行了三次SQL请求:
我们在去数据库中查看数据是否添加成功。
如下图所示,新增了三条数据,并且slogan
字段中的数据是经过加密的。
以上就完整的实现了,把经过加密的数据,存储到数据库中的演示。
(1)The server time zone value
服务器时区异常
如果报错,如下:
Cannot create PoolableConnectionFactory (The server time zone value '?????????????????' is unrecognized or represents more than one time zone. You must configure either the server or JDBC driver (via the serverTimezone configuration property) to use a more specifc time zone value if you want to utilize time zone support.)
解决方法:数据库连接URL后面加 serverTimezone=GMT
或serverTimezone=GMT%2B8
,即可解决。
(2)执行多条SQL语句
执行多条SQL语句时,查询语句select
和update
、insert
语句不能在同一个JDBC Request
组件中执行。
当执行多条SQL 语句时,每条语句后面加;
。
并且在 Database URL
后增加一个参数allowMultiQueries=true
,否则将不能够执行多条语句,报错。
(3)更新操作中文乱码
需要在 Database URL
后增加一个参数characterEncoding=utf-8
,这样就可以解决更新操作时候的中文乱码了。
提示:一定要设置为UTF-8编码吗?不一定,要跟你的数据库的编码保持一致,就不会中文乱码了。
(4)Datebase URL
添加参数规则
Datebase URL
后增加参数,在dbname
后加?
,如有多个参数,每个参数用&
隔开,如:
jdbc:mysql://127.0.0.1:3306/guest?serverTimezone=GMT&useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true