jmeter之JSR223使用groovy执行linux命令

先展示示例（基于apache-jmeter-5.6.3版本）

def cmd_list = ["pwd", "ls", "ping 127.0.0.1 -c 1", "who"]

def random = new Random()

def cmd = cmd_list[random.nextInt(cmd_list.size())]

log.info("cmd: ${cmd}")

def process = cmd.execute()

process.waitFor()

def exitCode = process.exitValue()

def output = process.text

//def error = process.err.text

log.info("exit: ${exitCode}, output: ${output}")

println("exit: ${exitCode}, output: ${output}")

SampleResult.setResponseCode(exitCode.toString()) // 设置响应码（如 0 表示成功）

SampleResult.setResponseMessage("${output}") // 设置响应消息

SampleResult.setResponseData(output, "UTF-8") // 设置响应数据

SampleResult.setDataType("text") // 响应数据类型

SampleResult.setDataEncoding("UTF-8")

SampleResult.setSampleLabel("Shell Script Executed") // 自定义标签

坑点： 1，网上有说要import org.apache.jmeter.samplers.SampleResult，千万不要做这个操作，否则SampleResult对象操作回报错误 2，获取execute错误输出会提示IO Stream已经关闭（待解）

sqlplus一个好用替身SQLcl

官方的工具，使用java写就的，下载后解压，设置好JAVA_HOME就能使用，要求java11以上 https://www.oracle.com/database/sqldeveloper/technologies/sqlcl/download/ 或者直接vim sql，在最顶行添加export JAVA_HOME=/opt/jdk-17.0.12也可以连接方法和sqlplus基本一致，比如 . […]

cannot create temp file for here-document: No space left on device

第一眼看到这个错误是不是就觉的是磁盘满了呢，但是df看怎么都没有100%占用的。没错，原始的感觉是对的，但是分叉路不对，习惯了df -h，就忘记了inode这东西，因为它也会满，所以要双管齐下先df -h查看磁盘文件大小占用的空间，有则清理如果df -h查看磁盘未满，就df -i 查看inode占用比例，如果满也是清理不过inode清理需要找到是哪里占用了，不像du -hs一样能从上往下查到 […]

mysql java使用示例

简单的更容易遗忘，除非持久化输出

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.Statement;

