in shardingsphere-benchmark/src/main/java/org/apache/shardingsphere/benchmark/common/statistic/BenchmarkRangeroutingStatistic.java [169:212]
public void calculateRangeRoutingSharding(Map benchmarkResultPath, Map sqlConfig, String benchmarkVersion, int skipBegin, int skipEnd, int concurrency, long updateTime, int dbShardingCount, int tableShardingCount) {
String proxyRangeRoutingShardingInsertupdatedeleteResultPath = (String) benchmarkResultPath.get("ss.benchmark.proxy.rangerouting.sharding.insertupdatedelete.result");
Map proxyRangeRoutingShardingInsertupdatedeleteResult = BenchmarkResultParser.benchmarkStatistic(proxyRangeRoutingShardingInsertupdatedeleteResultPath, skipBegin, skipEnd);
if (proxyRangeRoutingShardingInsertupdatedeleteResult.size() > 0) {
String ssInsertUpdateDeleteSQL = (String)sqlConfig.get("ss.benchmark.rangerouting.sharding.delete.sql") + ";\r\n" + (String)sqlConfig.get("ss.benchmark.rangerouting.sharding.insert.sql") + ";\r\n" + (String)sqlConfig.get("ss.benchmark.rangerouting.sharding.update.sql") + ";\r\n";
BenchmarkResultBean proxyRangeRoutingShardingInsertupdatedeleteResultBean = new BenchmarkResultBean(benchmarkVersion,proxyRangeRoutingShardingInsertupdatedeleteResult, ssInsertUpdateDeleteSQL, "Sharding", "ShardingProxy", "RangeRouting", "Insert+Update+delete", concurrency, updateTime, dbShardingCount, tableShardingCount);
result.add(proxyRangeRoutingShardingInsertupdatedeleteResultBean);
}
String shardingjdbcRangeRoutingShardingInsertupdatedeleteResultPath = (String) benchmarkResultPath.get("ss.benchmark.shardingjdbc.rangerouting.sharding.insertupdatedelete.result");
Map shardingjdbcRangeRoutingShardingInsertupdatedeleteResult = BenchmarkResultParser.benchmarkStatistic(shardingjdbcRangeRoutingShardingInsertupdatedeleteResultPath, skipBegin, skipEnd);
if (shardingjdbcRangeRoutingShardingInsertupdatedeleteResult.size() > 0) {
String ssInsertUpdateDeleteSQL = (String)sqlConfig.get("ss.benchmark.rangerouting.sharding.delete.sql") + ";\r\n" + (String)sqlConfig.get("ss.benchmark.rangerouting.sharding.insert.sql") + ";\r\n" + (String)sqlConfig.get("ss.benchmark.rangerouting.sharding.update.sql") + ";\r\n";
BenchmarkResultBean shardingjdbcRangeRoutingShardingInsertupdatedeleteResultBean = new BenchmarkResultBean(benchmarkVersion, shardingjdbcRangeRoutingShardingInsertupdatedeleteResult, ssInsertUpdateDeleteSQL, "Sharding", "ShardingJDBC", "RangeRouting", "Insert+Update+delete", concurrency, updateTime, dbShardingCount, tableShardingCount);
result.add(shardingjdbcRangeRoutingShardingInsertupdatedeleteResultBean);
}
String jdbcRangeRoutingShardingInsertupdatedeleteResultPath = (String) benchmarkResultPath.get("ss.benchmark.jdbc.rangerouting.sharding.insertupdatedelete.result");
Map jdbcRangeRoutingShardingInsertupdatedeleteResult = BenchmarkResultParser.benchmarkStatistic(jdbcRangeRoutingShardingInsertupdatedeleteResultPath, skipBegin, skipEnd);
if (jdbcRangeRoutingShardingInsertupdatedeleteResult.size() > 0) {
String jdbcInsertUpdateDeleteSQL = (String)sqlConfig.get("jdbc.benchmark.rangerouting.sharding.delete.sql") + ";\r\n" + (String)sqlConfig.get("jdbc.benchmark.rangerouting.sharding.insert.sql") + ";\r\n" + (String)sqlConfig.get("jdbc.benchmark.rangerouting.sharding.update.sql") + ";\r\n";
BenchmarkResultBean jdbcRangeRoutingShardingInsertupdatedeleteResultBean = new BenchmarkResultBean(benchmarkVersion, jdbcRangeRoutingShardingInsertupdatedeleteResult, jdbcInsertUpdateDeleteSQL, "Sharding", "MYSQL", "RangeRouting", "Insert+Update+delete", concurrency, updateTime, 0, 0);
result.add(jdbcRangeRoutingShardingInsertupdatedeleteResultBean);
}
String proxyRangeRoutingShardingSelectResultPath = (String) benchmarkResultPath.get("ss.benchmark.proxy.rangerouting.sharding.select.result");
Map proxyRangeRoutingShardingSelectResult = BenchmarkResultParser.benchmarkStatistic(proxyRangeRoutingShardingSelectResultPath, skipBegin, skipEnd);
if (proxyRangeRoutingShardingSelectResult.size() > 0) {
String ssSelectSql = (String)sqlConfig.get("ss.benchmark.rangerouting.sharding.select.sql");
BenchmarkResultBean proxyRangeRoutingShardingSelectResultBean = new BenchmarkResultBean(benchmarkVersion, proxyRangeRoutingShardingSelectResult, ssSelectSql, "Sharding", "ShardingProxy", "RangeRouting", "Select", concurrency, updateTime, dbShardingCount, tableShardingCount);
result.add(proxyRangeRoutingShardingSelectResultBean);
}
String shardingjdbcRangeRoutingShardingSelectResultPath = (String) benchmarkResultPath.get("ss.benchmark.shardingjdbc.rangerouting.sharding.select.result");
Map shardingjdbcRangeRoutingShardingSelectResult = BenchmarkResultParser.benchmarkStatistic(shardingjdbcRangeRoutingShardingSelectResultPath, skipBegin, skipEnd);
if (shardingjdbcRangeRoutingShardingSelectResult.size() > 0) {
String ssSelectSql = (String)sqlConfig.get("ss.benchmark.rangerouting.sharding.select.sql");
BenchmarkResultBean shardingjdbcRangeRoutingShardingSelectResultBean = new BenchmarkResultBean(benchmarkVersion, shardingjdbcRangeRoutingShardingSelectResult, ssSelectSql, "Sharding", "ShardingJDBC", "RangeRouting", "Select", concurrency, updateTime, dbShardingCount, tableShardingCount);
result.add(shardingjdbcRangeRoutingShardingSelectResultBean);
}
String jdbcRangeRoutingShardingSelectResultPath = (String) benchmarkResultPath.get("ss.benchmark.jdbc.rangerouting.sharding.select.result");
Map jdbcRangeRoutingShardingSelectResult = BenchmarkResultParser.benchmarkStatistic(jdbcRangeRoutingShardingSelectResultPath, skipBegin, skipEnd);
if (jdbcRangeRoutingShardingSelectResult.size() > 0) {
String jdbcSelectSql = (String)sqlConfig.get("jdbc.benchmark.rangerouting.sharding.select.sql");
BenchmarkResultBean jdbcRangeRoutingShardingSelectResultBean = new BenchmarkResultBean(benchmarkVersion, jdbcRangeRoutingShardingSelectResult, jdbcSelectSql, "Sharding", "MYSQL", "RangeRouting", "Select", concurrency, updateTime, 0, 0);
result.add(jdbcRangeRoutingShardingSelectResultBean);
}
}