PolarDB-X 1.0-性能白皮书-PolarDB-X Sysbench测试说明

Sysbench 说明

Sysbench是一款开源的、模块化的、跨平台的多线程性能测试工具，可以执行数据库、CPU、内存、线程、IO等方面的性能测试。目前支持的数据库有MySQL、Oracle和PostgreSQL。以下验证PolarDB-X在Sysbench OLTP和SELECT场景中的性能表现。

测试设计

• 购买PolarDB-X、ECS、RDS。

• PolarDB-X（4种规格）：入门版8C32G、标准版16C64G、企业版32C128G、企业版64C256G。
• ECS压力机（1台）：32C64G、操作系统 Aliyun Linux 2.1903 64位、计算网络增强型。
• RDS（12台）：16C64G、MySQL 5.7、独享型。
• 备注：DRDS、ECS、RDS都处于同一可用区，同一VPC。

• 在PolarDB-X控制台创建水平拆分库，选择已经购买的12台RDS。
• 在ECS安装Sysbench，并准备1.6亿数据。关于如何使用Sysbench，请参见Sysbench使用指南。

测试参数说明

1. --test='/usr/local/share/sysbench/oltp_drds.lua'  OLTP场景使用oltp_drds.lua, SELECT场景使用select.lua
2. --mysql_table_options='dbpartition by hash(`id`) tbpartition by hash(id) tbpartitions 2'PolarDB-X分库分表语法，表示每个分库2张分表。
3. --oltp-table-size=160000000  准备1.6亿数据。
4. --oltp_auto_inc=off 关闭自增主键。
5. --oltp_skip_trx=on 跳过事务。
6. --oltp_secondary 将ID设置为非主键防止主键冲突。
7. --oltp_range_size=5连续取值5个，必定走到5个分片。
8. --rand-init=on 每个测试表都是用随机数据来填充的sysbench。
9. --num-threads=200具体每个场景的并发数详情请参见结果表格。

测试语句范例：

1. sysbench --test='/usr/local/share/sysbench/oltp_drds.lua'--oltp_tables_count=1--report-interval=5--oltp-table-size=160000000  --mysql-user=****--mysql-password=****--mysql-table-engine=innodb  --rand-init=on  --mysql-host=****--mysql-port=3306--mysql-db=****--max-requests=0   --oltp_skip_trx=on --oltp_auto_inc=off  --oltp_secondary --oltp_range_size=5--mysql_table_options='dbpartition by hash(`id`) tbpartition by hash(id) tbpartitions 2'  --num-threads=200--max-time=300 run

OLTP 测试结果

SELECT 测试结果

OLTP 场景测试脚本详情

1. pathtest = string.match(test,"(.*/)")
2. 
   
3. if pathtest then
4.   dofile(pathtest .."common.lua")
5. else
6.   require("common")
7. end
8. 
   
9. function get_range_end(start)
10.    return start + oltp_range_size -1
11. end
12. 
    
13. function thread_init(thread_id)
14.   set_vars()
15. 
    
16.   if(((db_driver =="mysql") or (db_driver =="attachsql")) and mysql_table_engine =="myisam")then
17.      local i
18.      local tables ={}
19.      for i=1, oltp_tables_count do
20.         tables[i]= string.format("sbtest%i WRITE", i)
21.      end
22.      begin_query ="LOCK TABLES ".. table.concat(tables," ,")
23.      commit_query ="UNLOCK TABLES"
24.   else
25.      begin_query ="BEGIN"
26.      commit_query ="COMMIT"
27.   end
28. 
    
29. end
30. 
    
31. function event(thread_id)
32.   local rs
33.   local i
34.   local table_name
35.   local range_start
36.   local c_val
37.   local pad_val
38.   local query
39. 
    
40.   table_name ="sbtest".. sb_rand_uniform(1, oltp_tables_count)
41.   if not oltp_skip_trx then
42.      db_query(begin_query)
43.   end
44. 
    
45.   if not oltp_write_only then
46. 
    
47.   for i=1, oltp_point_selects do
48.      rs = db_query("SELECT c FROM ".. table_name .." WHERE id=".. sb_rand(1, oltp_table_size))
49.   end
50. 
    
51.   if oltp_range_selects then
52. 
    
53.   for i=1, oltp_simple_ranges do
54.      range_start = sb_rand(1, oltp_table_size)
55.      rs = db_query("SELECT c FROM ".. table_name .." WHERE id BETWEEN ".. range_start .." AND ".. get_range_end(range_start))
56.   end
57. 
    
58.   for i=1, oltp_sum_ranges do
59.      range_start = sb_rand(1, oltp_table_size)
60.      rs = db_query("SELECT SUM(K) FROM ".. table_name .." WHERE id BETWEEN ".. range_start .." AND ".. get_range_end(range_start))
61.   end
62. 
    
63.   for i=1, oltp_order_ranges do
64.      range_start = sb_rand(1, oltp_table_size)
65.      rs = db_query("SELECT c FROM ".. table_name .." WHERE id BETWEEN ".. range_start .." AND ".. get_range_end(range_start).." ORDER BY c")
66.   end
67. 
    
68.   for i=1, oltp_distinct_ranges do
69.      range_start = sb_rand(1, oltp_table_size)
70.      rs = db_query("SELECT DISTINCT c FROM ".. table_name .." WHERE id BETWEEN ".. range_start .." AND ".. get_range_end(range_start).." ORDER BY c")
71.   end
72. 
    
73.   end
74. 
    
75.   end
76. 
    
77.   if not oltp_read_only then
78. 
    
79.   for i=1, oltp_index_updates do
80.      rs = db_query("UPDATE ".. table_name .." SET k=k+1 WHERE id=".. sb_rand(1, oltp_table_size))
81.   end
82. 
    
83.   for i=1, oltp_non_index_updates do
84.      c_val = sb_rand_str("###########-###########-###########-###########-###########-###########-###########-###########-###########-###########")
85.      query ="UPDATE ".. table_name .." SET c='".. c_val .."' WHERE id=".. sb_rand(1, oltp_table_size)
86.      rs = db_query(query)
87.      if rs then
88.        print(query)
89.      end
90.   end
91. 
    
92.   for i=1, oltp_delete_inserts do
93. 
    
94.   i = sb_rand(1, oltp_table_size)
95. 
    
96.   rs = db_query("DELETE FROM ".. table_name .." WHERE id=".. i)
97. 
    
98.   c_val = sb_rand_str([[
99. ###########-###########-###########-###########-###########-###########-###########-###########-###########-###########]])
100.   pad_val = sb_rand_str([[
101. ###########-###########-###########-###########-###########]])
102. 
     
103.   rs = db_query("INSERT INTO ".. table_name ..  " (id, k, c, pad) VALUES ".. string.format("(%d, %d, '%s', '%s')",i, sb_rand(1, oltp_table_size), c_val, pad_val))
104. 
     
105.   end
106. 
     
107.   end -- oltp_read_only
108. 
     
109.   if not oltp_skip_trx then
110.      db_query(commit_query)
111.   end
112. 
     
113. end