From 54fa0ea90f91c9d2ff3f5603939a7b0fc0353156 Mon Sep 17 00:00:00 2001
From: kruthar <kruthar@gmail.com>
Date: Mon, 2 Nov 2015 10:31:27 -0600
Subject: [PATCH] [jdbc] added ORDER BY clause to scan query
This will ensure record ordering my the primary key.
---
jdbc/src/main/java/com/yahoo/ycsb/db/JdbcDBClient.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/jdbc/src/main/java/com/yahoo/ycsb/db/JdbcDBClient.java b/jdbc/src/main/java/com/yahoo/ycsb/db/JdbcDBClient.java
index 1b9645fc..3cb15702 100644
--- a/jdbc/src/main/java/com/yahoo/ycsb/db/JdbcDBClient.java
+++ b/jdbc/src/main/java/com/yahoo/ycsb/db/JdbcDBClient.java
@@ -305,6 +305,8 @@ public class JdbcDBClient extends DB implements JdbcDBClientConstants {
select.append(" WHERE ");
select.append(PRIMARY_KEY);
select.append(" >= ?");
+ select.append(" ORDER BY ");
+ select.append(PRIMARY_KEY);
select.append(" LIMIT ?;");
PreparedStatement scanStatement = getShardConnectionByKey(key).prepareStatement(select.toString());
if (this.jdbcFetchSize != null) scanStatement.setFetchSize(this.jdbcFetchSize);
--
GitLab