4. 压测工具选型与配置：sysbench、JMeter、wrk2 的聚合查询场景配置方法

聚合查询压测对工具的要求与普通 OLTP 压测有显著差异：需要支持自定义 SQL、能够精确控制并发模型、必须能采集尾延迟（p99/p999）而非仅平均延迟。本章对三款主流压测工具在聚合查询场景下的选型依据、配置要点和参数陷阱进行系统对比。

4.1 工具选型对比矩阵

4.2 sysbench 聚合查询配置

4.2.1 自定义 Lua 脚本结构

sysbench 通过 Lua 脚本定义压测逻辑，聚合查询场景需要重写 event() 函数。以下是一个针对 TPC-H 类聚合查询的脚本模板：

-- agg_query.lua
local stmt_defs = {
    stmt1 = [[
        SELECT /*+ PARALLEL(4) */
            c_custkey,
            COUNT(o_orderkey) as order_cnt,
            SUM(o_totalprice) as total_revenue
        FROM customer
        JOIN orders ON c_custkey = o_custkey
        WHERE o_orderdate BETWEEN '1994-01-01' AND '1994-12-31'
        GROUP BY c_custkey
        HAVING SUM(o_totalprice) > 100000
        ORDER BY total_revenue DESC
        LIMIT 100
    ]],
}

function thread_init()
    drv = sysbench.sql.driver()
    con = drv:connect()
    -- 预编译所有语句
    stmts = {}
    for name, sql in pairs(stmt_defs) do
        stmts[name] = con:prepare(sql)
    end
end

function event()
    local stmt = stmts["stmt1"]
    local rs = stmt:execute()
    rs:fetch_all()  -- 强制消费结果集
    rs:close()
end

function thread_done()
    for _, stmt in pairs(stmts) do
        stmt:close()
    end
    con:disconnect()
end

4.2.2 关键参数配置

4.2.3 启动命令示例

sysbench \
  --db-driver=mysql \
  --mysql-host=192.168.1.100 \
  --mysql-port=3306 \
  --mysql-user=perf \
  --mysql-password=perf123 \
  --mysql-db=tpch_10g \
  --threads=64 \
  --time=300 \
  --report-interval=10 \
  --percentile=99 \
  --histogram=on \
  --rand-type=uniform \
  /path/to/agg_query.lua \
  run

4.3 JMeter 聚合查询配置

4.3.1 测试计划结构

JMeter 配置聚合查询压测的核心步骤：

1. 添加 JDBC Connection Configuration：配置数据库连接 URL、驱动类、连接池参数
2. 添加 JDBC Request：写入聚合 SQL，选择 Callable Statement 或 Select Statement
3. 添加 Listener：使用 jp@gc - Response Times Over Time 和 jp@gc - Percentiles 插件采集尾延迟
4. 配置线程组：设置目标并发数、Ramp-Up 时间、循环次数

4.3.2 关键配置参数

4.4 wrk2 聚合查询配置

4.4.1 适用场景限制

wrk2 是 HTTP 层压测工具，无法直接连接数据库。聚合查询场景下仅适用于以下架构：

• 数据库通过 REST API 或 GraphQL 暴露聚合查询接口
• 应用层封装了聚合查询逻辑，wrk2 压测 HTTP 端点
• 需要测量从 HTTP 请求到聚合结果返回的端到端延迟

4.4.2 Lua 脚本配置

-- wrk2_agg.lua
wrk.method = "POST"
wrk.body = [[
    {
        "query": "SELECT c_custkey, COUNT(o_orderkey) as cnt
                  FROM customer JOIN orders ON ...
                  GROUP BY c_custkey LIMIT 100",
        "params": {}
    }
]]
wrk.headers["Content-Type"] = "application/json"

-- 自定义延迟分布采集
response = function(status, headers, body)
    if status ~= 200 then
        -- 记录错误，但不影响延迟统计
        wrk.status = status
    end
end

4.4.3 启动命令

wrk2 -t 16 -c 64 -d 300s -R 1000 \
  -s wrk2_agg.lua \
  --latency \
  --u_latency \
  http://api.example.com/aggregate

4.5 三工具聚合查询压测流程对比

4.6 配置参数速查表