本文详细介绍了PolarDB-X的TPC-H测试设计、测试过程和测试结果。
背景信息
TPC-H是业界常用的一套Benchmark,由TPC委员会制定发布,用于评测数据库的分析型查询能力。TPC-H查询包含8张数据表、22条复杂的SQL查询,大多数查询包含若干表Join、子查询和Group-by聚合等。
本文中TPC-H的实现基于TPC-H的基准测试,并不能与已发布的TPC-H基准测试结果相比较,本文中的测试并不符合TPC-H基准测试的所有要求。
测试设计
测试数据量
测试基于100 GB数据量(Scalar Factor=100),其中主要表数据量如下:
LINEITEM表约6亿行
ORDERS表1.5亿行
PART_SUPP表8000万行
测试所用实例规格
节点规格
节点数
数据集大小
8C64G
6
100 GB
测试所用压力机规格
ecs.g7.4xlarge(16 vCPU,64 GB内存)
测试方法
准备压力机ECS
准备一个ECS,后续操作步骤中涉及的数据准备、运行压测等使用的都是这台ECS机器。
说明测试所用ECS需要部署在VPC网络内。请记录该VPC的名称和ID,后续的所有实例都将部署在该VPC内。
准备压测所用PolarDB-X实例
创建PolarDB-X实例,详细操作步骤请参见创建实例。
说明需保证ECS和PolarDB-X实例在同一个VPC中。
在实例中创建一个待压测的数据库(本测试中数据库名为tpch_100g),详细操作步骤请参见创建数据库。
CREATE DATABASE tpch_100g MODE = 'auto';
在数据库tpch_100g中创建对应的表,方法如下:
CREATE TABLE `customer` ( `c_custkey` int(11) NOT NULL, `c_name` varchar(25) NOT NULL, `c_address` varchar(40) NOT NULL, `c_nationkey` int(11) NOT NULL, `c_phone` varchar(15) NOT NULL, `c_acctbal` decimal(15,2) NOT NULL, `c_mktsegment` varchar(10) NOT NULL, `c_comment` varchar(117) NOT NULL, PRIMARY KEY (`c_custkey`) ) ENGINE=InnoDB DEFAULT CHARSET=latin1 PARTITION BY KEY(`c_custkey`) PARTITIONS 192; CREATE TABLE `lineitem` ( `l_orderkey` bigint(20) NOT NULL, `l_partkey` int(11) NOT NULL, `l_suppkey` int(11) NOT NULL, `l_linenumber` bigint(20) NOT NULL, `l_quantity` decimal(15,2) NOT NULL, `l_extendedprice` decimal(15,2) NOT NULL, `l_discount` decimal(15,2) NOT NULL, `l_tax` decimal(15,2) NOT NULL, `l_returnflag` varchar(1) NOT NULL, `l_linestatus` varchar(1) NOT NULL, `l_shipdate` date NOT NULL, `l_commitdate` date NOT NULL, `l_receiptdate` date NOT NULL, `l_shipinstruct` varchar(25) NOT NULL, `l_shipmode` varchar(10) NOT NULL, `l_comment` varchar(44) NOT NULL, KEY `IDX_LINEITEM_PARTKEY` (`l_partkey`), KEY `IDX_SUPPKEY` (`l_suppkey`), KEY `IDX_LINEITEM_SHIPDATE` (`l_shipdate`), PRIMARY KEY (`l_orderkey`,`l_linenumber`) ) ENGINE=InnoDB DEFAULT CHARSET=latin1 PARTITION BY KEY(`l_orderkey`) PARTITIONS 192; CREATE TABLE `orders` ( `o_orderkey` bigint(20) NOT NULL, `o_custkey` int(11) NOT NULL, `o_orderstatus` varchar(1) NOT NULL, `o_totalprice` decimal(15,2) NOT NULL, `o_orderdate` date NOT NULL, `o_orderpriority` varchar(15) NOT NULL, `o_clerk` varchar(15) NOT NULL, `o_shippriority` bigint(20) NOT NULL, `o_comment` varchar(79) NOT NULL, PRIMARY KEY (`O_ORDERKEY`) ) ENGINE=InnoDB DEFAULT CHARSET=latin1 PARTITION BY KEY(`o_orderkey`) PARTITIONS 192; CREATE TABLE `part` ( `p_partkey` int(11) NOT NULL, `p_name` varchar(55) NOT NULL, `p_mfgr` varchar(25) NOT NULL, `p_brand` varchar(10) NOT NULL, `p_type` varchar(25) NOT NULL, `p_size` int(11) NOT NULL, `p_container` varchar(10) NOT NULL, `p_retailprice` decimal(15,2) NOT NULL, `p_comment` varchar(23) NOT NULL, PRIMARY KEY (`p_partkey`) ) ENGINE=InnoDB DEFAULT CHARSET=latin1 PARTITION BY KEY(`p_partkey`) PARTITIONS 192; CREATE TABLE `partsupp` ( `ps_partkey` int(11) NOT NULL, `ps_suppkey` int(11) NOT NULL, `ps_availqty` int(11) NOT NULL, `ps_supplycost` decimal(15,2) NOT NULL, `ps_comment` varchar(199) NOT NULL, KEY `IDX_PARTSUPP_SUPPKEY` (`PS_SUPPKEY`), PRIMARY KEY (`ps_partkey`,`ps_suppkey`) ) ENGINE=InnoDB DEFAULT CHARSET=latin1 PARTITION BY KEY(`ps_partkey`) PARTITIONS 192; CREATE TABLE `supplier` ( `s_suppkey` int(11) NOT NULL, `s_name` varchar(25) NOT NULL, `s_address` varchar(40) NOT NULL, `s_nationkey` int(11) NOT NULL, `s_phone` varchar(15) NOT NULL, `s_acctbal` decimal(15,2) NOT NULL, `s_comment` varchar(101) NOT NULL, PRIMARY KEY (`s_suppkey`) ) ENGINE=InnoDB DEFAULT CHARSET=latin1 PARTITION BY KEY(`s_suppkey`) PARTITIONS 192; CREATE TABLE `nation` ( `n_nationkey` int(11) NOT NULL, `n_name` varchar(25) NOT NULL, `n_regionkey` int(11) NOT NULL, `n_comment` varchar(152) DEFAULT NULL, PRIMARY KEY (`n_nationkey`) ) ENGINE=InnoDB DEFAULT CHARSET=latin1 broadcast; CREATE TABLE `region` ( `r_regionkey` int(11) NOT NULL, `r_name` varchar(25) NOT NULL, `r_comment` varchar(152) DEFAULT NULL, PRIMARY KEY (`r_regionkey`) ) ENGINE=InnoDB DEFAULT CHARSET=latin1 broadcast;
调整实例参数
说明为了在压测场景下达到最佳性能,需要调整PolarDB-X计算层实例参数。
修改参数XPROTO_MAX_DN_CONCURRENT和XPROTO_MAX_DN_WAIT_CONNECTION的值为4000,详细操作步骤请参见参数设置。
通过命令行连接到PolarDB-X实例,在同一会话内执行如下SQL语句,关闭日志记录与CPU采样统计:
set GLOBAL RECORD_SQL = false; set GLOBAL ENABLE_HTAP=true; set GLOBAL ENABLE_MASTER_MPP=true; set GLOBAL MPP_METRIC_LEVEL = 0; set GLOBAL ENABLE_CPU_PROFILE = false; set GLOBAL ENABLE_SORT_AGG=false; set GLOBAL MPP_PARALLELISM=192; set GLOBAL GROUP_PARALLELISM=8;
数据准备
导入压测数据
下载并上传数据导入工具BatchTool至压力机(下载地址:https://github.com/polardb/polardbx-tools/releases)。更多信息,请参见使用Batch Tool工具导入导出数据。
以alibaba cloud linux 3为例,执行以下命令在压力机ECS上安装Java环境:
yum install -y java-11-openjdk.x86_64
执行以下命令导入TPC-H 100 GB数据集:
java -Xmn8g -Xmx16g -jar batch-tool.jar -h ${HOST} -P${PORT} -u ${USER} -p ${PASSWORD} -D tpch_100g -o import -benchmark tpch -scale 100 -s , -pro 1 -con 80 -minConn 81 -maxConn 81 -batchSize 500
说明参数说明(请您根据实际测试数据库信息进行替换):
{HOST}:主机名
{PORT}:端口号
{USER}:用户名
{PASSWORD}:密码
校验数据完整性
通过命令行连接到PolarDB-X实例,查询每张表的数据量是否符合预期:
select (select count(*) from customer) as customer_cnt, (select count(*) from lineitem) as lineitem_cnt, (select count(*) from nation) as nation_cnt, (select count(*) from orders) as order_cnt, (select count(*) from part) as part_cnt, (select count(*) from partsupp) as partsupp_cnt, (select count(*) from region) as region_cnt, (select count(*) from supplier) as supplier_cnt;
+--------------+--------------+------------+-----------+----------+--------------+------------+--------------+ | customer_cnt | lineitem_cnt | nation_cnt | order_cnt | part_cnt | partsupp_cnt | region_cnt | supplier_cnt | +--------------+--------------+------------+-----------+----------+--------------+------------+--------------+ | 15000000 | 600037902 | 25 | 150000000 | 20000000 | 80000000 | 5 | 1000000 | +--------------+--------------+------------+-----------+----------+--------------+------------+--------------+
采集统计信息
通过命令行连接到PolarDB-X实例,执行analyze table收集表的统计信息:
analyze table customer; analyze table lineitem; analyze table nation; analyze table orders; analyze table part; analyze table partsupp; analyze table region; analyze table supplier;
进行测试
下载测试脚本tpch-queries.tar.gz并解压:
tar xzvf tpch-queries.tar.gz
运行脚本,执行查询并计时:
cd tpch-queries 'time' -f "%e" sh all_query.sh {HOST} {USER} {PASSWORD} {DB} {PORT}
测试结果
引擎版本MySQL 5.7
版本号:polardb-2.4.0_5.4.19-20240718_xcluster5.4.19-20240630,详情请参见:版本发布说明。
表格中SQL列为tpch-queries.tar.gz中对应的SQL文件。
SQL | 执行耗时(秒) |
01.sql | 41.44 |
02.sql | 1.66 |
03.sql | 12.35 |
04.sql | 2.84 |
05.sql | 6.95 |
06.sql | 7.71 |
07.sql | 27.13 |
08.sql | 9.44 |
09.sql | 37.43 |
10.sql | 4.92 |
11.sql | 3.02 |
12.sql | 9.7 |
13.sql | 2.88 |
14.sql | 1.72 |
15.sql | 5.46 |
16.sql | 1.63 |
17.sql | 1.74 |
18.sql | 11.28 |
19.sql | 2.78 |
20.sql | 9.77 |
21.sql | 15.01 |
22.sql | 2.39 |
合计 | 219.25 |
引擎版本MySQL 8.0
版本号:polardb-2.4.0_5.4.19-20240718_xcluster8.4.19-20240630,详情请参见:版本发布说明。
表格中SQL列为tpch-queries.tar.gz中对应的SQL文件。
SQL | 执行耗时(秒) |
01.sql | 33.19 |
02.sql | 1.96 |
03.sql | 11.87 |
04.sql | 2.6 |
05.sql | 5.92 |
06.sql | 8.83 |
07.sql | 27.26 |
08.sql | 10.34 |
09.sql | 33.32 |
10.sql | 4.89 |
11.sql | 3.26 |
12.sql | 8.67 |
13.sql | 2.78 |
14.sql | 1.62 |
15.sql | 5.29 |
16.sql | 1.79 |
17.sql | 1.68 |
18.sql | 11.19 |
19.sql | 3.1 |
20.sql | 11.14 |
21.sql | 14.84 |
22.sql | 2.13 |
合计 | 207.67 |