shardingsphere-benchmark/src/main/java/org/apache/shardingsphere/benchmark/jmeter/rangerouting/masterslave/JMeterProxyRangeRoutingMasterSlaveInsertUpdateDelete.java [30:66]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        results.sampleStart();
        Connection connection = null;

        try {
            connection = dataSource.getConnection();

            String insertSql = (String) sqlConfig.get("ss.benchmark.rangerouting.masterslave.insert.sql");
            List insertParams = convertParams((List) sqlConfig.get("ss.benchmark.rangerouting.masterslave.insert.values"));
    
    
            String insertSqlBatch = (String) sqlConfig.get("ss.benchmark.rangerouting.shardingmasterslaveencrypt.insert.sql");
            int insertCount = getInsertCount(insertSqlBatch);
/*           
            List insertBatchParams = convertParams((List) sqlConfig.get("ss.benchmark.rangerouting.shardingmasterslaveencrypt.insert.values"));
            rs = JDBCDataSourceUtil.insert(connection, insertSqlBatch, insertParams);
            List batchIds = batchInsert(rs, insertCount);*/
            List batchIds = batchInsert(insertCount, connection, insertSql, insertParams);


            String updateSql = (String) sqlConfig.get("ss.benchmark.rangerouting.masterslave.update.sql");
            List updateParams = convertParams((List) sqlConfig.get("ss.benchmark.rangerouting.masterslave.update.values"));
            updateParams = appendIds(batchIds, updateParams);
            JDBCDataSourceUtil.update(connection, updateSql, updateParams);

            String deleteSql = (String) sqlConfig.get("ss.benchmark.rangerouting.masterslave.delete.sql");
            List deleteParams = convertParams((List) sqlConfig.get("ss.benchmark.rangerouting.masterslave.delete.values"));
            deleteParams = appendIds(batchIds, deleteParams);
            JDBCDataSourceUtil.delete(connection, deleteSql, deleteParams);

            results.setSuccessful(true);
        } catch (SQLException e) {
            results.setSuccessful(false);
            e.printStackTrace();
        } catch (Exception e) {
            results.setSuccessful(false);
            e.printStackTrace();
        } finally {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



shardingsphere-benchmark/src/main/java/org/apache/shardingsphere/benchmark/jmeter/rangerouting/masterslave/JMeterShardingJDBCRangeRoutingMasterSlaveInsertUpdateDelete.java [37:73]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        results.sampleStart();
        Connection connection = null;

        try {
            connection = dataSource.getConnection();

            String insertSql = (String) sqlConfig.get("ss.benchmark.rangerouting.masterslave.insert.sql");
            List insertParams = convertParams((List) sqlConfig.get("ss.benchmark.rangerouting.masterslave.insert.values"));
    
    
            String insertSqlBatch = (String) sqlConfig.get("ss.benchmark.rangerouting.shardingmasterslaveencrypt.insert.sql");
            int insertCount = getInsertCount(insertSqlBatch);
/*           
            List insertBatchParams = convertParams((List) sqlConfig.get("ss.benchmark.rangerouting.shardingmasterslaveencrypt.insert.values"));
            rs = JDBCDataSourceUtil.insert(connection, insertSqlBatch, insertParams);
            List batchIds = batchInsert(rs, insertCount);*/
            List batchIds = batchInsert(insertCount, connection, insertSql, insertParams);


            String updateSql = (String) sqlConfig.get("ss.benchmark.rangerouting.masterslave.update.sql");
            List updateParams = convertParams((List) sqlConfig.get("ss.benchmark.rangerouting.masterslave.update.values"));
            updateParams = appendIds(batchIds, updateParams);
            JDBCDataSourceUtil.update(connection, updateSql, updateParams);

            String deleteSql = (String) sqlConfig.get("ss.benchmark.rangerouting.masterslave.delete.sql");
            List deleteParams = convertParams((List) sqlConfig.get("ss.benchmark.rangerouting.masterslave.delete.values"));
            deleteParams = appendIds(batchIds, deleteParams);
            JDBCDataSourceUtil.delete(connection, deleteSql, deleteParams);

            results.setSuccessful(true);
        } catch (SQLException e) {
            results.setSuccessful(false);
            e.printStackTrace();
        } catch (Exception e) {
            results.setSuccessful(false);
            e.printStackTrace();
        } finally {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -