Fix issue 3

Alias the subquery in postgresql
osalvador · Jan 13, 2020 · 74f5359 · 74f5359
1 parent 83bd7ba
commit 74f5359
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/pom.xml b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>org.replicadb</groupId>
     <artifactId>ReplicaDB</artifactId>
-    <version>0.6.0</version>
+    <version>0.6.1</version>
 
     <name>ReplicaDB</name>
     <url>https://github.com/osalvador/ReplicaDB</url>
@@ -108,7 +108,7 @@
         <!--<dependency>-->
         <!--<groupId>com.denodo</groupId>-->
         <!--<artifactId>denodo</artifactId>-->
-        <!--<version>6.0</version>-->
+        <!--<version>7.0</version>-->
         <!--</dependency>-->
 
 

diff --git a/src/main/java/org/replicadb/manager/PostgresqlManager.java b/src/main/java/org/replicadb/manager/PostgresqlManager.java
@@ -169,7 +169,7 @@ public ResultSet readTable(String tableName, String[] columns, int nThread) thro
         // Read table with source-query option specified
         if (options.getSourceQuery() != null && !options.getSourceQuery().isEmpty()) {
             sqlCmd = "SELECT  * FROM (" +
-                    options.getSourceQuery() + ") OFFSET ? ";
+                    options.getSourceQuery() + ") as T1 OFFSET ? ";
         } else {
 
             sqlCmd = "SELECT " +
@@ -284,7 +284,7 @@ public void preSourceTasks() throws SQLException {
 
             // Source Query
             if (options.getSourceQuery() != null && !options.getSourceQuery().isEmpty()) {
-                sql = sql + "( " + this.options.getSourceQuery() + " )";
+                sql = sql + "( " + this.options.getSourceQuery() + " ) as T1";
 
             } else {