feat: Added random query distribution

demos/redis-sidecar-spring-demo/src/main/java/com/redis/sidecar/springdemo/MySQLDataLoader.java

@@ -215,7 +215,7 @@ public MySQLDataLoader(Config config, DataSource dataSource) {
 	}
 
 	@PostConstruct
-	public void execute() throws SQLException {
+	public void start() throws SQLException {
 		CUSTOMERS.execute(new CustomerRowProvider(config.getCustomers()), dataSource, config.getBatch());
 		PRODUCTS.execute(new ProductRowProvider(config.getProducts()), dataSource, config.getBatch());
 		ORDERS.execute(new OrderRowProvider(config.getOrders(), config.getCustomers()), dataSource, config.getBatch());

demos/redis-sidecar-spring-demo/src/main/java/com/redis/sidecar/springdemo/MySQLQueryExecutor.java

@@ -6,6 +6,7 @@
 import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Random;
 
 import javax.annotation.PostConstruct;
 import javax.sql.DataSource;
@@ -49,7 +50,7 @@ public MySQLQueryExecutor(RedisURI redisURI, DataSourceProperties dataSourceProp
 	}
 
 	@PostConstruct
-	public void executeQueries() {
+	public void start() {
 		if (config.isFlush()) {
 			RedisClient.create(redisURI).connect().sync().flushall();
 		}
@@ -80,6 +81,7 @@ public void executeQueries() {
 
 	private static class QueryTask implements Runnable {
 
+		private final Random random = new Random();
 		private final DataSource dataSource;
 		private final ProgressBar progressBar;
 		private final int totalRows;
@@ -93,17 +95,15 @@ public QueryTask(DataSource dataSource, int totalRows, ProgressBar progressBar)
 
 		@Override
 		public void run() {
-			int index = 0;
 			while (!stopped) {
-				index++;
 				try (Connection connection = dataSource.getConnection();
 						PreparedStatement statement = connection.prepareStatement(QUERY)) {
-					statement.setInt(1, index % totalRows);
+					int orderNumber = random.nextInt(totalRows) + 1;
+					statement.setInt(1, orderNumber);
 					try (ResultSet resultSet = statement.executeQuery()) {
 						while (resultSet.next()) {
-							for (int columnIndex = 1; columnIndex <= resultSet.getMetaData()
-									.getColumnCount(); columnIndex++) {
-								resultSet.getObject(columnIndex);
+							for (int index = 0; index < resultSet.getMetaData().getColumnCount(); index++) {
+								resultSet.getObject(index + 1);
 							}
 						}
 					}