public class MysqlDemo {

static {

try {

Class.forName("com.mysql.cj.jdbc.Driver");

} catch (ClassNotFoundException e) {

e.printStackTrace();

}

public static void run_test(String url, String user, String pwd){

try {

System.out.println(String.format("url: %s", url));

Connection conn = DriverManager.getConnection(url, user, pwd);

Statement stmt1 = conn.createStatement();

ResultSet rs;

rs = stmt1.executeQuery("show tables");

while(rs.next()){

System.out.println(rs.getString(1));

}

//持续插入数据

int rows=0;

stmt1.executeUpdate("drop database if exists jdbc_test");

stmt1.executeUpdate("create database jdbc_test");

stmt1.executeUpdate("create table jdbc_test.tb_jdbc(id bigint key, c1 varchar(128))");

for(int i=1;i<1000;i++){

String val = String.format("(%d, 'jdbc_abc_%d')", i, i);

rows = stmt1.executeUpdate("replace into jdbc_test.tb_jdbc(id, c1) values" + val);

if(rows != 0){

System.out.println("insert " + val);

}

Thread.sleep(1000);

}

}catch (Exception e)

{

System.out.println(e.toString());

}

public static void main(String[] args){

run_test(args[0], args[1], args[2]);

}

在idea中创建一个普通的项目，编译后打包输出成mysql_jdbc_demo.jar文件，然后这么执行 java -cp mysql-connector-java8.jar:mysql_jdbc_demo.jar MysqlDemo "jdbc:mysql://192.168.2.199:3306 […]

mysql c-api使用示例

整理旧资料，收拾新东西，有些db状态不是mysql客户端能模拟出来的，所以记录下打样过程，如果以后有需要也不用从头看起

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <mysql/mysql.h>

MYSQL *conn;

void print_err()

{

fprintf(stderr, "%d %s", mysql_errno(conn),mysql_error(conn));

}

void init_db()

{

conn = mysql_init(NULL);

if(conn == NULL)

{

fprintf(stderr, "mysql_init() failed");

exit(EXIT_FAILURE);

}

mysql_real_connect(conn, "192.168.1.10", "test1234", "test1234", "db1", 3306, NULL, 0);

}

void query(char* sql, char* param1)

{

int ret = -1;

MYSQL_STMT *stmt;

MYSQL_BIND bind[1];

long length;

stmt = mysql_stmt_init(conn);

if(conn == NULL)

{

fprintf(stderr, "mysql_stmt_init() failed\n");

exit(EXIT_FAILURE);

}

ret = mysql_stmt_prepare(stmt, sql, strlen(sql));

if(ret != 0)

{

fprintf(stderr, "mysql_stmt_prepare() failed\n");

print_err();

exit(EXIT_FAILURE);

mysql_stmt_execute(stmt);

}else{

fprintf(stdout, "mysql_stmt_prepare() success\n");

}

if(mysql_stmt_reset(stmt))

{

fprintf(stderr, "mysql_stmt_reset() failed\n");

print_err();

}else{

fprintf(stdout, "mysql_stmt_reset() success\n");

}

ret = mysql_stmt_prepare(stmt, sql, strlen(sql));

if(ret != 0)

{

fprintf(stderr, "mysql_stmt_prepare() failed\n");

print_err();

exit(EXIT_FAILURE);

mysql_stmt_execute(stmt);

}else{

fprintf(stdout, "mysql_stmt_prepare() success\n");

}

memset(bind, 0, sizeof(bind));

/*普通bind*/

bind[0].buffer_type = MYSQL_TYPE_STRING;

bind[0].buffer = (char *)param1;

bind[0].buffer_length = strlen(param1);

ret = mysql_stmt_bind_param(stmt, bind);

if(ret != 0)

{

fprintf(stderr, "mysql_stmt_bind_param() failed\n");

exit(EXIT_FAILURE);

mysql_stmt_execute(stmt);

}else{

fprintf(stdout, "mysql_stmt_bind_param() success\n");

}

/*发送long data*/

// bind[0].buffer_type= MYSQL_TYPE_STRING;

// bind[0].length= &length;

// bind[0].is_null= 0;

// ret = mysql_stmt_bind_named_param(stmt, bind, 1, NULL);

// if(ret != 0)

// {

// fprintf(stderr, "mysql_stmt_bind_named_param() failed\n");

// print_err();

// }else{

// fprintf(stdout, "mysql_stmt_bind_named_param() success\n");

// }

if(mysql_stmt_send_long_data(stmt,0,"MySQL",5))

{

fprintf(stderr, "mysql_stmt_send_long_data() failed\n");

print_err();

}else{

fprintf(stdout, "mysql_stmt_send_long_data() success\n");

}

if(mysql_stmt_send_long_data(stmt,0," - The most popular Open Source database",40))

{

fprintf(stderr, "mysql_stmt_send_long_data() failed\n");

print_err();

}else{

fprintf(stdout, "mysql_stmt_send_long_data() success\n");

}

/***/

ret = mysql_stmt_execute(stmt);

if(ret != 0)

{

fprintf(stderr, "mysql_stmt_execute() failed\n");

print_err();

}else{

fprintf(stdout, "mysql_stmt_execute() success\n");

}

mysql_stmt_close(stmt);

}

void close_db()

{

mysql_close(conn);

}

int main()

{

init_db();

query("select md5(?) from dual", "123");

close_db();

}

gcc -o foo mysql_c_demo.c -I/home/mysql8/mysql8.0.22_run/include -L/home/mysql8/mysql8.0.22_run/lib -lmysqlclient

mysql odbc-bench

很久没有更新了，每天七七八八的琐碎事情占据了所有时间，是不是该暂停一下了 1，安装好unixODBC，安装完之后通过odbcinst -j查看配置文件路径，如下实例

# odbcinst -j

unixODBC 2.3.7

DRIVERS............: /usr/local/etc/odbcinst.ini

SYSTEM DATA SOURCES: /usr/local/etc/odbc.ini

FILE DATA SOURCES..: /usr/local/etc/ODBCDataSources

USER DATA SOURCES..: /root/.odbc.ini

SQLULEN Size.......: 8

SQLLEN Size........: 8

SQLSETPOSIROW Size.: 8

# cat /usr/local/etc/odbcinst.ini

[MYSQL]

Description = ODBC for MySQL

Driver = /usr/lib/libmyodbc5w.so

Setup = /usr/lib/libodbcmyS.so

Driver64 = /usr/lib64/libmyodbc5w.so

Setup64 = /usr/lib64/libodbcmyS.so

FileUsage = 1

# cat /usr/local/etc/odbc.ini

[tpcc2]

Description = MySQL test database

Driver = MYSQL

SERVER = 10.21.12.235

USER = test1234

PASSWORD = test1234

PORT = 15051

DATABASE = tpcc2

TraceFile = /tmp/odbc.trace

Trace = ON

2，构建和使用odbc-bench git路径是这个https://github.com/openlink/odbc-bench [crayon-6866 […]

shell统计日志中的时间戳差值

比如这样的日志，需要统计后一条记录和前一条记录之间的时间差值 [2024-10-11 10:42:24 023047] DEBUG 478832,readermgn.cpp:17:run,tid:0x7f80697fa700,479378,reader mgn running [2024-10-11 10:42:30 329273] DEBUG 478832,readermgn.cpp:17:ru […]

python下的数据库连接池dbutils

最近在测试业务的时候，出现长时间并发线程跑sql的时候建立链接耗时的问题，于是搜罗了一下python下是否有链接池的功能，于是乎找到dbutils这个模块，官方路径是在这里 https://webwareforpython.github.io/DBUtils/ 基础使用相对不麻烦，使用pymysql作为连接器进行演示验证

#coding: utf-8

import pymysql

from dbutils.pooled_db import PooledDB

import threading

from concurrent.futures import ThreadPoolExecutor

pool = PooledDB(

creator=pymysql,

maxconnections=16, # 可同时创建的最大连接数，如果并发很快这里可能会出现超过最大链接数的报错

mincached=4,

maxcached=12,

maxshared=128,

blocking=False,

maxusage=None,

setsession=["set autocommit=0"], #用于设置session的前导语句

ping=1,

reset=True,

# mysql登陆参数

host="192.30.2.19",

port=3306,

user="test1234",

passwd="test1234",

database="mysql",

charset="utf8mb4",

cursorclass=pymysql.cursors.DictCursor, # 这里设置返回cursor类型, DictCursor会返回字典类型，带有字段名

)

def run_test(num):

tid = threading.currentThread().ident

conn = pool.connection()

cursor = conn.cursor()

cursor.execute("begin")

cursor.execute(f"insert into db1.t1(id,tid) values({num}, '{tid}')")

cursor.execute(f"select {num} as num, '{tid}' as tid from dual")

print(cursor.fetchall())

cursor.execute("commit")

conn.close()

for i in range(30):

# 每次最多创建16个线程

threadpool = ThreadPoolExecutor(16)

for j in range(16):

threadpool.submit(run_test, *(i*16 + j,))

threadpool.shutdown(wait=True)

&nbsp […]

mowblog

一群散乱的记忆

jmeter之JSR223使用groovy执行linux命令

sqlplus一个好用替身SQLcl

cannot create temp file for here-document: No space left on device

mysql java使用示例

mysql c-api使用示例

mysql odbc-bench

shell统计日志中的时间戳差值

python下的数据库连接池dbutils

2025 年 7 月
一	二	三	四	五	六	日
	1	2	3	4	5	6
7	8	9	10	11	12	13
14	15	16	17	18	19	20
21	22	23	24	25	26	27
28	29	30	31