You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ma...@apache.org on 2014/02/12 05:59:56 UTC
[1/4] Fix PHOENIX-33 Support table-wildcard select in join queries
Updated Branches:
refs/heads/master 7a6a46c0a -> 872acf6a5
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/test/java/org/apache/phoenix/end2end/HashJoinTest.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/end2end/HashJoinTest.java b/phoenix-core/src/test/java/org/apache/phoenix/end2end/HashJoinTest.java
index ce20ada..5ed8d43 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/end2end/HashJoinTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/end2end/HashJoinTest.java
@@ -19,13 +19,14 @@
*/
package org.apache.phoenix.end2end;
-import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE_NORMALIZED;
-import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE_NORMALIZED;
-import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE_NORMALIZED;
+import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE_DISPLAY_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE_DISPLAY_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_SCHEMA;
+import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE_DISPLAY_NAME;
import static org.apache.phoenix.util.TestUtil.PHOENIX_JDBC_URL;
import static org.apache.phoenix.util.TestUtil.TEST_PROPERTIES;
import static org.junit.Assert.assertEquals;
@@ -40,6 +41,7 @@ import java.sql.Date;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
+import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
@@ -54,6 +56,7 @@ import org.junit.runners.Parameterized;
import org.junit.runners.Parameterized.Parameters;
import com.google.common.collect.Lists;
+
import org.apache.phoenix.exception.SQLExceptionCode;
import org.apache.phoenix.schema.TableAlreadyExistsException;
import org.apache.phoenix.util.QueryUtil;
@@ -96,26 +99,26 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* LEFT JOIN joinItemTable i ON o.item_id = i.item_id
* GROUP BY i.name ORDER BY i.name
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME + "\n" +
" SERVER AGGREGATE INTO DISTINCT ROWS BY [I.NAME]\n" +
"CLIENT MERGE SORT\n" +
"CLIENT SORTED BY [I.NAME]\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED,
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME,
/*
* testLeftJoinWithAggregation()
* SELECT i.item_id iid, sum(quantity) q FROM joinOrderTable o
* LEFT JOIN joinItemTable i ON o.item_id = i.item_id
* GROUP BY i.item_id ORDER BY q DESC"
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME + "\n" +
" SERVER AGGREGATE INTO DISTINCT ROWS BY [I.item_id]\n" +
"CLIENT MERGE SORT\n" +
"CLIENT SORTED BY [SUM(O.QUANTITY) DESC]\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY FIRST KEY ONLY",
/*
* testLeftJoinWithAggregation()
@@ -123,51 +126,51 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* LEFT JOIN joinOrderTable o ON o.item_id = i.item_id
* GROUP BY i.item_id ORDER BY q DESC NULLS LAST, iid
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY FIRST KEY ONLY\n" +
" SERVER AGGREGATE INTO ORDERED DISTINCT ROWS BY [I.item_id]\n" +
"CLIENT MERGE SORT\n" +
"CLIENT SORTED BY [SUM(O.QUANTITY) DESC NULLS LAST, I.item_id]\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED,
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME,
/*
* testRightJoinWithAggregation()
* SELECT i.name, sum(quantity) FROM joinOrderTable o
* RIGHT JOIN joinItemTable i ON o.item_id = i.item_id
* GROUP BY i.name ORDER BY i.name
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" SERVER AGGREGATE INTO DISTINCT ROWS BY [I.NAME]\n" +
"CLIENT MERGE SORT\n" +
"CLIENT SORTED BY [I.NAME]\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED,
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME,
/*
* testRightJoinWithAggregation()
* SELECT i.item_id iid, sum(quantity) q FROM joinOrderTable o
* RIGHT JOIN joinItemTable i ON o.item_id = i.item_id
* GROUP BY i.item_id ORDER BY q DESC NULLS LAST, iid
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY FIRST KEY ONLY\n" +
" SERVER AGGREGATE INTO ORDERED DISTINCT ROWS BY [I.item_id]\n" +
"CLIENT MERGE SORT\n" +
"CLIENT SORTED BY [SUM(O.QUANTITY) DESC NULLS LAST, I.item_id]\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED,
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME,
/*
* testJoinWithWildcard()
* SELECT * FROM joinItemTable LEFT JOIN joinSupplierTable supp
* ON joinItemTable.supplier_id = supp.supplier_id
* ORDER BY item_id
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_NORMALIZED,
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_DISPLAY_NAME,
/*
* testJoinPlanWithIndex()
* SELECT item.item_id, item.name, supp.supplier_id, supp.name
@@ -176,11 +179,11 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* AND (supp.name BETWEEN 'S1' AND 'S5')
* WHERE item.name BETWEEN 'T1' AND 'T5'
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY (NAME >= 'T1' AND NAME <= 'T5')\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_NORMALIZED + "\n" +
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY (NAME >= 'S1' AND NAME <= 'S5')",
/*
* testJoinPlanWithIndex()
@@ -190,11 +193,11 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* WHERE (item.name = 'T1' OR item.name = 'T5')
* AND (supp.name = 'S1' OR supp.name = 'S5')
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY (NAME = 'T1' OR NAME = 'T5')\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_NORMALIZED + "\n" +
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY (NAME = 'S1' OR NAME = 'S5')",
/*
* testJoinWithSkipMergeOptimization()
@@ -202,23 +205,23 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* JOIN joinOrderTable o ON o.item_id = i.item_id AND quantity < 5000
* JOIN joinSupplierTable s ON i.supplier_id = s.supplier_id
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" PARALLEL EQUI-JOIN 2 HASH TABLES:\n" +
" BUILD HASH TABLE 0 (SKIP MERGE)\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED + "\n" +
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY QUANTITY < 5000\n" +
" BUILD HASH TABLE 1\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_NORMALIZED,
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_DISPLAY_NAME,
/*
* testSelfJoin
* SELECT i2.item_id, i1.name FROM joinItemTable i1
* JOIN joinItemTable i2 ON i1.item_id = i2.item_id
* ORDER BY i1.item_id
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY FIRST KEY ONLY",
/*
* testSelfJoin
@@ -226,18 +229,18 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* JOIN joinItemTable i2 ON i1.item_id = i2.supplier_id
* ORDER BY i1.name, i2.name
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" SERVER SORTED BY [I1.NAME, I2.NAME]\n" +
"CLIENT MERGE SORT\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED,
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME,
}});
testCases.add(new String[][] {
{
- "CREATE INDEX IDX_CUSTOMER ON " + JOIN_CUSTOMER_TABLE + " (name)",
- "CREATE INDEX IDX_ITEM ON " + JOIN_ITEM_TABLE + " (name) INCLUDE (price, discount1, discount2, \"supplier_id\", description)",
- "CREATE INDEX IDX_SUPPLIER ON " + JOIN_SUPPLIER_TABLE + " (name)"
+ "CREATE INDEX IDX_CUSTOMER ON " + JOIN_CUSTOMER_TABLE_FULL_NAME + " (name)",
+ "CREATE INDEX IDX_ITEM ON " + JOIN_ITEM_TABLE_FULL_NAME + " (name) INCLUDE (price, discount1, discount2, \"supplier_id\", description)",
+ "CREATE INDEX IDX_SUPPLIER ON " + JOIN_SUPPLIER_TABLE_FULL_NAME + " (name)"
}, {
/*
* testLeftJoinWithAggregation()
@@ -245,13 +248,13 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* LEFT JOIN joinItemTable i ON o.item_id = i.item_id
* GROUP BY i.name ORDER BY i.name
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED + "\n" +
- " SERVER AGGREGATE INTO DISTINCT ROWS BY [I.NAME]\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME + "\n" +
+ " SERVER AGGREGATE INTO DISTINCT ROWS BY [I._0:NAME]\n" +
"CLIENT MERGE SORT\n" +
- "CLIENT SORTED BY [I.NAME]\n" +
+ "CLIENT SORTED BY [I._0:NAME]\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER IDX_ITEM\n" +
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SCHEMA + ".IDX_ITEM\n" +
" SERVER FILTER BY FIRST KEY ONLY",
/*
* testLeftJoinWithAggregation()
@@ -259,13 +262,13 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* LEFT JOIN joinItemTable i ON o.item_id = i.item_id
* GROUP BY i.item_id ORDER BY q DESC"
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED + "\n" +
- " SERVER AGGREGATE INTO DISTINCT ROWS BY [I.item_id]\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME + "\n" +
+ " SERVER AGGREGATE INTO DISTINCT ROWS BY [I.:item_id]\n" +
"CLIENT MERGE SORT\n" +
"CLIENT SORTED BY [SUM(O.QUANTITY) DESC]\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER IDX_ITEM\n" +
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SCHEMA + ".IDX_ITEM\n" +
" SERVER FILTER BY FIRST KEY ONLY",
/*
* testLeftJoinWithAggregation()
@@ -273,51 +276,51 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* LEFT JOIN joinOrderTable o ON o.item_id = i.item_id
* GROUP BY i.item_id ORDER BY q DESC NULLS LAST, iid
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY FIRST KEY ONLY\n" +
" SERVER AGGREGATE INTO ORDERED DISTINCT ROWS BY [I.item_id]\n" +
"CLIENT MERGE SORT\n" +
"CLIENT SORTED BY [SUM(O.QUANTITY) DESC NULLS LAST, I.item_id]\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED,
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME,
/*
* testRightJoinWithAggregation()
* SELECT i.name, sum(quantity) FROM joinOrderTable o
* RIGHT JOIN joinItemTable i ON o.item_id = i.item_id
* GROUP BY i.name ORDER BY i.name
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER IDX_ITEM\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SCHEMA + ".IDX_ITEM\n" +
" SERVER FILTER BY FIRST KEY ONLY\n" +
- " SERVER AGGREGATE INTO ORDERED DISTINCT ROWS BY [I.NAME]\n" +
+ " SERVER AGGREGATE INTO ORDERED DISTINCT ROWS BY [I._0:NAME]\n" +
"CLIENT MERGE SORT\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED,
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME,
/*
* testRightJoinWithAggregation()
* SELECT i.item_id iid, sum(quantity) q FROM joinOrderTable o
* RIGHT JOIN joinItemTable i ON o.item_id = i.item_id
* GROUP BY i.item_id ORDER BY q DESC NULLS LAST, iid
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY FIRST KEY ONLY\n" +
" SERVER AGGREGATE INTO ORDERED DISTINCT ROWS BY [I.item_id]\n" +
"CLIENT MERGE SORT\n" +
"CLIENT SORTED BY [SUM(O.QUANTITY) DESC NULLS LAST, I.item_id]\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED,
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME,
/*
* testJoinWithWildcard()
* SELECT * FROM joinItemTable LEFT JOIN joinSupplierTable supp
* ON joinItemTable.supplier_id = supp.supplier_id
* ORDER BY item_id
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_NORMALIZED,
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_DISPLAY_NAME,
/*
* testJoinPlanWithIndex()
* SELECT item.item_id, item.name, supp.supplier_id, supp.name
@@ -326,11 +329,11 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* AND (supp.name BETWEEN 'S1' AND 'S5')
* WHERE item.name BETWEEN 'T1' AND 'T5'
*/
- "CLIENT PARALLEL 1-WAY RANGE SCAN OVER IDX_ITEM ['T1'] - ['T5']\n" +
+ "CLIENT PARALLEL 1-WAY RANGE SCAN OVER " + JOIN_SCHEMA + ".IDX_ITEM ['T1'] - ['T5']\n" +
" SERVER FILTER BY FIRST KEY ONLY\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY RANGE SCAN OVER IDX_SUPPLIER ['S1'] - ['S5']",
+ " CLIENT PARALLEL 1-WAY RANGE SCAN OVER " + JOIN_SCHEMA + ".IDX_SUPPLIER ['S1'] - ['S5']",
/*
* testJoinPlanWithIndex()
* SELECT item.item_id, item.name, supp.supplier_id, supp.name
@@ -339,33 +342,33 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* WHERE (item.name = 'T1' OR item.name = 'T5')
* AND (supp.name = 'S1' OR supp.name = 'S5')
*/
- "CLIENT PARALLEL 1-WAY SKIP SCAN ON 2 KEYS OVER IDX_ITEM ['T1'] - ['T5']\n" +
+ "CLIENT PARALLEL 1-WAY SKIP SCAN ON 2 KEYS OVER " + JOIN_SCHEMA + ".IDX_ITEM ['T1'] - ['T5']\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY SKIP SCAN ON 2 KEYS OVER IDX_SUPPLIER ['S1'] - ['S5']",
+ " CLIENT PARALLEL 1-WAY SKIP SCAN ON 2 KEYS OVER " + JOIN_SCHEMA + ".IDX_SUPPLIER ['S1'] - ['S5']",
/*
* testJoinWithSkipMergeOptimization()
* SELECT s.name FROM joinItemTable i
* JOIN joinOrderTable o ON o.item_id = i.item_id AND quantity < 5000
* JOIN joinSupplierTable s ON i.supplier_id = s.supplier_id
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER IDX_ITEM\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SCHEMA + ".IDX_ITEM\n" +
" PARALLEL EQUI-JOIN 2 HASH TABLES:\n" +
" BUILD HASH TABLE 0 (SKIP MERGE)\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED + "\n" +
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY QUANTITY < 5000\n" +
" BUILD HASH TABLE 1\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER IDX_SUPPLIER",
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SCHEMA + ".IDX_SUPPLIER",
/*
* testSelfJoin
* SELECT i2.item_id, i1.name FROM joinItemTable i1
* JOIN joinItemTable i2 ON i1.item_id = i2.item_id
* ORDER BY i1.item_id
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER IDX_ITEM\n" +
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SCHEMA + ".IDX_ITEM\n" +
" SERVER FILTER BY FIRST KEY ONLY",
/*
* testSelfJoin
@@ -373,23 +376,23 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* JOIN joinItemTable i2 ON i1.item_id = i2.supplier_id
* ORDER BY i1.name, i2.name
*/
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER IDX_ITEM\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SCHEMA + ".IDX_ITEM\n" +
" SERVER FILTER BY FIRST KEY ONLY\n" +
- " SERVER SORTED BY [I1.NAME, I2.NAME]\n" +
+ " SERVER SORTED BY [I1._0:NAME, I2._0:NAME]\n" +
"CLIENT MERGE SORT\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER IDX_ITEM",
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SCHEMA + ".IDX_ITEM",
}});
return testCases;
}
protected void initTableValues() throws Exception {
- ensureTableCreated(getUrl(), JOIN_CUSTOMER_TABLE);
- ensureTableCreated(getUrl(), JOIN_ITEM_TABLE);
- ensureTableCreated(getUrl(), JOIN_SUPPLIER_TABLE);
- ensureTableCreated(getUrl(), JOIN_ORDER_TABLE);
+ ensureTableCreated(getUrl(), JOIN_CUSTOMER_TABLE_FULL_NAME);
+ ensureTableCreated(getUrl(), JOIN_ITEM_TABLE_FULL_NAME);
+ ensureTableCreated(getUrl(), JOIN_SUPPLIER_TABLE_FULL_NAME);
+ ensureTableCreated(getUrl(), JOIN_ORDER_TABLE_FULL_NAME);
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(getUrl(), props);
@@ -398,7 +401,7 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
// Insert into customer table
PreparedStatement stmt = conn.prepareStatement(
- "upsert into " + JOIN_CUSTOMER_TABLE +
+ "upsert into " + JOIN_CUSTOMER_TABLE_FULL_NAME +
" (\"customer_id\", " +
" NAME, " +
" PHONE, " +
@@ -456,7 +459,7 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
// Insert into item table
stmt = conn.prepareStatement(
- "upsert into " + JOIN_ITEM_TABLE +
+ "upsert into " + JOIN_ITEM_TABLE_FULL_NAME +
" (\"item_id\", " +
" NAME, " +
" PRICE, " +
@@ -530,7 +533,7 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
// Insert into supplier table
stmt = conn.prepareStatement(
- "upsert into " + JOIN_SUPPLIER_TABLE +
+ "upsert into " + JOIN_SUPPLIER_TABLE_FULL_NAME +
" (\"supplier_id\", " +
" NAME, " +
" PHONE, " +
@@ -581,7 +584,7 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
// Insert into order table
stmt = conn.prepareStatement(
- "upsert into " + JOIN_ORDER_TABLE +
+ "upsert into " + JOIN_ORDER_TABLE_FULL_NAME +
" (\"order_id\", " +
" \"customer_id\", " +
" \"item_id\", " +
@@ -637,7 +640,7 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testDefaultJoin() throws Exception {
- String query = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE + " item JOIN " + JOIN_SUPPLIER_TABLE + " supp ON item.\"supplier_id\" = supp.\"supplier_id\"";
+ String query = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\"";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -682,7 +685,7 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testInnerJoin() throws Exception {
- String query = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name, next value for my.seq FROM " + JOIN_ITEM_TABLE + " item INNER JOIN " + JOIN_SUPPLIER_TABLE + " supp ON item.\"supplier_id\" = supp.\"supplier_id\"";
+ String query = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name, next value for my.seq FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item INNER JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\"";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -734,9 +737,9 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testLeftJoin() throws Exception {
String query[] = new String[3];
- query[0] = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name, next value for my.seq FROM " + JOIN_ITEM_TABLE + " item LEFT JOIN " + JOIN_SUPPLIER_TABLE + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" ORDER BY \"item_id\"";
- query[1] = "SELECT " + JOIN_ITEM_TABLE + ".\"item_id\", " + JOIN_ITEM_TABLE + ".name, " + JOIN_SUPPLIER_TABLE + ".\"supplier_id\", " + JOIN_SUPPLIER_TABLE + ".name, next value for my.seq FROM " + JOIN_ITEM_TABLE + " LEFT JOIN " + JOIN_SUPPLIER_TABLE + " ON " + JOIN_ITEM_TABLE + ".\"supplier_id\" = " + JOIN_SUPPLIER_TABLE + ".\"supplier_id\" ORDER BY \"item_id\"";
- query[2] = "SELECT item.\"item_id\", " + JOIN_ITEM_TABLE + ".name, supp.\"supplier_id\", " + JOIN_SUPPLIER_TABLE + ".name, next value for my.seq FROM " + JOIN_ITEM_TABLE + " item LEFT JOIN " + JOIN_SUPPLIER_TABLE + " supp ON " + JOIN_ITEM_TABLE + ".\"supplier_id\" = supp.\"supplier_id\" ORDER BY \"item_id\"";
+ query[0] = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name, next value for my.seq FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item LEFT JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" ORDER BY \"item_id\"";
+ query[1] = "SELECT " + JOIN_ITEM_TABLE_FULL_NAME + ".\"item_id\", " + JOIN_ITEM_TABLE_FULL_NAME + ".name, " + JOIN_SUPPLIER_TABLE_FULL_NAME + ".\"supplier_id\", " + JOIN_SUPPLIER_TABLE_FULL_NAME + ".name, next value for my.seq FROM " + JOIN_ITEM_TABLE_FULL_NAME + " LEFT JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " ON " + JOIN_ITEM_TABLE_FULL_NAME + ".\"supplier_id\" = " + JOIN_SUPPLIER_TABLE_FULL_NAME + ".\"supplier_id\" ORDER BY \"item_id\"";
+ query[2] = "SELECT item.\"item_id\", " + JOIN_ITEM_TABLE_FULL_NAME + ".name, supp.\"supplier_id\", " + JOIN_SUPPLIER_TABLE_FULL_NAME + ".name, next value for my.seq FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item LEFT JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON " + JOIN_ITEM_TABLE_FULL_NAME + ".\"supplier_id\" = supp.\"supplier_id\" ORDER BY \"item_id\"";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -790,7 +793,7 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testRightJoin() throws Exception {
- String query = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_SUPPLIER_TABLE + " supp RIGHT JOIN " + JOIN_ITEM_TABLE + " item ON item.\"supplier_id\" = supp.\"supplier_id\" ORDER BY \"item_id\"";
+ String query = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp RIGHT JOIN " + JOIN_ITEM_TABLE_FULL_NAME + " item ON item.\"supplier_id\" = supp.\"supplier_id\" ORDER BY \"item_id\"";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -840,8 +843,8 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testInnerJoinWithPreFilters() throws Exception {
- String query1 = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE + " item INNER JOIN " + JOIN_SUPPLIER_TABLE + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" AND supp.\"supplier_id\" BETWEEN '0000000001' AND '0000000005'";
- String query2 = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE + " item INNER JOIN " + JOIN_SUPPLIER_TABLE + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" AND (supp.\"supplier_id\" = '0000000001' OR supp.\"supplier_id\" = '0000000005')";
+ String query1 = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item INNER JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" AND supp.\"supplier_id\" BETWEEN '0000000001' AND '0000000005'";
+ String query2 = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item INNER JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" AND (supp.\"supplier_id\" = '0000000001' OR supp.\"supplier_id\" = '0000000005')";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -902,7 +905,7 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testLeftJoinWithPreFilters() throws Exception {
- String query = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE + " item LEFT JOIN " + JOIN_SUPPLIER_TABLE + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" AND (supp.\"supplier_id\" = '0000000001' OR supp.\"supplier_id\" = '0000000005') ORDER BY \"item_id\"";
+ String query = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item LEFT JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" AND (supp.\"supplier_id\" = '0000000001' OR supp.\"supplier_id\" = '0000000005') ORDER BY \"item_id\"";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -952,8 +955,8 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testJoinWithPostFilters() throws Exception {
- String query1 = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_SUPPLIER_TABLE + " supp RIGHT JOIN " + JOIN_ITEM_TABLE + " item ON item.\"supplier_id\" = supp.\"supplier_id\" WHERE supp.\"supplier_id\" BETWEEN '0000000001' AND '0000000005'";
- String query2 = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE + " item LEFT JOIN " + JOIN_SUPPLIER_TABLE + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" WHERE supp.\"supplier_id\" = '0000000001' OR supp.\"supplier_id\" = '0000000005'";
+ String query1 = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp RIGHT JOIN " + JOIN_ITEM_TABLE_FULL_NAME + " item ON item.\"supplier_id\" = supp.\"supplier_id\" WHERE supp.\"supplier_id\" BETWEEN '0000000001' AND '0000000005'";
+ String query2 = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item LEFT JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" WHERE supp.\"supplier_id\" = '0000000001' OR supp.\"supplier_id\" = '0000000005'";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1014,9 +1017,9 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testStarJoin() throws Exception {
- String query = "SELECT \"order_id\", c.name, i.name iname, quantity, o.date FROM " + JOIN_ORDER_TABLE + " o LEFT JOIN "
- + JOIN_CUSTOMER_TABLE + " c ON o.\"customer_id\" = c.\"customer_id\" LEFT JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\"";
+ String query = "SELECT \"order_id\", c.name, i.name iname, quantity, o.date FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o LEFT JOIN "
+ + JOIN_CUSTOMER_TABLE_FULL_NAME + " c ON o.\"customer_id\" = c.\"customer_id\" LEFT JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\"";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1065,12 +1068,12 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testLeftJoinWithAggregation() throws Exception {
- String query1 = "SELECT i.name, sum(quantity) FROM " + JOIN_ORDER_TABLE + " o LEFT JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" GROUP BY i.name ORDER BY i.name";
- String query2 = "SELECT i.\"item_id\" iid, sum(quantity) q FROM " + JOIN_ORDER_TABLE + " o LEFT JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" GROUP BY i.\"item_id\" ORDER BY q DESC";
- String query3 = "SELECT i.\"item_id\" iid, sum(quantity) q FROM " + JOIN_ITEM_TABLE + " i LEFT JOIN "
- + JOIN_ORDER_TABLE + " o ON o.\"item_id\" = i.\"item_id\" GROUP BY i.\"item_id\" ORDER BY q DESC NULLS LAST, iid";
+ String query1 = "SELECT i.name, sum(quantity) FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o LEFT JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" GROUP BY i.name ORDER BY i.name";
+ String query2 = "SELECT i.\"item_id\" iid, sum(quantity) q FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o LEFT JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" GROUP BY i.\"item_id\" ORDER BY q DESC";
+ String query3 = "SELECT i.\"item_id\" iid, sum(quantity) q FROM " + JOIN_ITEM_TABLE_FULL_NAME + " i LEFT JOIN "
+ + JOIN_ORDER_TABLE_FULL_NAME + " o ON o.\"item_id\" = i.\"item_id\" GROUP BY i.\"item_id\" ORDER BY q DESC NULLS LAST, iid";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1149,10 +1152,10 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testRightJoinWithAggregation() throws Exception {
- String query1 = "SELECT i.name, sum(quantity) FROM " + JOIN_ORDER_TABLE + " o RIGHT JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" GROUP BY i.name ORDER BY i.name";
- String query2 = "SELECT i.\"item_id\" iid, sum(quantity) q FROM " + JOIN_ORDER_TABLE + " o RIGHT JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" GROUP BY i.\"item_id\" ORDER BY q DESC NULLS LAST, iid";
+ String query1 = "SELECT i.name, sum(quantity) FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o RIGHT JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" GROUP BY i.name ORDER BY i.name";
+ String query2 = "SELECT i.\"item_id\" iid, sum(quantity) q FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o RIGHT JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" GROUP BY i.\"item_id\" ORDER BY q DESC NULLS LAST, iid";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1220,9 +1223,9 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testLeftRightJoin() throws Exception {
- String query = "SELECT \"order_id\", i.name, s.name, quantity, date FROM " + JOIN_ORDER_TABLE + " o LEFT JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" RIGHT JOIN "
- + JOIN_SUPPLIER_TABLE + " s ON i.\"supplier_id\" = s.\"supplier_id\" ORDER BY \"order_id\", s.\"supplier_id\" DESC";
+ String query = "SELECT \"order_id\", i.name, s.name, quantity, date FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o LEFT JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" RIGHT JOIN "
+ + JOIN_SUPPLIER_TABLE_FULL_NAME + " s ON i.\"supplier_id\" = s.\"supplier_id\" ORDER BY \"order_id\", s.\"supplier_id\" DESC";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1285,9 +1288,9 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testMultiLeftJoin() throws Exception {
- String query = "SELECT \"order_id\", i.name, s.name, quantity, date FROM " + JOIN_ORDER_TABLE + " o LEFT JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" LEFT JOIN "
- + JOIN_SUPPLIER_TABLE + " s ON i.\"supplier_id\" = s.\"supplier_id\"";
+ String query = "SELECT \"order_id\", i.name, s.name, quantity, date FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o LEFT JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" LEFT JOIN "
+ + JOIN_SUPPLIER_TABLE_FULL_NAME + " s ON i.\"supplier_id\" = s.\"supplier_id\"";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1332,9 +1335,9 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testMultiRightJoin() throws Exception {
- String query = "SELECT \"order_id\", i.name, s.name, quantity, date FROM " + JOIN_ORDER_TABLE + " o RIGHT JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" RIGHT JOIN "
- + JOIN_SUPPLIER_TABLE + " s ON i.\"supplier_id\" = s.\"supplier_id\" ORDER BY \"order_id\", s.\"supplier_id\" DESC";
+ String query = "SELECT \"order_id\", i.name, s.name, quantity, date FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o RIGHT JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" RIGHT JOIN "
+ + JOIN_SUPPLIER_TABLE_FULL_NAME + " s ON i.\"supplier_id\" = s.\"supplier_id\" ORDER BY \"order_id\", s.\"supplier_id\" DESC";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1403,98 +1406,98 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testJoinWithWildcard() throws Exception {
- String query = "SELECT * FROM " + JOIN_ITEM_TABLE + " LEFT JOIN " + JOIN_SUPPLIER_TABLE + " supp ON " + JOIN_ITEM_TABLE + ".\"supplier_id\" = supp.\"supplier_id\" ORDER BY \"item_id\"";
+ String query = "SELECT * FROM " + JOIN_ITEM_TABLE_FULL_NAME + " LEFT JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON " + JOIN_ITEM_TABLE_FULL_NAME + ".\"supplier_id\" = supp.\"supplier_id\" ORDER BY \"item_id\"";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
PreparedStatement statement = conn.prepareStatement(query);
ResultSet rs = statement.executeQuery();
assertTrue (rs.next());
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".item_id"), "0000000001");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".NAME"), "T1");
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".PRICE"), 100);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT1"), 5);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT2"), 10);
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".supplier_id"), "0000000001");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".DESCRIPTION"), "Item T1");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".item_id"), "0000000001");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".NAME"), "T1");
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".PRICE"), 100);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT1"), 5);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT2"), 10);
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".supplier_id"), "0000000001");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DESCRIPTION"), "Item T1");
assertEquals(rs.getString("SUPP.supplier_id"), "0000000001");
assertEquals(rs.getString("supp.name"), "S1");
assertEquals(rs.getString("supp.phone"), "888-888-1111");
assertEquals(rs.getString("supp.address"), "101 YYY Street");
assertEquals(rs.getString("supp.loc_id"), "10001");
assertTrue (rs.next());
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".item_id"), "0000000002");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".NAME"), "T2");
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".PRICE"), 200);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT1"), 5);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT2"), 8);
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".supplier_id"), "0000000001");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".DESCRIPTION"), "Item T2");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".item_id"), "0000000002");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".NAME"), "T2");
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".PRICE"), 200);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT1"), 5);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT2"), 8);
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".supplier_id"), "0000000001");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DESCRIPTION"), "Item T2");
assertEquals(rs.getString("SUPP.supplier_id"), "0000000001");
assertEquals(rs.getString("supp.name"), "S1");
assertEquals(rs.getString("supp.phone"), "888-888-1111");
assertEquals(rs.getString("supp.address"), "101 YYY Street");
assertEquals(rs.getString("supp.loc_id"), "10001");
assertTrue (rs.next());
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".item_id"), "0000000003");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".NAME"), "T3");
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".PRICE"), 300);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT1"), 8);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT2"), 12);
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".supplier_id"), "0000000002");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".DESCRIPTION"), "Item T3");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".item_id"), "0000000003");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".NAME"), "T3");
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".PRICE"), 300);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT1"), 8);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT2"), 12);
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".supplier_id"), "0000000002");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DESCRIPTION"), "Item T3");
assertEquals(rs.getString("SUPP.supplier_id"), "0000000002");
assertEquals(rs.getString("supp.name"), "S2");
assertEquals(rs.getString("supp.phone"), "888-888-2222");
assertEquals(rs.getString("supp.address"), "202 YYY Street");
assertEquals(rs.getString("supp.loc_id"), "10002");
assertTrue (rs.next());
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".item_id"), "0000000004");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".NAME"), "T4");
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".PRICE"), 400);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT1"), 6);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT2"), 10);
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".supplier_id"), "0000000002");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".DESCRIPTION"), "Item T4");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".item_id"), "0000000004");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".NAME"), "T4");
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".PRICE"), 400);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT1"), 6);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT2"), 10);
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".supplier_id"), "0000000002");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DESCRIPTION"), "Item T4");
assertEquals(rs.getString("SUPP.supplier_id"), "0000000002");
assertEquals(rs.getString("supp.name"), "S2");
assertEquals(rs.getString("supp.phone"), "888-888-2222");
assertEquals(rs.getString("supp.address"), "202 YYY Street");
assertEquals(rs.getString("supp.loc_id"), "10002");
assertTrue (rs.next());
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".item_id"), "0000000005");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".NAME"), "T5");
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".PRICE"), 500);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT1"), 8);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT2"), 15);
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".supplier_id"), "0000000005");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".DESCRIPTION"), "Item T5");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".item_id"), "0000000005");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".NAME"), "T5");
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".PRICE"), 500);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT1"), 8);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT2"), 15);
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".supplier_id"), "0000000005");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DESCRIPTION"), "Item T5");
assertEquals(rs.getString("SUPP.supplier_id"), "0000000005");
assertEquals(rs.getString("supp.name"), "S5");
assertEquals(rs.getString("supp.phone"), "888-888-5555");
assertEquals(rs.getString("supp.address"), "505 YYY Street");
assertEquals(rs.getString("supp.loc_id"), "10005");
assertTrue (rs.next());
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".item_id"), "0000000006");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".NAME"), "T6");
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".PRICE"), 600);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT1"), 8);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT2"), 15);
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".supplier_id"), "0000000006");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".DESCRIPTION"), "Item T6");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".item_id"), "0000000006");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".NAME"), "T6");
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".PRICE"), 600);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT1"), 8);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT2"), 15);
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".supplier_id"), "0000000006");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DESCRIPTION"), "Item T6");
assertEquals(rs.getString("SUPP.supplier_id"), "0000000006");
assertEquals(rs.getString("supp.name"), "S6");
assertEquals(rs.getString("supp.phone"), "888-888-6666");
assertEquals(rs.getString("supp.address"), "606 YYY Street");
assertEquals(rs.getString("supp.loc_id"), "10006");
assertTrue (rs.next());
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".item_id"), "invalid001");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".NAME"), "INVALID-1");
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".PRICE"), 0);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT1"), 0);
- assertEquals(rs.getInt(JOIN_ITEM_TABLE_NORMALIZED + ".DISCOUNT2"), 0);
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".supplier_id"), "0000000000");
- assertEquals(rs.getString(JOIN_ITEM_TABLE_NORMALIZED + ".DESCRIPTION"), "Invalid item for join test");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".item_id"), "invalid001");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".NAME"), "INVALID-1");
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".PRICE"), 0);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT1"), 0);
+ assertEquals(rs.getInt(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DISCOUNT2"), 0);
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".supplier_id"), "0000000000");
+ assertEquals(rs.getString(JOIN_ITEM_TABLE_DISPLAY_NAME + ".DESCRIPTION"), "Invalid item for join test");
assertNull(rs.getString("SUPP.supplier_id"));
assertNull(rs.getString("supp.name"));
assertNull(rs.getString("supp.phone"));
@@ -1511,8 +1514,154 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
}
@Test
+ public void testJoinWithTableWildcard() throws Exception {
+ String query = "SELECT s.*, "+ JOIN_ITEM_TABLE_FULL_NAME + ".*, \"order_id\" FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o RIGHT JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" RIGHT JOIN "
+ + JOIN_SUPPLIER_TABLE_FULL_NAME + " s ON i.\"supplier_id\" = s.\"supplier_id\" ORDER BY \"order_id\", s.\"supplier_id\" DESC";
+ Properties props = new Properties(TEST_PROPERTIES);
+ Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
+ try {
+ PreparedStatement statement = conn.prepareStatement(query);
+ ResultSet rs = statement.executeQuery();
+ ResultSetMetaData md = rs.getMetaData();
+ assertEquals(md.getColumnCount(), 13);
+
+ assertTrue (rs.next());
+ assertEquals(rs.getString(1), "0000000005");
+ assertEquals(rs.getString(2), "S5");
+ assertEquals(rs.getString(3), "888-888-5555");
+ assertEquals(rs.getString(4), "505 YYY Street");
+ assertEquals(rs.getString(5), "10005");
+ assertEquals(rs.getString(6), "0000000005");
+ assertEquals(rs.getString(7), "T5");
+ assertEquals(rs.getInt(8), 500);
+ assertEquals(rs.getInt(9), 8);
+ assertEquals(rs.getInt(10), 15);
+ assertEquals(rs.getString(11), "0000000005");
+ assertEquals(rs.getString(12), "Item T5");
+ assertNull(rs.getString(13));
+ assertTrue (rs.next());
+ assertEquals(rs.getString(1), "0000000004");
+ assertEquals(rs.getString(2), "S4");
+ assertEquals(rs.getString(3), "888-888-4444");
+ assertEquals(rs.getString(4), "404 YYY Street");
+ assertNull(rs.getString(5));
+ assertNull(rs.getString(6));
+ assertNull(rs.getString(7));
+ assertEquals(rs.getInt(8), 0);
+ assertEquals(rs.getInt(9), 0);
+ assertEquals(rs.getInt(10), 0);
+ assertNull(rs.getString(11));
+ assertNull(rs.getString(12));
+ assertNull(rs.getString(13));
+ assertTrue (rs.next());
+ assertEquals(rs.getString(1), "0000000003");
+ assertEquals(rs.getString(2), "S3");
+ assertEquals(rs.getString(3), "888-888-3333");
+ assertEquals(rs.getString(4), "303 YYY Street");
+ assertNull(rs.getString(5));
+ assertNull(rs.getString(6));
+ assertNull(rs.getString(7));
+ assertEquals(rs.getInt(8), 0);
+ assertEquals(rs.getInt(9), 0);
+ assertEquals(rs.getInt(10), 0);
+ assertNull(rs.getString(11));
+ assertNull(rs.getString(12));
+ assertNull(rs.getString(13));
+ assertTrue (rs.next());
+ assertEquals(rs.getString(1), "0000000002");
+ assertEquals(rs.getString(2), "S2");
+ assertEquals(rs.getString(3), "888-888-2222");
+ assertEquals(rs.getString(4), "202 YYY Street");
+ assertEquals(rs.getString(5), "10002");
+ assertEquals(rs.getString(6), "0000000004");
+ assertEquals(rs.getString(7), "T4");
+ assertEquals(rs.getInt(8), 400);
+ assertEquals(rs.getInt(9), 6);
+ assertEquals(rs.getInt(10), 10);
+ assertEquals(rs.getString(11), "0000000002");
+ assertEquals(rs.getString(12), "Item T4");
+ assertNull(rs.getString(13));
+ assertTrue (rs.next());
+ assertEquals(rs.getString(1), "0000000001");
+ assertEquals(rs.getString(2), "S1");
+ assertEquals(rs.getString(3), "888-888-1111");
+ assertEquals(rs.getString(4), "101 YYY Street");
+ assertEquals(rs.getString(5), "10001");
+ assertEquals(rs.getString(6), "0000000001");
+ assertEquals(rs.getString(7), "T1");
+ assertEquals(rs.getInt(8), 100);
+ assertEquals(rs.getInt(9), 5);
+ assertEquals(rs.getInt(10), 10);
+ assertEquals(rs.getString(11), "0000000001");
+ assertEquals(rs.getString(12), "Item T1");
+ assertEquals(rs.getString(13), "000000000000001");
+ assertTrue (rs.next());
+ assertEquals(rs.getString(1), "0000000006");
+ assertEquals(rs.getString(2), "S6");
+ assertEquals(rs.getString(3), "888-888-6666");
+ assertEquals(rs.getString(4), "606 YYY Street");
+ assertEquals(rs.getString(5), "10006");
+ assertEquals(rs.getString(6), "0000000006");
+ assertEquals(rs.getString(7), "T6");
+ assertEquals(rs.getInt(8), 600);
+ assertEquals(rs.getInt(9), 8);
+ assertEquals(rs.getInt(10), 15);
+ assertEquals(rs.getString(11), "0000000006");
+ assertEquals(rs.getString(12), "Item T6");
+ assertEquals(rs.getString(13), "000000000000002");
+ assertTrue (rs.next());
+ assertEquals(rs.getString(1), "0000000001");
+ assertEquals(rs.getString(2), "S1");
+ assertEquals(rs.getString(3), "888-888-1111");
+ assertEquals(rs.getString(4), "101 YYY Street");
+ assertEquals(rs.getString(5), "10001");
+ assertEquals(rs.getString(6), "0000000002");
+ assertEquals(rs.getString(7), "T2");
+ assertEquals(rs.getInt(8), 200);
+ assertEquals(rs.getInt(9), 5);
+ assertEquals(rs.getInt(10), 8);
+ assertEquals(rs.getString(11), "0000000001");
+ assertEquals(rs.getString(12), "Item T2");
+ assertEquals(rs.getString(13), "000000000000003");
+ assertTrue (rs.next());
+ assertEquals(rs.getString(1), "0000000006");
+ assertEquals(rs.getString(2), "S6");
+ assertEquals(rs.getString(3), "888-888-6666");
+ assertEquals(rs.getString(4), "606 YYY Street");
+ assertEquals(rs.getString(5), "10006");
+ assertEquals(rs.getString(6), "0000000006");
+ assertEquals(rs.getString(7), "T6");
+ assertEquals(rs.getInt(8), 600);
+ assertEquals(rs.getInt(9), 8);
+ assertEquals(rs.getInt(10), 15);
+ assertEquals(rs.getString(11), "0000000006");
+ assertEquals(rs.getString(12), "Item T6");
+ assertEquals(rs.getString(13), "000000000000004");
+ assertTrue (rs.next());
+ assertEquals(rs.getString(1), "0000000002");
+ assertEquals(rs.getString(2), "S2");
+ assertEquals(rs.getString(3), "888-888-2222");
+ assertEquals(rs.getString(4), "202 YYY Street");
+ assertEquals(rs.getString(5), "10002");
+ assertEquals(rs.getString(6), "0000000003");
+ assertEquals(rs.getString(7), "T3");
+ assertEquals(rs.getInt(8), 300);
+ assertEquals(rs.getInt(9), 8);
+ assertEquals(rs.getInt(10), 12);
+ assertEquals(rs.getString(11), "0000000002");
+ assertEquals(rs.getString(12), "Item T3");
+ assertEquals(rs.getString(13), "000000000000005");
+
+ assertFalse(rs.next());
+ } finally {
+ conn.close();
+ }
+ }
+
+ @Test
public void testJoinMultiJoinKeys() throws Exception {
- String query = "SELECT c.name, s.name FROM " + JOIN_CUSTOMER_TABLE + " c LEFT JOIN " + JOIN_SUPPLIER_TABLE + " s ON \"customer_id\" = \"supplier_id\" AND c.loc_id = s.loc_id AND substr(s.name, 2, 1) = substr(c.name, 2, 1)";
+ String query = "SELECT c.name, s.name FROM " + JOIN_CUSTOMER_TABLE_FULL_NAME + " c LEFT JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " s ON \"customer_id\" = \"supplier_id\" AND c.loc_id = s.loc_id AND substr(s.name, 2, 1) = substr(c.name, 2, 1)";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1545,8 +1694,8 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testJoinWithDifferentNumericJoinKeyTypes() throws Exception {
- String query = "SELECT \"order_id\", i.name, i.price, discount2, quantity FROM " + JOIN_ORDER_TABLE + " o INNER JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" AND o.price = (i.price * (100 - discount2)) / 100.0 WHERE quantity < 5000";
+ String query = "SELECT \"order_id\", i.name, i.price, discount2, quantity FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o INNER JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" AND o.price = (i.price * (100 - discount2)) / 100.0 WHERE quantity < 5000";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1567,8 +1716,8 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testJoinWithDifferentDateJoinKeyTypes() throws Exception {
- String query = "SELECT \"order_id\", c.name, o.date FROM " + JOIN_ORDER_TABLE + " o INNER JOIN "
- + JOIN_CUSTOMER_TABLE + " c ON o.\"customer_id\" = c.\"customer_id\" AND o.date = c.date";
+ String query = "SELECT \"order_id\", c.name, o.date FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o INNER JOIN "
+ + JOIN_CUSTOMER_TABLE_FULL_NAME + " c ON o.\"customer_id\" = c.\"customer_id\" AND o.date = c.date";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1600,8 +1749,8 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testJoinWithIncomparableJoinKeyTypes() throws Exception {
- String query = "SELECT \"order_id\", i.name, i.price, discount2, quantity FROM " + JOIN_ORDER_TABLE + " o INNER JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" AND o.price / 100 = substr(i.name, 2, 1)";
+ String query = "SELECT \"order_id\", i.name, i.price, discount2, quantity FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o INNER JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" AND o.price / 100 = substr(i.name, 2, 1)";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1617,8 +1766,8 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testJoinPlanWithIndex() throws Exception {
- String query1 = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE + " item LEFT JOIN " + JOIN_SUPPLIER_TABLE + " supp ON substr(item.name, 2, 1) = substr(supp.name, 2, 1) AND (supp.name BETWEEN 'S1' AND 'S5') WHERE item.name BETWEEN 'T1' AND 'T5'";
- String query2 = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE + " item INNER JOIN " + JOIN_SUPPLIER_TABLE + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" WHERE (item.name = 'T1' OR item.name = 'T5') AND (supp.name = 'S1' OR supp.name = 'S5')";
+ String query1 = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item LEFT JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON substr(item.name, 2, 1) = substr(supp.name, 2, 1) AND (supp.name BETWEEN 'S1' AND 'S5') WHERE item.name BETWEEN 'T1' AND 'T5'";
+ String query2 = "SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item INNER JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" WHERE (item.name = 'T1' OR item.name = 'T5') AND (supp.name = 'S1' OR supp.name = 'S5')";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1680,9 +1829,9 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testJoinWithSkipMergeOptimization() throws Exception {
- String query = "SELECT s.name FROM " + JOIN_ITEM_TABLE + " i JOIN "
- + JOIN_ORDER_TABLE + " o ON o.\"item_id\" = i.\"item_id\" AND quantity < 5000 JOIN "
- + JOIN_SUPPLIER_TABLE + " s ON i.\"supplier_id\" = s.\"supplier_id\"";
+ String query = "SELECT s.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " i JOIN "
+ + JOIN_ORDER_TABLE_FULL_NAME + " o ON o.\"item_id\" = i.\"item_id\" AND quantity < 5000 JOIN "
+ + JOIN_SUPPLIER_TABLE_FULL_NAME + " s ON i.\"supplier_id\" = s.\"supplier_id\"";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1708,10 +1857,10 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
@Test
public void testSelfJoin() throws Exception {
- String query1 = "SELECT i2.\"item_id\", i1.name FROM " + JOIN_ITEM_TABLE + " i1 JOIN "
- + JOIN_ITEM_TABLE + " i2 ON i1.\"item_id\" = i2.\"item_id\" ORDER BY i1.\"item_id\"";
- String query2 = "SELECT i1.name, i2.name FROM " + JOIN_ITEM_TABLE + " i1 JOIN "
- + JOIN_ITEM_TABLE + " i2 ON i1.\"item_id\" = i2.\"supplier_id\" ORDER BY i1.name, i2.name";
+ String query1 = "SELECT i2.\"item_id\", i1.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " i1 JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i2 ON i1.\"item_id\" = i2.\"item_id\" ORDER BY i1.\"item_id\"";
+ String query2 = "SELECT i1.name, i2.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " i1 JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i2 ON i1.\"item_id\" = i2.\"supplier_id\" ORDER BY i1.name, i2.name";
Properties props = new Properties(TEST_PROPERTIES);
Connection conn = DriverManager.getConnection(PHOENIX_JDBC_URL, props);
try {
@@ -1791,14 +1940,14 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
conn.createStatement().execute("UPSERT INTO " + tempTable
+ "(\"order_id\", item_name, supplier_name, quantity, date) "
+ "SELECT \"order_id\", i.name, s.name, quantity, date FROM "
- + JOIN_ORDER_TABLE + " o LEFT JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" LEFT JOIN "
- + JOIN_SUPPLIER_TABLE + " s ON i.\"supplier_id\" = s.\"supplier_id\"");
+ + JOIN_ORDER_TABLE_FULL_NAME + " o LEFT JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" LEFT JOIN "
+ + JOIN_SUPPLIER_TABLE_FULL_NAME + " s ON i.\"supplier_id\" = s.\"supplier_id\"");
conn.createStatement().execute("UPSERT INTO " + tempTable
+ "(\"order_id\", item_name, quantity) "
+ "SELECT 'ORDER_SUM', i.name, sum(quantity) FROM "
- + JOIN_ORDER_TABLE + " o LEFT JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" "
+ + JOIN_ORDER_TABLE_FULL_NAME + " o LEFT JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" "
+ "GROUP BY i.name ORDER BY i.name");
String query = "SELECT * FROM " + tempTable;
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/test/java/org/apache/phoenix/end2end/SkipRangeParallelIteratorRegionSplitterTest.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/end2end/SkipRangeParallelIteratorRegionSplitterTest.java b/phoenix-core/src/test/java/org/apache/phoenix/end2end/SkipRangeParallelIteratorRegionSplitterTest.java
index 11c9d6b..ca25b82 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/end2end/SkipRangeParallelIteratorRegionSplitterTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/end2end/SkipRangeParallelIteratorRegionSplitterTest.java
@@ -46,6 +46,7 @@ import org.junit.runners.Parameterized.Parameters;
import com.google.common.base.Function;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
+
import org.apache.phoenix.compile.ColumnResolver;
import org.apache.phoenix.compile.ScanRanges;
import org.apache.phoenix.compile.StatementContext;
@@ -348,6 +349,12 @@ public class SkipRangeParallelIteratorRegionSplitterTest extends BaseClientManag
}
@Override
+ public TableRef resolveTable(String schemaName, String tableName)
+ throws SQLException {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
public ColumnRef resolveColumn(String schemaName, String tableName, String colName) throws SQLException {
throw new UnsupportedOperationException();
}
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/test/java/org/apache/phoenix/query/BaseConnectionlessQueryTest.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseConnectionlessQueryTest.java b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseConnectionlessQueryTest.java
index 41c4716..d5209d6 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseConnectionlessQueryTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseConnectionlessQueryTest.java
@@ -23,10 +23,10 @@ import static org.apache.phoenix.util.PhoenixRuntime.TENANT_ID_ATTRIB;
import static org.apache.phoenix.util.TestUtil.ATABLE_NAME;
import static org.apache.phoenix.util.TestUtil.ENTITY_HISTORY_TABLE_NAME;
import static org.apache.phoenix.util.TestUtil.FUNKY_NAME;
-import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE;
+import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE_FULL_NAME;
import static org.apache.phoenix.util.TestUtil.MULTI_CF_NAME;
import static org.apache.phoenix.util.TestUtil.PHOENIX_CONNECTIONLESS_JDBC_URL;
import static org.apache.phoenix.util.TestUtil.PTSDB_NAME;
@@ -75,10 +75,10 @@ public class BaseConnectionlessQueryTest extends BaseTest {
ensureTableCreated(getUrl(), FUNKY_NAME);
ensureTableCreated(getUrl(), PTSDB_NAME);
ensureTableCreated(getUrl(), MULTI_CF_NAME);
- ensureTableCreated(getUrl(), JOIN_ORDER_TABLE);
- ensureTableCreated(getUrl(), JOIN_CUSTOMER_TABLE);
- ensureTableCreated(getUrl(), JOIN_ITEM_TABLE);
- ensureTableCreated(getUrl(), JOIN_SUPPLIER_TABLE);
+ ensureTableCreated(getUrl(), JOIN_ORDER_TABLE_FULL_NAME);
+ ensureTableCreated(getUrl(), JOIN_CUSTOMER_TABLE_FULL_NAME);
+ ensureTableCreated(getUrl(), JOIN_ITEM_TABLE_FULL_NAME);
+ ensureTableCreated(getUrl(), JOIN_SUPPLIER_TABLE_FULL_NAME);
ensureTableCreated(getUrl(), TABLE_WITH_ARRAY);
Properties props = new Properties();
props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(MetaDataProtocol.MIN_TABLE_TIMESTAMP));
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
index 94a997b..2a3ef95 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
@@ -30,10 +30,10 @@ import static org.apache.phoenix.util.TestUtil.HBASE_DYNAMIC_COLUMNS;
import static org.apache.phoenix.util.TestUtil.HBASE_NATIVE;
import static org.apache.phoenix.util.TestUtil.INDEX_DATA_SCHEMA;
import static org.apache.phoenix.util.TestUtil.INDEX_DATA_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE;
+import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE_FULL_NAME;
import static org.apache.phoenix.util.TestUtil.KEYONLY_NAME;
import static org.apache.phoenix.util.TestUtil.MDTEST_NAME;
import static org.apache.phoenix.util.TestUtil.MULTI_CF_NAME;
@@ -321,21 +321,21 @@ public abstract class BaseTest {
);
builder.put("SumDoubleTest","create table SumDoubleTest" +
" (id varchar not null primary key, d DOUBLE, f FLOAT, ud UNSIGNED_DOUBLE, uf UNSIGNED_FLOAT, i integer, de decimal)");
- builder.put(JOIN_ORDER_TABLE, "create table " + JOIN_ORDER_TABLE +
+ builder.put(JOIN_ORDER_TABLE_FULL_NAME, "create table " + JOIN_ORDER_TABLE_FULL_NAME +
" (\"order_id\" char(15) not null primary key, " +
" \"customer_id\" char(10) not null, " +
" \"item_id\" char(10) not null, " +
" price integer not null, " +
" quantity integer not null, " +
" date timestamp not null)");
- builder.put(JOIN_CUSTOMER_TABLE, "create table " + JOIN_CUSTOMER_TABLE +
+ builder.put(JOIN_CUSTOMER_TABLE_FULL_NAME, "create table " + JOIN_CUSTOMER_TABLE_FULL_NAME +
" (\"customer_id\" char(10) not null primary key, " +
" name varchar not null, " +
" phone char(12), " +
" address varchar, " +
" loc_id char(5), " +
" date date)");
- builder.put(JOIN_ITEM_TABLE, "create table " + JOIN_ITEM_TABLE +
+ builder.put(JOIN_ITEM_TABLE_FULL_NAME, "create table " + JOIN_ITEM_TABLE_FULL_NAME +
" (\"item_id\" char(10) not null primary key, " +
" name varchar not null, " +
" price integer, " +
@@ -343,7 +343,7 @@ public abstract class BaseTest {
" discount2 integer, " +
" \"supplier_id\" char(10), " +
" description varchar)");
- builder.put(JOIN_SUPPLIER_TABLE, "create table " + JOIN_SUPPLIER_TABLE +
+ builder.put(JOIN_SUPPLIER_TABLE_FULL_NAME, "create table " + JOIN_SUPPLIER_TABLE_FULL_NAME +
" (\"supplier_id\" char(10) not null primary key, " +
" name varchar not null, " +
" phone char(12), " +
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/test/java/org/apache/phoenix/util/TestUtil.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/util/TestUtil.java b/phoenix-core/src/test/java/org/apache/phoenix/util/TestUtil.java
index 2816023..5f75a0c 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/util/TestUtil.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/util/TestUtil.java
@@ -163,14 +163,19 @@ public class TestUtil {
public static final String INDEX_DATA_SCHEMA = "INDEX_TEST";
public static final String INDEX_DATA_TABLE = "INDEX_DATA_TABLE";
public static final String MUTABLE_INDEX_DATA_TABLE = "MUTABLE_INDEX_DATA_TABLE";
- public static final String JOIN_ORDER_TABLE_NORMALIZED = "joinOrderTable";
- public static final String JOIN_CUSTOMER_TABLE_NORMALIZED = "joinCustomerTable";
- public static final String JOIN_ITEM_TABLE_NORMALIZED = "joinItemTable";
- public static final String JOIN_SUPPLIER_TABLE_NORMALIZED = "joinSupplierTable";
- public static final String JOIN_ORDER_TABLE = '"' + JOIN_ORDER_TABLE_NORMALIZED + '"';
- public static final String JOIN_CUSTOMER_TABLE = '"' + JOIN_CUSTOMER_TABLE_NORMALIZED + '"';
- public static final String JOIN_ITEM_TABLE = '"' + JOIN_ITEM_TABLE_NORMALIZED + '"';
- public static final String JOIN_SUPPLIER_TABLE = '"' + JOIN_SUPPLIER_TABLE_NORMALIZED + '"';
+ public static final String JOIN_SCHEMA = "JOIN";
+ public static final String JOIN_ORDER_TABLE = "OrderTable";
+ public static final String JOIN_CUSTOMER_TABLE = "CustomerTable";
+ public static final String JOIN_ITEM_TABLE = "ItemTable";
+ public static final String JOIN_SUPPLIER_TABLE = "SupplierTable";
+ public static final String JOIN_ORDER_TABLE_FULL_NAME = '"' + JOIN_SCHEMA + "\".\"" + JOIN_ORDER_TABLE + '"';
+ public static final String JOIN_CUSTOMER_TABLE_FULL_NAME = '"' + JOIN_SCHEMA + "\".\"" + JOIN_CUSTOMER_TABLE + '"';
+ public static final String JOIN_ITEM_TABLE_FULL_NAME = '"' + JOIN_SCHEMA + "\".\"" + JOIN_ITEM_TABLE + '"';
+ public static final String JOIN_SUPPLIER_TABLE_FULL_NAME = '"' + JOIN_SCHEMA + "\".\"" + JOIN_SUPPLIER_TABLE + '"';
+ public static final String JOIN_ORDER_TABLE_DISPLAY_NAME = JOIN_SCHEMA + "." + JOIN_ORDER_TABLE;
+ public static final String JOIN_CUSTOMER_TABLE_DISPLAY_NAME = JOIN_SCHEMA + "." + JOIN_CUSTOMER_TABLE;
+ public static final String JOIN_ITEM_TABLE_DISPLAY_NAME = JOIN_SCHEMA + "." + JOIN_ITEM_TABLE;
+ public static final String JOIN_SUPPLIER_TABLE_DISPLAY_NAME = JOIN_SCHEMA + "." + JOIN_SUPPLIER_TABLE;
public static final Properties TEST_PROPERTIES = new Properties();
[4/4] git commit: Fix test case failures
Posted by ma...@apache.org.
Fix test case failures
Project: http://git-wip-us.apache.org/repos/asf/incubator-phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-phoenix/commit/872acf6a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-phoenix/tree/872acf6a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-phoenix/diff/872acf6a
Branch: refs/heads/master
Commit: 872acf6a53174df5f641e43ffccb9c9b07626c1e
Parents: 9ee8d64
Author: maryannxue <ma...@apache.org>
Authored: Tue Feb 11 23:59:30 2014 -0500
Committer: maryannxue <ma...@apache.org>
Committed: Tue Feb 11 23:59:30 2014 -0500
----------------------------------------------------------------------
.../test/java/org/apache/phoenix/end2end/HashJoinTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/872acf6a/phoenix-core/src/test/java/org/apache/phoenix/end2end/HashJoinTest.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/end2end/HashJoinTest.java b/phoenix-core/src/test/java/org/apache/phoenix/end2end/HashJoinTest.java
index 032c1dc..a1efb22 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/end2end/HashJoinTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/end2end/HashJoinTest.java
@@ -264,9 +264,9 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
* GROUP BY i.name ORDER BY i.name
*/
"CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME + "\n" +
- " SERVER AGGREGATE INTO DISTINCT ROWS BY [I._0:NAME]\n" +
+ " SERVER AGGREGATE INTO DISTINCT ROWS BY [I.0:NAME]\n" +
"CLIENT MERGE SORT\n" +
- "CLIENT SORTED BY [I._0:NAME]\n" +
+ "CLIENT SORTED BY [I.0:NAME]\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
" CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SCHEMA + ".IDX_ITEM\n" +
@@ -307,7 +307,7 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
*/
"CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SCHEMA + ".IDX_ITEM\n" +
" SERVER FILTER BY FIRST KEY ONLY\n" +
- " SERVER AGGREGATE INTO ORDERED DISTINCT ROWS BY [I._0:NAME]\n" +
+ " SERVER AGGREGATE INTO ORDERED DISTINCT ROWS BY [I.0:NAME]\n" +
"CLIENT MERGE SORT\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
@@ -393,7 +393,7 @@ public class HashJoinTest extends BaseHBaseManagedTimeTest {
*/
"CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SCHEMA + ".IDX_ITEM\n" +
" SERVER FILTER BY FIRST KEY ONLY\n" +
- " SERVER SORTED BY [I1._0:NAME, I2._0:NAME]\n" +
+ " SERVER SORTED BY [I1.0:NAME, I2.0:NAME]\n" +
"CLIENT MERGE SORT\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
[3/4] git commit: Fix merge conflicts
Posted by ma...@apache.org.
Fix merge conflicts
Project: http://git-wip-us.apache.org/repos/asf/incubator-phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-phoenix/commit/9ee8d645
Tree: http://git-wip-us.apache.org/repos/asf/incubator-phoenix/tree/9ee8d645
Diff: http://git-wip-us.apache.org/repos/asf/incubator-phoenix/diff/9ee8d645
Branch: refs/heads/master
Commit: 9ee8d645d55da0d079eef632df3123f535390115
Parents: 7ac4ee2 7a6a46c
Author: maryannxue <ma...@apache.org>
Authored: Tue Feb 11 23:13:53 2014 -0500
Committer: maryannxue <ma...@apache.org>
Committed: Tue Feb 11 23:13:53 2014 -0500
----------------------------------------------------------------------
phoenix-core/src/main/antlr3/PhoenixSQL.g | 32 +-
.../phoenix/compile/CreateSequenceCompiler.java | 10 +-
.../apache/phoenix/compile/DeleteCompiler.java | 8 +-
.../phoenix/compile/ExpressionCompiler.java | 20 +-
.../phoenix/compile/ExpressionProjector.java | 2 +-
.../apache/phoenix/compile/FromCompiler.java | 4 +-
.../apache/phoenix/compile/JoinCompiler.java | 4 +-
.../apache/phoenix/compile/LimitCompiler.java | 4 +-
.../apache/phoenix/compile/OrderByCompiler.java | 6 +-
.../phoenix/compile/ProjectionCompiler.java | 151 +-
.../TrackOrderPreservingExpressionCompiler.java | 10 +-
.../apache/phoenix/compile/UpsertCompiler.java | 22 +-
.../apache/phoenix/compile/WhereCompiler.java | 8 +-
.../apache/phoenix/compile/WhereOptimizer.java | 25 +-
.../coprocessor/MetaDataEndpointImpl.java | 32 +-
.../phoenix/coprocessor/ScanRegionObserver.java | 125 +-
.../coprocessor/SequenceRegionObserver.java | 11 +-
.../UngroupedAggregateRegionObserver.java | 17 +-
.../expression/ArrayConstructorExpression.java | 2 +-
.../phoenix/expression/BaseExpression.java | 6 +-
.../phoenix/expression/CoerceExpression.java | 28 +-
.../phoenix/expression/ColumnExpression.java | 14 +-
.../expression/ComparisonExpression.java | 22 +-
.../phoenix/expression/DateAddExpression.java | 12 +-
.../expression/DateSubtractExpression.java | 12 +-
.../expression/DecimalAddExpression.java | 6 +-
.../expression/DecimalDivideExpression.java | 6 +-
.../expression/DecimalMultiplyExpression.java | 6 +-
.../expression/DecimalSubtractExpression.java | 8 +-
.../phoenix/expression/DoubleAddExpression.java | 2 +-
.../expression/DoubleDivideExpression.java | 2 +-
.../expression/DoubleMultiplyExpression.java | 2 +-
.../expression/DoubleSubtractExpression.java | 2 +-
.../phoenix/expression/ExpressionType.java | 4 +-
.../phoenix/expression/InListExpression.java | 12 +-
.../IndexKeyValueColumnExpression.java | 26 -
.../expression/KeyValueColumnExpression.java | 12 +-
.../phoenix/expression/LikeExpression.java | 4 +-
.../phoenix/expression/LiteralExpression.java | 43 +-
.../phoenix/expression/LongAddExpression.java | 2 +-
.../expression/LongDivideExpression.java | 2 +-
.../expression/LongMultiplyExpression.java | 2 +-
.../expression/LongSubtractExpression.java | 2 +-
.../expression/ProjectedColumnExpression.java | 22 +-
.../expression/RowKeyColumnExpression.java | 2 +-
.../RowValueConstructorExpression.java | 4 +-
.../expression/StringConcatExpression.java | 8 +-
.../expression/TimestampAddExpression.java | 12 +-
.../expression/TimestampSubtractExpression.java | 12 +-
.../expression/aggregator/BaseAggregator.java | 12 +-
.../aggregator/BaseDecimalStddevAggregator.java | 6 +-
.../aggregator/BaseStddevAggregator.java | 6 +-
.../expression/aggregator/CountAggregator.java | 4 +-
.../aggregator/DecimalStddevPopAggregator.java | 6 +-
.../aggregator/DecimalStddevSampAggregator.java | 6 +-
.../aggregator/DecimalSumAggregator.java | 8 +-
.../DistinctCountClientAggregator.java | 7 +-
.../DistinctValueWithCountClientAggregator.java | 20 +-
.../DistinctValueWithCountServerAggregator.java | 3 +-
.../aggregator/DoubleSumAggregator.java | 10 +-
.../expression/aggregator/IntSumAggregator.java | 6 +-
.../aggregator/LongSumAggregator.java | 6 +-
.../expression/aggregator/MaxAggregator.java | 6 +-
.../expression/aggregator/MinAggregator.java | 8 +-
.../aggregator/NumberSumAggregator.java | 14 +-
.../aggregator/PercentRankClientAggregator.java | 6 +-
.../aggregator/PercentileClientAggregator.java | 6 +-
.../PercentileDiscClientAggregator.java | 6 +-
.../aggregator/StddevPopAggregator.java | 6 +-
.../aggregator/StddevSampAggregator.java | 6 +-
.../aggregator/UnsignedIntSumAggregator.java | 6 +-
.../aggregator/UnsignedLongSumAggregator.java | 6 +-
.../expression/function/ArrayIndexFunction.java | 2 +-
.../function/AvgAggregateFunction.java | 6 +-
.../function/CeilTimestampExpression.java | 8 +-
.../function/CountAggregateFunction.java | 2 +-
.../DistinctCountAggregateFunction.java | 2 +-
.../expression/function/InvertFunction.java | 8 +-
.../expression/function/LTrimFunction.java | 12 +-
.../expression/function/LengthFunction.java | 2 +-
.../expression/function/LowerFunction.java | 2 +-
.../function/MaxAggregateFunction.java | 10 +-
.../function/MinAggregateFunction.java | 10 +-
.../function/PercentRankAggregateFunction.java | 2 +-
.../PercentileContAggregateFunction.java | 2 +-
.../PercentileDiscAggregateFunction.java | 2 +-
.../expression/function/RTrimFunction.java | 10 +-
.../function/RegexpReplaceFunction.java | 4 +-
.../function/RegexpSubstrFunction.java | 4 +-
.../expression/function/ReverseFunction.java | 10 +-
.../function/RoundDateExpression.java | 8 +-
.../function/RoundDecimalExpression.java | 2 +-
.../function/RoundTimestampExpression.java | 8 +-
.../function/SqlTypeNameFunction.java | 2 +-
.../expression/function/StddevPopFunction.java | 4 +-
.../expression/function/StddevSampFunction.java | 4 +-
.../expression/function/SubstrFunction.java | 20 +-
.../function/SumAggregateFunction.java | 18 +-
.../expression/function/ToCharFunction.java | 2 +-
.../expression/function/ToDateFunction.java | 2 +-
.../expression/function/ToNumberFunction.java | 4 +-
.../expression/function/TrimFunction.java | 12 +-
.../expression/function/UpperFunction.java | 2 +-
.../apache/phoenix/index/IndexMaintainer.java | 81 +-
.../apache/phoenix/iterate/ExplainTable.java | 8 +-
.../phoenix/iterate/ParallelIterators.java | 10 +-
.../phoenix/jdbc/PhoenixDatabaseMetaData.java | 12 +-
.../phoenix/jdbc/PhoenixParameterMetaData.java | 6 +-
.../apache/phoenix/jdbc/PhoenixStatement.java | 6 +-
.../org/apache/phoenix/parse/ColumnDef.java | 19 +-
.../phoenix/parse/IndexKeyConstraint.java | 12 +-
.../apache/phoenix/parse/ParseNodeFactory.java | 14 +-
.../phoenix/parse/PrimaryKeyConstraint.java | 26 +-
.../query/ConnectionQueryServicesImpl.java | 7 +-
.../java/org/apache/phoenix/query/KeyRange.java | 6 +-
.../apache/phoenix/query/QueryConstants.java | 18 +-
.../org/apache/phoenix/schema/ColumnRef.java | 36 +-
.../apache/phoenix/schema/DelegateColumn.java | 4 +-
.../apache/phoenix/schema/DelegateDatum.java | 4 +-
.../apache/phoenix/schema/KeyValueSchema.java | 2 +-
.../apache/phoenix/schema/MetaDataClient.java | 71 +-
.../apache/phoenix/schema/PArrayDataType.java | 18 +-
.../org/apache/phoenix/schema/PColumnImpl.java | 21 +-
.../org/apache/phoenix/schema/PDataType.java | 573 ++++---
.../java/org/apache/phoenix/schema/PDatum.java | 4 +-
.../apache/phoenix/schema/PMetaDataImpl.java | 2 +-
.../org/apache/phoenix/schema/PTableImpl.java | 12 +-
.../org/apache/phoenix/schema/RowKeySchema.java | 4 +-
.../org/apache/phoenix/schema/SaltingUtil.java | 6 +-
.../org/apache/phoenix/schema/Sequence.java | 14 +-
.../org/apache/phoenix/schema/SortOrder.java | 142 ++
.../org/apache/phoenix/schema/ValueSchema.java | 29 +-
.../java/org/apache/phoenix/util/ByteUtil.java | 14 +-
.../java/org/apache/phoenix/util/IndexUtil.java | 10 +-
.../org/apache/phoenix/util/MetaDataUtil.java | 3 +-
.../org/apache/phoenix/util/PhoenixRuntime.java | 101 +-
.../org/apache/phoenix/util/SchemaUtil.java | 26 +-
.../org/apache/phoenix/util/StringUtil.java | 38 +-
.../phoenix/compile/HavingClauseTest.java | 194 ---
.../phoenix/compile/HavingCompilerTest.java | 199 +++
.../phoenix/compile/JoinQueryCompileTest.java | 146 --
.../phoenix/compile/JoinQueryCompilerTest.java | 146 ++
.../apache/phoenix/compile/LimitClauseTest.java | 157 --
.../phoenix/compile/LimitCompilerTest.java | 157 ++
.../phoenix/compile/QueryCompileTest.java | 1298 --------------
.../phoenix/compile/QueryCompilerTest.java | 1313 ++++++++++++++
.../apache/phoenix/compile/ScanRangesTest.java | 14 +-
.../apache/phoenix/compile/ViewCompileTest.java | 119 --
.../phoenix/compile/ViewCompilerTest.java | 119 ++
.../phoenix/compile/WhereClauseCompileTest.java | 931 ----------
.../compile/WhereClauseOptimizerTest.java | 1620 ------------------
.../phoenix/compile/WhereCompilerTest.java | 931 ++++++++++
.../phoenix/compile/WhereOptimizerTest.java | 1620 ++++++++++++++++++
.../apache/phoenix/end2end/AlterTableTest.java | 9 +-
.../org/apache/phoenix/end2end/ArrayTest.java | 157 +-
.../end2end/DescColumnSortOrderTest.java | 555 ------
.../phoenix/end2end/DynamicColumnTest.java | 9 +-
.../phoenix/end2end/DynamicFamilyTest.java | 11 +-
.../apache/phoenix/end2end/HashJoinTest.java | 23 +-
.../end2end/QueryDatabaseMetaDataTest.java | 2 +-
...RangeParallelIteratorRegionSplitterTest.java | 8 +-
.../apache/phoenix/end2end/SortOrderFTest.java | 554 ++++++
.../phoenix/end2end/index/IndexTestUtil.java | 6 +-
.../expression/ColumnExpressionTest.java | 9 +-
.../DescColumnSortOrderExpressionTest.java | 325 ----
.../expression/SortOrderExpressionTest.java | 324 ++++
.../filter/SkipScanFilterIntersectTest.java | 8 +-
.../phoenix/filter/SkipScanFilterTest.java | 8 +-
.../iterate/AggregateResultScannerTest.java | 6 +-
.../apache/phoenix/parse/QueryParserTest.java | 14 +-
.../query/BaseConnectionlessQueryTest.java | 44 +-
.../apache/phoenix/schema/PDataTypeTest.java | 172 +-
.../apache/phoenix/schema/RowKeySchemaTest.java | 12 +-
.../phoenix/schema/RowKeyValueAccessorTest.java | 2 +-
.../apache/phoenix/schema/SortOrderTest.java | 113 ++
.../apache/phoenix/schema/ValueBitSetTest.java | 4 +-
.../apache/phoenix/util/PhoenixRuntimeTest.java | 26 +
.../org/apache/phoenix/util/ScanUtilTest.java | 14 +-
.../java/org/apache/phoenix/util/TestUtil.java | 4 +-
.../flume/serializer/BaseEventSerializer.java | 48 +-
180 files changed, 7385 insertions(+), 6551 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/9ee8d645/phoenix-core/src/main/antlr3/PhoenixSQL.g
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/9ee8d645/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/9ee8d645/phoenix-core/src/main/java/org/apache/phoenix/compile/JoinCompiler.java
----------------------------------------------------------------------
diff --cc phoenix-core/src/main/java/org/apache/phoenix/compile/JoinCompiler.java
index e0b3704,0afbd3f..e7e0d56
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/JoinCompiler.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/JoinCompiler.java
@@@ -346,16 -341,24 +346,16 @@@ public class JoinCompiler
String colName = sourceColumn.getName().getString();
String fullName = getProjectedColumnName(schemaName, tableName, colName);
String aliasedName = sourceTable.getTableAlias() == null ? fullName : getProjectedColumnName(null, sourceTable.getTableAlias(), colName);
- String displayName = aliasedName;
- if (isRewrite) {
- String dataColName = IndexUtil.getDataColumnName(colName);
- displayName = sourceTable.getTableAlias() == null ? getProjectedColumnName(schemaName, table.getParentTableName().getString(), dataColName) : getProjectedColumnName(null, sourceTable.getTableAlias(), dataColName);
- }
- columnNameMap.put(colName, displayName);
- if (!fullName.equals(displayName)) {
- columnNameMap.put(fullName, displayName);
- }
- if (!aliasedName.equals(displayName) && !aliasedName.equals(fullName)) {
- columnNameMap.put(aliasedName, displayName);
+ columnNameMap.put(colName, aliasedName);
+ if (!fullName.equals(aliasedName)) {
+ columnNameMap.put(fullName, aliasedName);
}
- PName name = PNameFactory.newName(displayName);
+ PName name = PNameFactory.newName(aliasedName);
PColumnImpl column = new PColumnImpl(name, familyName, sourceColumn.getDataType(),
sourceColumn.getMaxLength(), sourceColumn.getScale(), sourceColumn.isNullable(),
- position, sourceColumn.getColumnModifier(), sourceColumn.getArraySize());
+ position, sourceColumn.getSortOrder(), sourceColumn.getArraySize());
Expression sourceExpression = new ColumnRef(sourceTable, sourceColumn.getPosition()).newColumnExpression();
projectedColumns.add(column);
sourceExpressions.add(sourceExpression);
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/9ee8d645/phoenix-core/src/main/java/org/apache/phoenix/compile/ProjectionCompiler.java
----------------------------------------------------------------------
diff --cc phoenix-core/src/main/java/org/apache/phoenix/compile/ProjectionCompiler.java
index 72f5c1a,2869a25..1fb6f5d
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/ProjectionCompiler.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/ProjectionCompiler.java
@@@ -52,9 -57,8 +57,10 @@@ import org.apache.phoenix.parse.Functio
import org.apache.phoenix.parse.ParseNode;
import org.apache.phoenix.parse.SelectStatement;
import org.apache.phoenix.parse.SequenceValueParseNode;
+import org.apache.phoenix.parse.TableName;
+import org.apache.phoenix.parse.TableWildcardParseNode;
import org.apache.phoenix.parse.WildcardParseNode;
+ import org.apache.phoenix.query.QueryConstants;
import org.apache.phoenix.schema.ArgumentTypeMismatchException;
import org.apache.phoenix.schema.ColumnNotFoundException;
import org.apache.phoenix.schema.ColumnRef;
@@@ -205,12 -196,13 +221,14 @@@ public class ProjectionCompiler
* @throws SQLException
*/
public static RowProjector compile(StatementContext context, SelectStatement statement, GroupBy groupBy, List<? extends PDatum> targetColumns) throws SQLException {
+ List<KeyValueColumnExpression> arrayKVRefs = new ArrayList<KeyValueColumnExpression>();
+ List<Expression> arrayKVFuncs = new ArrayList<Expression>();
List<AliasedNode> aliasedNodes = statement.getSelect();
// Setup projected columns in Scan
- SelectClauseVisitor selectVisitor = new SelectClauseVisitor(context, groupBy);
+ SelectClauseVisitor selectVisitor = new SelectClauseVisitor(context, groupBy, arrayKVRefs, arrayKVFuncs, statement);
List<ExpressionProjector> projectedColumns = new ArrayList<ExpressionProjector>();
- TableRef tableRef = context.getResolver().getTables().get(0);
+ ColumnResolver resolver = context.getResolver();
+ TableRef tableRef = context.getCurrentTable();
PTable table = tableRef.getTable();
boolean isWildcard = false;
Scan scan = context.getScan();
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/9ee8d645/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeFactory.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/9ee8d645/phoenix-core/src/test/java/org/apache/phoenix/compile/JoinQueryCompilerTest.java
----------------------------------------------------------------------
diff --cc phoenix-core/src/test/java/org/apache/phoenix/compile/JoinQueryCompilerTest.java
index 0000000,2c1d1ab..7c52e55
mode 000000,100644..100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/compile/JoinQueryCompilerTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/compile/JoinQueryCompilerTest.java
@@@ -1,0 -1,146 +1,146 @@@
+ /*
+ * Copyright 2014 The Apache Software Foundation
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+ package org.apache.phoenix.compile;
+
-import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE_NORMALIZED;
-import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE_NORMALIZED;
-import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE_NORMALIZED;
-import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE_NORMALIZED;
++import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE_FULL_NAME;
++import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE_DISPLAY_NAME;
++import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE_FULL_NAME;
++import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE_DISPLAY_NAME;
++import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE_FULL_NAME;
++import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE_DISPLAY_NAME;
++import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE_FULL_NAME;
++import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE_DISPLAY_NAME;
+ import static org.apache.phoenix.util.TestUtil.TEST_PROPERTIES;
+ import static org.junit.Assert.assertEquals;
+
+ import java.sql.Connection;
+ import java.sql.DriverManager;
+ import java.sql.ResultSet;
+ import java.sql.SQLException;
+ import java.util.Collections;
+ import java.util.List;
+
+ import org.junit.Test;
+ import org.apache.hadoop.hbase.client.Scan;
+ import org.apache.phoenix.compile.JoinCompiler.JoinSpec;
+ import org.apache.phoenix.jdbc.PhoenixConnection;
+ import org.apache.phoenix.jdbc.PhoenixStatement;
+ import org.apache.phoenix.parse.SQLParser;
+ import org.apache.phoenix.parse.SelectStatement;
+ import org.apache.phoenix.query.BaseConnectionlessQueryTest;
+ import org.apache.phoenix.util.QueryUtil;
+
+ /**
+ * Test compilation of queries containing joins.
+ */
+ public class JoinQueryCompilerTest extends BaseConnectionlessQueryTest {
+
+ @Test
+ public void testExplainPlan() throws Exception {
+ Connection conn = DriverManager.getConnection(getUrl());
- String query = "EXPLAIN SELECT s.\"supplier_id\", \"order_id\", c.name, i.name, quantity, o.date FROM " + JOIN_ORDER_TABLE + " o LEFT JOIN "
- + JOIN_CUSTOMER_TABLE + " c ON o.\"customer_id\" = c.\"customer_id\" AND c.name LIKE 'C%' LEFT JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" RIGHT JOIN "
- + JOIN_SUPPLIER_TABLE + " s ON s.\"supplier_id\" = i.\"supplier_id\" WHERE i.name LIKE 'T%'";
++ String query = "EXPLAIN SELECT s.\"supplier_id\", \"order_id\", c.name, i.name, quantity, o.date FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o LEFT JOIN "
++ + JOIN_CUSTOMER_TABLE_FULL_NAME + " c ON o.\"customer_id\" = c.\"customer_id\" AND c.name LIKE 'C%' LEFT JOIN "
++ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" RIGHT JOIN "
++ + JOIN_SUPPLIER_TABLE_FULL_NAME + " s ON s.\"supplier_id\" = i.\"supplier_id\" WHERE i.name LIKE 'T%'";
+ ResultSet rs = conn.createStatement().executeQuery(query);
+ assertEquals(
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_NORMALIZED + "\n" +
++ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_DISPLAY_NAME + "\n" +
+ " SERVER FILTER BY FIRST KEY ONLY\n" +
+ " PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
+ " BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED + "\n" +
++ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME + "\n" +
+ " PARALLEL EQUI-JOIN 2 HASH TABLES:\n" +
+ " BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_CUSTOMER_TABLE_NORMALIZED + "\n" +
++ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_CUSTOMER_TABLE_DISPLAY_NAME + "\n" +
+ " SERVER FILTER BY NAME LIKE 'C%'\n" +
+ " BUILD HASH TABLE 1\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
++ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
+ " AFTER-JOIN SERVER FILTER BY I.NAME LIKE 'T%'", QueryUtil.getExplainPlan(rs));
+ }
+
+ @Test
+ public void testWhereClauseOptimization() throws Exception {
+ PhoenixConnection pconn = DriverManager.getConnection(getUrl(), TEST_PROPERTIES).unwrap(PhoenixConnection.class);
- String queryTemplate = "SELECT t1.\"item_id\", t2.\"item_id\", t3.\"item_id\" FROM " + JOIN_ITEM_TABLE + " t1 "
- + "%s JOIN " + JOIN_ITEM_TABLE + " t2 ON t1.\"item_id\" = t2.\"item_id\" "
- + "%s JOIN " + JOIN_ITEM_TABLE + " t3 ON t1.\"item_id\" = t3.\"item_id\" "
++ String queryTemplate = "SELECT t1.\"item_id\", t2.\"item_id\", t3.\"item_id\" FROM " + JOIN_ITEM_TABLE_FULL_NAME + " t1 "
++ + "%s JOIN " + JOIN_ITEM_TABLE_FULL_NAME + " t2 ON t1.\"item_id\" = t2.\"item_id\" "
++ + "%s JOIN " + JOIN_ITEM_TABLE_FULL_NAME + " t3 ON t1.\"item_id\" = t3.\"item_id\" "
+ + "WHERE t1.\"item_id\" = '0000000001' AND t2.\"item_id\" = '0000000002' AND t3.\"item_id\" = '0000000003'";
+
+ String query = String.format(queryTemplate, "INNER", "INNER");
+ JoinSpec joinSpec = getJoinSpec(query, pconn);
+ assertEquals(1, joinSpec.getPreFilters().size());
+ assertEquals(1, joinSpec.getJoinTables().get(0).getPreFilters().size());
+ assertEquals(1, joinSpec.getJoinTables().get(1).getPreFilters().size());
+
+ query = String.format(queryTemplate, "INNER", "LEFT");
+ joinSpec = getJoinSpec(query, pconn);
+ assertEquals(1, joinSpec.getPreFilters().size());
+ assertEquals(1, joinSpec.getJoinTables().get(0).getPreFilters().size());
+ assertEquals(0, joinSpec.getJoinTables().get(1).getPreFilters().size());
+
+ query = String.format(queryTemplate, "INNER", "RIGHT");
+ joinSpec = getJoinSpec(query, pconn);
+ assertEquals(0, joinSpec.getPreFilters().size());
+ assertEquals(0, joinSpec.getJoinTables().get(0).getPreFilters().size());
+ assertEquals(1, joinSpec.getJoinTables().get(1).getPreFilters().size());
+
+ query = String.format(queryTemplate, "LEFT", "INNER");
+ joinSpec = getJoinSpec(query, pconn);
+ assertEquals(1, joinSpec.getPreFilters().size());
+ assertEquals(0, joinSpec.getJoinTables().get(0).getPreFilters().size());
+ assertEquals(1, joinSpec.getJoinTables().get(1).getPreFilters().size());
+
+ query = String.format(queryTemplate, "LEFT", "LEFT");
+ joinSpec = getJoinSpec(query, pconn);
+ assertEquals(1, joinSpec.getPreFilters().size());
+ assertEquals(0, joinSpec.getJoinTables().get(0).getPreFilters().size());
+ assertEquals(0, joinSpec.getJoinTables().get(1).getPreFilters().size());
+
+ query = String.format(queryTemplate, "LEFT", "RIGHT");
+ joinSpec = getJoinSpec(query, pconn);
+ assertEquals(0, joinSpec.getPreFilters().size());
+ assertEquals(0, joinSpec.getJoinTables().get(0).getPreFilters().size());
+ assertEquals(1, joinSpec.getJoinTables().get(1).getPreFilters().size());
+
+ query = String.format(queryTemplate, "RIGHT", "INNER");
+ joinSpec = getJoinSpec(query, pconn);
+ assertEquals(0, joinSpec.getPreFilters().size());
+ assertEquals(1, joinSpec.getJoinTables().get(0).getPreFilters().size());
+ assertEquals(1, joinSpec.getJoinTables().get(1).getPreFilters().size());
+
+ query = String.format(queryTemplate, "RIGHT", "RIGHT");
+ joinSpec = getJoinSpec(query, pconn);
+ assertEquals(0, joinSpec.getPreFilters().size());
+ assertEquals(0, joinSpec.getJoinTables().get(0).getPreFilters().size());
+ assertEquals(1, joinSpec.getJoinTables().get(1).getPreFilters().size());
+ }
+
+ private static JoinSpec getJoinSpec(String query, PhoenixConnection connection) throws SQLException {
+ Scan scan = new Scan();
+ List<Object> binds = Collections.emptyList();
+ SQLParser parser = new SQLParser(query);
+ SelectStatement select = parser.parseQuery();
+ ColumnResolver resolver = FromCompiler.getResolver(select, connection);
+ select = StatementNormalizer.normalize(select, resolver);
+ StatementContext context = new StatementContext(new PhoenixStatement(connection), resolver, binds, scan);
+ return JoinCompiler.getJoinSpec(context, select);
+ }
+ }
+
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/9ee8d645/phoenix-core/src/test/java/org/apache/phoenix/end2end/HashJoinTest.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/9ee8d645/phoenix-core/src/test/java/org/apache/phoenix/end2end/SkipRangeParallelIteratorRegionSplitterTest.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/9ee8d645/phoenix-core/src/test/java/org/apache/phoenix/query/BaseConnectionlessQueryTest.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/9ee8d645/phoenix-core/src/test/java/org/apache/phoenix/util/TestUtil.java
----------------------------------------------------------------------
[2/4] git commit: Fix PHOENIX-33 Support table-wildcard select in
join queries
Posted by ma...@apache.org.
Fix PHOENIX-33 Support table-wildcard select in join queries
Project: http://git-wip-us.apache.org/repos/asf/incubator-phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-phoenix/commit/7ac4ee2d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-phoenix/tree/7ac4ee2d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-phoenix/diff/7ac4ee2d
Branch: refs/heads/master
Commit: 7ac4ee2dffea9f1f67462f999870fd7431658eb5
Parents: a977a75
Author: maryannxue <ma...@apache.org>
Authored: Tue Feb 11 22:58:18 2014 -0500
Committer: maryannxue <ma...@apache.org>
Committed: Tue Feb 11 22:58:18 2014 -0500
----------------------------------------------------------------------
phoenix-core/src/main/antlr3/PhoenixSQL.g | 1 +
.../apache/phoenix/compile/ColumnResolver.java | 10 +
.../apache/phoenix/compile/FromCompiler.java | 14 +-
.../phoenix/compile/IndexStatementRewriter.java | 40 +-
.../apache/phoenix/compile/JoinCompiler.java | 119 ++---
.../apache/phoenix/compile/PostDDLCompiler.java | 5 +
.../phoenix/compile/ProjectionCompiler.java | 56 ++-
.../apache/phoenix/compile/QueryCompiler.java | 18 +-
.../phoenix/compile/StatementNormalizer.java | 89 +++-
.../org/apache/phoenix/parse/BindTableNode.java | 10 +-
.../apache/phoenix/parse/ConcreteTableNode.java | 4 +-
.../apache/phoenix/parse/DerivedTableNode.java | 4 +-
.../org/apache/phoenix/parse/JoinTableNode.java | 2 +-
.../apache/phoenix/parse/NamedTableNode.java | 12 +-
.../apache/phoenix/parse/ParseNodeFactory.java | 4 +
.../apache/phoenix/parse/ParseNodeRewriter.java | 5 +
.../apache/phoenix/parse/ParseNodeVisitor.java | 3 +-
.../org/apache/phoenix/parse/TableNode.java | 10 -
.../phoenix/parse/TableWildcardParseNode.java | 52 ++
.../parse/TraverseAllParseNodeVisitor.java | 5 +
.../parse/TraverseNoParseNodeVisitor.java | 5 +
.../parse/UnsupportedAllParseNodeVisitor.java | 5 +
.../phoenix/compile/JoinQueryCompileTest.java | 38 +-
.../apache/phoenix/end2end/HashJoinTest.java | 495 ++++++++++++-------
...RangeParallelIteratorRegionSplitterTest.java | 7 +
.../query/BaseConnectionlessQueryTest.java | 16 +-
.../java/org/apache/phoenix/query/BaseTest.java | 16 +-
.../java/org/apache/phoenix/util/TestUtil.java | 21 +-
28 files changed, 720 insertions(+), 346 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/antlr3/PhoenixSQL.g
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/antlr3/PhoenixSQL.g b/phoenix-core/src/main/antlr3/PhoenixSQL.g
index 53abed6..5370673 100644
--- a/phoenix-core/src/main/antlr3/PhoenixSQL.g
+++ b/phoenix-core/src/main/antlr3/PhoenixSQL.g
@@ -600,6 +600,7 @@ select_list returns [List<AliasedNode> ret]
selectable returns [AliasedNode ret]
: field=expression (a=parseAlias)? { $ret = factory.aliasedNode(a, field); }
| familyName=identifier DOT ASTERISK { $ret = factory.aliasedNode(null, factory.family(familyName));} // i.e. the 'cf.*' in 'select cf.* from' cf being column family of an hbase table
+ | tableName=table_name DOT ASTERISK { $ret = factory.aliasedNode(null, factory.tableWildcard(tableName)); }
;
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/compile/ColumnResolver.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/compile/ColumnResolver.java b/phoenix-core/src/main/java/org/apache/phoenix/compile/ColumnResolver.java
index 6c8abe7..2ba418e 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/ColumnResolver.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/ColumnResolver.java
@@ -43,6 +43,16 @@ public interface ColumnResolver {
public List<TableRef> getTables();
/**
+ * Resolves table using name or alias.
+ * @param schemaName the schema name
+ * @param tableName the table name or table alias
+ * @return the resolved TableRef
+ * @throws TableNotFoundException if the table could not be resolved
+ * @throws AmbiguousTableException if the table name is ambiguous
+ */
+ public TableRef resolveTable(String schemaName, String tableName) throws SQLException;
+
+ /**
* Resolves column using name and alias.
* @param schemaName TODO
* @param tableName TODO
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java b/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
index 92f11bc..296ce79 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
@@ -87,6 +87,12 @@ public class FromCompiler {
}
@Override
+ public TableRef resolveTable(String schemaName, String tableName)
+ throws SQLException {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
public ColumnRef resolveColumn(String schemaName, String tableName, String colName) throws SQLException {
throw new UnsupportedOperationException();
}
@@ -237,6 +243,12 @@ public class FromCompiler {
return tableRefs;
}
+ @Override
+ public TableRef resolveTable(String schemaName, String tableName)
+ throws SQLException {
+ throw new UnsupportedOperationException();
+ }
+
@Override
public ColumnRef resolveColumn(String schemaName, String tableName,
String colName) throws SQLException {
@@ -388,7 +400,7 @@ public class FromCompiler {
}
}
- private TableRef resolveTable(String schemaName, String tableName) throws SQLException {
+ public TableRef resolveTable(String schemaName, String tableName) throws SQLException {
String fullTableName = SchemaUtil.getTableName(schemaName, tableName);
List<TableRef> tableRefs = tableMap.get(fullTableName);
if (tableRefs.size() == 0) {
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/compile/IndexStatementRewriter.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/compile/IndexStatementRewriter.java b/phoenix-core/src/main/java/org/apache/phoenix/compile/IndexStatementRewriter.java
index 66349f7..c4a690a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/IndexStatementRewriter.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/IndexStatementRewriter.java
@@ -10,6 +10,7 @@ import org.apache.phoenix.parse.ParseNodeFactory;
import org.apache.phoenix.parse.ParseNodeRewriter;
import org.apache.phoenix.parse.SelectStatement;
import org.apache.phoenix.parse.TableName;
+import org.apache.phoenix.parse.TableWildcardParseNode;
import org.apache.phoenix.parse.WildcardParseNode;
import org.apache.phoenix.schema.ColumnRef;
import org.apache.phoenix.schema.PDataType;
@@ -54,20 +55,10 @@ public class IndexStatementRewriter extends ParseNodeRewriter {
@Override
public ParseNode visit(ColumnParseNode node) throws SQLException {
ColumnRef dataColRef = getResolver().resolveColumn(node.getSchemaName(), node.getTableName(), node.getName());
- TableName tName = null;
- if (multiTableRewriteMap != null) {
- TableRef origRef = dataColRef.getTableRef();
- TableRef tableRef = multiTableRewriteMap.get(origRef);
- if (tableRef == null)
- return node;
-
- if (origRef.getTableAlias() != null) {
- tName = TableName.create(null, origRef.getTableAlias());
- } else {
- String schemaName = tableRef.getTable().getSchemaName().getString();
- tName = TableName.create(schemaName.length() == 0 ? null : schemaName, tableRef.getTable().getTableName().getString());
- }
- }
+ TableName tName = getReplacedTableName(dataColRef.getTableRef());
+ if (multiTableRewriteMap != null && tName == null)
+ return node;
+
String indexColName = IndexUtil.getIndexColumnName(dataColRef.getColumn());
// Same alias as before, but use the index column name instead of the data column name
ParseNode indexColNode = new ColumnParseNode(tName, node.isCaseSensitive() ? '"' + indexColName + '"' : indexColName, node.getAlias());
@@ -94,9 +85,30 @@ public class IndexStatementRewriter extends ParseNodeRewriter {
}
@Override
+ public ParseNode visit(TableWildcardParseNode node) throws SQLException {
+ TableName tName = getReplacedTableName(getResolver().resolveTable(node.getTableName().getSchemaName(), node.getTableName().getTableName()));
+ return tName == null ? node : TableWildcardParseNode.create(tName, true);
+ }
+
+ @Override
public ParseNode visit(FamilyWildcardParseNode node) throws SQLException {
return multiTableRewriteMap != null ? node : new FamilyWildcardParseNode(node, true);
}
+ private TableName getReplacedTableName(TableRef origRef) {
+ if (multiTableRewriteMap == null)
+ return null;
+
+ TableRef tableRef = multiTableRewriteMap.get(origRef);
+ if (tableRef == null)
+ return null;
+
+ if (origRef.getTableAlias() != null)
+ return TableName.create(null, origRef.getTableAlias());
+
+ String schemaName = tableRef.getTable().getSchemaName().getString();
+ return TableName.create(schemaName.length() == 0 ? null : schemaName, tableRef.getTable().getTableName().getString());
+ }
+
}
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/compile/JoinCompiler.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/compile/JoinCompiler.java b/phoenix-core/src/main/java/org/apache/phoenix/compile/JoinCompiler.java
index bea89da..e0b3704 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/JoinCompiler.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/JoinCompiler.java
@@ -71,6 +71,7 @@ import org.apache.phoenix.parse.StatelessTraverseAllParseNodeVisitor;
import org.apache.phoenix.parse.TableName;
import org.apache.phoenix.parse.TableNode;
import org.apache.phoenix.parse.TableNodeVisitor;
+import org.apache.phoenix.parse.TableWildcardParseNode;
import org.apache.phoenix.parse.TraverseNoParseNodeVisitor;
import org.apache.phoenix.parse.WildcardParseNode;
import org.apache.phoenix.schema.AmbiguousColumnException;
@@ -85,11 +86,9 @@ import org.apache.phoenix.schema.PTable;
import org.apache.phoenix.schema.PTableImpl;
import org.apache.phoenix.schema.PTableType;
import org.apache.phoenix.schema.TableRef;
-import org.apache.phoenix.util.IndexUtil;
import org.apache.phoenix.util.SchemaUtil;
import com.google.common.collect.ArrayListMultimap;
-import com.google.common.collect.ImmutableList;
import com.google.common.collect.ListMultimap;
import com.google.common.collect.Lists;
@@ -205,11 +204,11 @@ public class JoinCompiler {
for (ColumnRef ref : prefilterRefVisitor.getColumnRefMap().keySet()) {
if (!columnRefs.containsKey(ref))
columnRefs.put(ref, ColumnRefType.PREFILTER);
- }
+ }
}
private JoinSpec(ColumnResolver resolver, TableNode tableNode, TableRef table, List<AliasedNode> select, List<ParseNode> preFilters,
- List<ParseNode> postFilters, List<JoinTable> joinTables, Map<ColumnRef, ColumnRefType> columnRefs) {
+ List<ParseNode> postFilters, List<JoinTable> joinTables, Map<TableRef, JoinTable> tableRefToJoinTableMap, Map<ColumnRef, ColumnRefType> columnRefs) {
this.origResolver = resolver;
this.mainTableNode = tableNode;
this.mainTable = table;
@@ -217,6 +216,7 @@ public class JoinCompiler {
this.preFilters = preFilters;
this.postFilters = postFilters;
this.joinTables = joinTables;
+ this.tableRefToJoinTableMap = tableRefToJoinTableMap;
this.columnRefs = columnRefs;
}
@@ -275,9 +275,14 @@ public class JoinCompiler {
return AndExpression.create(expressions);
}
+
+ protected boolean isWildCardSelect(TableRef table) {
+ List<AliasedNode> selectList = table.equals(mainTable) ? this.select : tableRefToJoinTableMap.get(table).getSelect();
+ return (selectList.size() == 1 && selectList.get(0).getNode() instanceof TableWildcardParseNode);
+ }
public void projectColumns(Scan scan, TableRef table) {
- if (isWildCardSelect(select)) {
+ if (isWildCardSelect(table)) {
scan.getFamilyMap().clear();
return;
}
@@ -289,7 +294,7 @@ public class JoinCompiler {
}
}
- public ProjectedPTableWrapper createProjectedTable(TableRef tableRef, boolean retainPKColumns, boolean isRewrite) throws SQLException {
+ public ProjectedPTableWrapper createProjectedTable(TableRef tableRef, boolean retainPKColumns) throws SQLException {
List<PColumn> projectedColumns = new ArrayList<PColumn>();
List<Expression> sourceExpressions = new ArrayList<Expression>();
ListMultimap<String, String> columnNameMap = ArrayListMultimap.<String, String>create();
@@ -298,14 +303,14 @@ public class JoinCompiler {
if (retainPKColumns) {
for (PColumn column : table.getPKColumns()) {
addProjectedColumn(projectedColumns, sourceExpressions, columnNameMap,
- column, tableRef, column.getFamilyName(), hasSaltingColumn, isRewrite);
+ column, tableRef, column.getFamilyName(), hasSaltingColumn);
}
}
- if (isWildCardSelect(select)) {
+ if (isWildCardSelect(tableRef)) {
for (PColumn column : table.getColumns()) {
if (!retainPKColumns || !SchemaUtil.isPKColumn(column)) {
addProjectedColumn(projectedColumns, sourceExpressions, columnNameMap,
- column, tableRef, PNameFactory.newName(ScanProjector.VALUE_COLUMN_FAMILY), hasSaltingColumn, isRewrite);
+ column, tableRef, PNameFactory.newName(ScanProjector.VALUE_COLUMN_FAMILY), hasSaltingColumn);
}
}
} else {
@@ -316,7 +321,7 @@ public class JoinCompiler {
&& (!retainPKColumns || !SchemaUtil.isPKColumn(columnRef.getColumn()))) {
PColumn column = columnRef.getColumn();
addProjectedColumn(projectedColumns, sourceExpressions, columnNameMap,
- column, tableRef, PNameFactory.newName(ScanProjector.VALUE_COLUMN_FAMILY), hasSaltingColumn, isRewrite);
+ column, tableRef, PNameFactory.newName(ScanProjector.VALUE_COLUMN_FAMILY), hasSaltingColumn);
}
}
}
@@ -329,7 +334,7 @@ public class JoinCompiler {
}
private static void addProjectedColumn(List<PColumn> projectedColumns, List<Expression> sourceExpressions,
- ListMultimap<String, String> columnNameMap, PColumn sourceColumn, TableRef sourceTable, PName familyName, boolean hasSaltingColumn, boolean isRewrite)
+ ListMultimap<String, String> columnNameMap, PColumn sourceColumn, TableRef sourceTable, PName familyName, boolean hasSaltingColumn)
throws SQLException {
if (sourceColumn == SALTING_COLUMN)
return;
@@ -341,21 +346,13 @@ public class JoinCompiler {
String colName = sourceColumn.getName().getString();
String fullName = getProjectedColumnName(schemaName, tableName, colName);
String aliasedName = sourceTable.getTableAlias() == null ? fullName : getProjectedColumnName(null, sourceTable.getTableAlias(), colName);
- String displayName = aliasedName;
- if (isRewrite) {
- String dataColName = IndexUtil.getDataColumnName(colName);
- displayName = sourceTable.getTableAlias() == null ? getProjectedColumnName(schemaName, table.getParentTableName().getString(), dataColName) : getProjectedColumnName(null, sourceTable.getTableAlias(), dataColName);
- }
- columnNameMap.put(colName, displayName);
- if (!fullName.equals(displayName)) {
- columnNameMap.put(fullName, displayName);
- }
- if (!aliasedName.equals(displayName) && !aliasedName.equals(fullName)) {
- columnNameMap.put(aliasedName, displayName);
+ columnNameMap.put(colName, aliasedName);
+ if (!fullName.equals(aliasedName)) {
+ columnNameMap.put(fullName, aliasedName);
}
- PName name = PNameFactory.newName(displayName);
+ PName name = PNameFactory.newName(aliasedName);
PColumnImpl column = new PColumnImpl(name, familyName, sourceColumn.getDataType(),
sourceColumn.getMaxLength(), sourceColumn.getScale(), sourceColumn.isNullable(),
position, sourceColumn.getColumnModifier(), sourceColumn.getArraySize());
@@ -364,8 +361,12 @@ public class JoinCompiler {
sourceExpressions.add(sourceExpression);
}
+ public ColumnResolver getColumnResolver(PTableWrapper table) {
+ return new JoinedTableColumnResolver(table, origResolver);
+ }
+
public boolean hasPostReference(TableRef table) {
- if (isWildCardSelect(select))
+ if (isWildCardSelect(table))
return true;
for (Map.Entry<ColumnRef, ColumnRefType> e : columnRefs.entrySet()) {
@@ -492,7 +493,7 @@ public class JoinCompiler {
public static JoinSpec getSubJoinSpecWithoutPostFilters(JoinSpec join) {
return new JoinSpec(join.origResolver, join.mainTableNode, join.mainTable, join.select, join.preFilters, new ArrayList<ParseNode>(),
- join.joinTables.subList(0, join.joinTables.size() - 1), join.columnRefs);
+ join.joinTables.subList(0, join.joinTables.size() - 1), join.tableRefToJoinTableMap, join.columnRefs);
}
public static class JoinTable {
@@ -870,23 +871,25 @@ public class JoinCompiler {
// for creation of new statements
private static ParseNodeFactory NODE_FACTORY = new ParseNodeFactory();
- private static boolean isWildCardSelect(List<AliasedNode> select) {
- return (select.size() == 1 && select.get(0).getNode() == WildcardParseNode.INSTANCE);
- }
-
private static List<AliasedNode> extractFromSelect(List<AliasedNode> select, TableRef table, ColumnResolver resolver) throws SQLException {
List<AliasedNode> ret = new ArrayList<AliasedNode>();
- if (isWildCardSelect(select)) {
- ret.add(NODE_FACTORY.aliasedNode(null, WildcardParseNode.INSTANCE));
- return ret;
- }
-
ColumnParseNodeVisitor visitor = new ColumnParseNodeVisitor(resolver);
- for (AliasedNode node : select) {
- node.getNode().accept(visitor);
+ for (AliasedNode aliasedNode : select) {
+ ParseNode node = aliasedNode.getNode();
+ if (node instanceof TableWildcardParseNode) {
+ TableName tableName = ((TableWildcardParseNode) node).getTableName();
+ if (table.equals(resolver.resolveTable(tableName.getSchemaName(), tableName.getTableName()))) {
+ ret.clear();
+ ret.add(aliasedNode);
+ return ret;
+ }
+ continue;
+ }
+
+ node.accept(visitor);
ColumnParseNodeVisitor.ContentType type = visitor.getContentType(table);
if (type == ColumnParseNodeVisitor.ContentType.SELF_ONLY) {
- ret.add(node);
+ ret.add(aliasedNode);
} else if (type == ColumnParseNodeVisitor.ContentType.COMPLEX) {
for (Map.Entry<ColumnRef, ColumnParseNode> entry : visitor.getColumnRefMap().entrySet()) {
if (entry.getKey().getTableRef().equals(table)) {
@@ -961,7 +964,7 @@ public class JoinCompiler {
@Override
public void visit(BindTableNode boundTableNode) throws SQLException {
String alias = boundTableNode.getAlias();
- replaced = BindTableNode.create(alias == null ? null : '"' + alias + '"', getReplacedTableName(), true);
+ replaced = NODE_FACTORY.bindTable(alias == null ? null : '"' + alias + '"', getReplacedTableName());
}
@Override
@@ -974,7 +977,7 @@ public class JoinCompiler {
public void visit(NamedTableNode namedTableNode)
throws SQLException {
String alias = namedTableNode.getAlias();
- replaced = NamedTableNode.create(alias == null ? null : '"' + alias + '"', getReplacedTableName(), namedTableNode.getDynamicColumns(), true);
+ replaced = NODE_FACTORY.namedTable(alias == null ? null : '"' + alias + '"', getReplacedTableName(), namedTableNode.getDynamicColumns());
}
@Override
@@ -1000,7 +1003,7 @@ public class JoinCompiler {
TableRef table = jTable.getTable();
List<ParseNode> groupBy = table.equals(groupByTableRef) ? select.getGroupBy() : null;
List<OrderByNode> orderBy = table.equals(orderByTableRef) ? select.getOrderBy() : null;
- SelectStatement stmt = getSubqueryForOptimizedPlan(select, table, join.columnRefs, jTable.getPreFiltersCombined(), groupBy, orderBy);
+ SelectStatement stmt = getSubqueryForOptimizedPlan(select, table, join.columnRefs, jTable.getPreFiltersCombined(), groupBy, orderBy, join.isWildCardSelect(table));
QueryPlan plan = context.getConnection().getQueryServices().getOptimizer().optimize(stmt, statement);
if (!plan.getTableRef().equals(table)) {
TableNodeRewriter rewriter = new TableNodeRewriter(plan.getTableRef());
@@ -1016,7 +1019,7 @@ public class JoinCompiler {
TableRef table = join.getMainTable();
List<ParseNode> groupBy = table.equals(groupByTableRef) ? select.getGroupBy() : null;
List<OrderByNode> orderBy = table.equals(orderByTableRef) ? select.getOrderBy() : null;
- SelectStatement stmt = getSubqueryForOptimizedPlan(select, table, join.columnRefs, join.getPreFiltersCombined(), groupBy, orderBy);
+ SelectStatement stmt = getSubqueryForOptimizedPlan(select, table, join.columnRefs, join.getPreFiltersCombined(), groupBy, orderBy, join.isWildCardSelect(table));
QueryPlan plan = context.getConnection().getQueryServices().getOptimizer().optimize(stmt, statement);
if (!plan.getTableRef().equals(table)) {
TableNodeRewriter rewriter = new TableNodeRewriter(plan.getTableRef());
@@ -1033,11 +1036,11 @@ public class JoinCompiler {
return IndexStatementRewriter.translate(NODE_FACTORY.select(select, newFrom), resolver, replacement);
}
- private static SelectStatement getSubqueryForOptimizedPlan(SelectStatement select, TableRef table, Map<ColumnRef, ColumnRefType> columnRefs, ParseNode where, List<ParseNode> groupBy, List<OrderByNode> orderBy) {
+ private static SelectStatement getSubqueryForOptimizedPlan(SelectStatement select, TableRef table, Map<ColumnRef, ColumnRefType> columnRefs, ParseNode where, List<ParseNode> groupBy, List<OrderByNode> orderBy, boolean isWildCardSelect) {
String schemaName = table.getTable().getSchemaName().getString();
TableName tName = TableName.create(schemaName.length() == 0 ? null : schemaName, table.getTable().getTableName().getString());
List<AliasedNode> selectList = new ArrayList<AliasedNode>();
- if (isWildCardSelect(select.getSelect())) {
+ if (isWildCardSelect) {
selectList.add(NODE_FACTORY.aliasedNode(null, WildcardParseNode.INSTANCE));
} else {
for (ColumnRef colRef : columnRefs.keySet()) {
@@ -1190,34 +1193,36 @@ public class JoinCompiler {
}
}
- public static ColumnResolver getColumnResolver(PTableWrapper table) {
- return new JoinedTableColumnResolver(table);
- }
-
public static class JoinedTableColumnResolver implements ColumnResolver {
private PTableWrapper table;
- private List<TableRef> tableRefs;
+ private ColumnResolver tableResolver;
+ private TableRef tableRef;
- private JoinedTableColumnResolver(PTableWrapper table) {
+ private JoinedTableColumnResolver(PTableWrapper table, ColumnResolver tableResolver) {
this.table = table;
- TableRef tableRef = new TableRef(null, table.getTable(), 0, false);
- this.tableRefs = ImmutableList.of(tableRef);
+ this.tableResolver = tableResolver;
+ this.tableRef = new TableRef(null, table.getTable(), 0, false);
}
+
+ public PTableWrapper getPTableWrapper() {
+ return table;
+ }
@Override
public List<TableRef> getTables() {
- return tableRefs;
- }
-
- public PTableWrapper getPTableWrapper() {
- return table;
+ return tableResolver.getTables();
}
+ @Override
+ public TableRef resolveTable(String schemaName, String tableName)
+ throws SQLException {
+ return tableResolver.resolveTable(schemaName, tableName);
+ }
+
@Override
public ColumnRef resolveColumn(String schemaName, String tableName,
String colName) throws SQLException {
String name = getProjectedColumnName(schemaName, tableName, colName);
- TableRef tableRef = tableRefs.get(0);
try {
PColumn column = tableRef.getTable().getColumn(name);
return new ColumnRef(tableRef, column.getPosition());
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/compile/PostDDLCompiler.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/compile/PostDDLCompiler.java b/phoenix-core/src/main/java/org/apache/phoenix/compile/PostDDLCompiler.java
index bf8c2e5..6c4452a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/PostDDLCompiler.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/PostDDLCompiler.java
@@ -118,6 +118,11 @@ public class PostDDLCompiler {
return Collections.singletonList(tableRef);
}
@Override
+ public TableRef resolveTable(String schemaName, String tableName)
+ throws SQLException {
+ throw new UnsupportedOperationException();
+ }
+ @Override
public ColumnRef resolveColumn(String schemaName, String tableName, String colName) throws SQLException {
PColumn column = tableName != null
? tableRef.getTable().getColumnFamily(tableName).getColumn(colName)
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/compile/ProjectionCompiler.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/compile/ProjectionCompiler.java b/phoenix-core/src/main/java/org/apache/phoenix/compile/ProjectionCompiler.java
index d617b5e..72f5c1a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/ProjectionCompiler.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/ProjectionCompiler.java
@@ -34,6 +34,7 @@ import org.apache.hadoop.hbase.util.Bytes;
import com.google.common.collect.Iterators;
import com.google.common.collect.Lists;
import com.google.common.collect.Sets;
+
import org.apache.phoenix.compile.GroupByCompiler.GroupBy;
import org.apache.phoenix.coprocessor.GroupedAggregateRegionObserver;
import org.apache.phoenix.exception.SQLExceptionCode;
@@ -51,6 +52,8 @@ import org.apache.phoenix.parse.FamilyWildcardParseNode;
import org.apache.phoenix.parse.ParseNode;
import org.apache.phoenix.parse.SelectStatement;
import org.apache.phoenix.parse.SequenceValueParseNode;
+import org.apache.phoenix.parse.TableName;
+import org.apache.phoenix.parse.TableWildcardParseNode;
import org.apache.phoenix.parse.WildcardParseNode;
import org.apache.phoenix.schema.ArgumentTypeMismatchException;
import org.apache.phoenix.schema.ColumnNotFoundException;
@@ -99,7 +102,8 @@ public class ProjectionCompiler {
return compile(context, statement, groupBy, Collections.<PColumn>emptyList());
}
- private static void projectAllTableColumns(StatementContext context, TableRef tableRef, List<Expression> projectedExpressions, List<ExpressionProjector> projectedColumns) throws SQLException {
+ private static void projectAllTableColumns(StatementContext context, TableRef tableRef, boolean resolveColumn, List<Expression> projectedExpressions, List<ExpressionProjector> projectedColumns) throws SQLException {
+ ColumnResolver resolver = context.getResolver();
PTable table = tableRef.getTable();
int posOffset = table.getBucketNum() == null ? 0 : 1;
// In SELECT *, don't include tenant column for tenant connection
@@ -108,15 +112,26 @@ public class ProjectionCompiler {
}
for (int i = posOffset; i < table.getColumns().size(); i++) {
ColumnRef ref = new ColumnRef(tableRef,i);
+ String colName = ref.getColumn().getName().getString();
+ if (resolveColumn) {
+ if (tableRef.getTableAlias() != null) {
+ ref = resolver.resolveColumn(null, tableRef.getTableAlias(), colName);
+ colName = SchemaUtil.getColumnName(tableRef.getTableAlias(), colName);
+ } else {
+ String schemaName = table.getSchemaName().getString();
+ ref = resolver.resolveColumn(schemaName.length() == 0 ? null : schemaName, table.getTableName().getString(), colName);
+ colName = SchemaUtil.getColumnName(table.getName().getString(), colName);
+ }
+ }
Expression expression = ref.newColumnExpression();
projectedExpressions.add(expression);
- String colName = ref.getColumn().getName().getString();
boolean isCaseSensitive = !SchemaUtil.normalizeIdentifier(colName).equals(colName);
projectedColumns.add(new ExpressionProjector(colName, table.getName().getString(), expression, isCaseSensitive));
}
}
- private static void projectAllIndexColumns(StatementContext context, TableRef tableRef, List<Expression> projectedExpressions, List<ExpressionProjector> projectedColumns) throws SQLException {
+ private static void projectAllIndexColumns(StatementContext context, TableRef tableRef, boolean resolveColumn, List<Expression> projectedExpressions, List<ExpressionProjector> projectedColumns) throws SQLException {
+ ColumnResolver resolver = context.getResolver();
PTable index = tableRef.getTable();
PTable table = context.getConnection().getPMetaData().getTable(index.getParentName().getString());
int tableOffset = table.getBucketNum() == null ? 0 : 1;
@@ -127,11 +142,22 @@ public class ProjectionCompiler {
}
for (int i = tableOffset; i < table.getColumns().size(); i++) {
PColumn tableColumn = table.getColumns().get(i);
- PColumn indexColumn = index.getColumn(IndexUtil.getIndexColumnName(tableColumn));
+ String indexColName = IndexUtil.getIndexColumnName(tableColumn);
+ PColumn indexColumn = index.getColumn(indexColName);
ColumnRef ref = new ColumnRef(tableRef,indexColumn.getPosition());
+ String colName = tableColumn.getName().getString();
+ if (resolveColumn) {
+ if (tableRef.getTableAlias() != null) {
+ ref = resolver.resolveColumn(null, tableRef.getTableAlias(), indexColName);
+ colName = SchemaUtil.getColumnName(tableRef.getTableAlias(), colName);
+ } else {
+ String schemaName = index.getSchemaName().getString();
+ ref = resolver.resolveColumn(schemaName.length() == 0 ? null : schemaName, index.getTableName().getString(), indexColName);
+ colName = SchemaUtil.getColumnName(table.getName().getString(), colName);
+ }
+ }
Expression expression = ref.newColumnExpression();
projectedExpressions.add(expression);
- String colName = tableColumn.getName().getString();
boolean isCaseSensitive = !SchemaUtil.normalizeIdentifier(colName).equals(colName);
ExpressionProjector projector = new ExpressionProjector(colName, table.getName().getString(), expression, isCaseSensitive);
projectedColumns.add(projector);
@@ -183,7 +209,8 @@ public class ProjectionCompiler {
// Setup projected columns in Scan
SelectClauseVisitor selectVisitor = new SelectClauseVisitor(context, groupBy);
List<ExpressionProjector> projectedColumns = new ArrayList<ExpressionProjector>();
- TableRef tableRef = context.getResolver().getTables().get(0);
+ ColumnResolver resolver = context.getResolver();
+ TableRef tableRef = context.getCurrentTable();
PTable table = tableRef.getTable();
boolean isWildcard = false;
Scan scan = context.getScan();
@@ -199,13 +226,23 @@ public class ProjectionCompiler {
}
isWildcard = true;
if (tableRef.getTable().getType() == PTableType.INDEX && ((WildcardParseNode)node).isRewrite()) {
- projectAllIndexColumns(context, tableRef, projectedExpressions, projectedColumns);
+ projectAllIndexColumns(context, tableRef, false, projectedExpressions, projectedColumns);
} else {
- projectAllTableColumns(context, tableRef, projectedExpressions, projectedColumns);
+ projectAllTableColumns(context, tableRef, false, projectedExpressions, projectedColumns);
+ }
+ } else if (node instanceof TableWildcardParseNode) {
+ TableName tName = ((TableWildcardParseNode) node).getTableName();
+ TableRef tRef = resolver.resolveTable(tName.getSchemaName(), tName.getTableName());
+ if (tRef.equals(tableRef)) {
+ isWildcard = true;
}
+ if (tRef.getTable().getType() == PTableType.INDEX && ((TableWildcardParseNode)node).isRewrite()) {
+ projectAllIndexColumns(context, tRef, true, projectedExpressions, projectedColumns);
+ } else {
+ projectAllTableColumns(context, tRef, true, projectedExpressions, projectedColumns);
+ }
} else if (node instanceof FamilyWildcardParseNode){
// Project everything for SELECT cf.*
- // TODO: support cf.* expressions for multiple tables the same way with *.
String cfName = ((FamilyWildcardParseNode) node).getName();
// Delay projecting to scan, as when any other column in the column family gets
// added to the scan, it overwrites that we want to project the entire column
@@ -252,7 +289,6 @@ public class ProjectionCompiler {
index++;
}
- table = context.getCurrentTable().getTable(); // switch to current table for scan projection
// TODO make estimatedByteSize more accurate by counting the joined columns.
int estimatedKeySize = table.getRowKeySchema().getEstimatedValueLength();
int estimatedByteSize = 0;
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/compile/QueryCompiler.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/compile/QueryCompiler.java b/phoenix-core/src/main/java/org/apache/phoenix/compile/QueryCompiler.java
index e264c0a..17e954e 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/QueryCompiler.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/QueryCompiler.java
@@ -144,17 +144,17 @@ public class QueryCompiler {
byte[] emptyByteArray = new byte[0];
List<JoinTable> joinTables = join.getJoinTables();
if (joinTables.isEmpty()) {
- ProjectedPTableWrapper projectedTable = join.createProjectedTable(join.getMainTable(), !asSubquery, join.getMainTableNode().isRewrite());
+ ProjectedPTableWrapper projectedTable = join.createProjectedTable(join.getMainTable(), !asSubquery);
ScanProjector.serializeProjectorIntoScan(context.getScan(), JoinCompiler.getScanProjector(projectedTable));
context.setCurrentTable(join.getMainTable());
- context.setResolver(JoinCompiler.getColumnResolver(projectedTable));
+ context.setResolver(join.getColumnResolver(projectedTable));
join.projectColumns(context.getScan(), join.getMainTable());
return compileSingleQuery(context, select, binds, null);
}
boolean[] starJoinVector = JoinCompiler.getStarJoinVector(join);
if (starJoinVector != null) {
- ProjectedPTableWrapper initialProjectedTable = join.createProjectedTable(join.getMainTable(), !asSubquery, join.getMainTableNode().isRewrite());
+ ProjectedPTableWrapper initialProjectedTable = join.createProjectedTable(join.getMainTable(), !asSubquery);
PTableWrapper projectedTable = initialProjectedTable;
int count = joinTables.size();
ImmutableBytesPtr[] joinIds = new ImmutableBytesPtr[count];
@@ -171,8 +171,8 @@ public class QueryCompiler {
SelectStatement subStatement = joinTable.getAsSubquery();
if (subStatement.getFrom().size() > 1)
throw new SQLFeatureNotSupportedException("Sub queries not supported.");
- ProjectedPTableWrapper subProjTable = join.createProjectedTable(joinTable.getTable(), false, joinTable.getTableNode().isRewrite());
- ColumnResolver resolver = JoinCompiler.getColumnResolver(subProjTable);
+ ProjectedPTableWrapper subProjTable = join.createProjectedTable(joinTable.getTable(), false);
+ ColumnResolver resolver = join.getColumnResolver(subProjTable);
Scan subScan = ScanUtil.newScan(scanCopy);
ScanProjector.serializeProjectorIntoScan(subScan, JoinCompiler.getScanProjector(subProjTable));
StatementContext subContext = new StatementContext(statement, resolver, binds, subScan);
@@ -190,7 +190,7 @@ public class QueryCompiler {
if (!starJoinVector[i]) {
needsProject = true;
}
- ColumnResolver leftResolver = starJoinVector[i] ? join.getOriginalResolver() : JoinCompiler.getColumnResolver(projectedTable);
+ ColumnResolver leftResolver = starJoinVector[i] ? join.getOriginalResolver() : join.getColumnResolver(projectedTable);
joinIds[i] = new ImmutableBytesPtr(emptyByteArray); // place-holder
Pair<List<Expression>, List<Expression>> joinConditions = joinTable.compileJoinConditions(context, leftResolver, resolver);
joinExpressions[i] = joinConditions.getFirst();
@@ -204,7 +204,7 @@ public class QueryCompiler {
ScanProjector.serializeProjectorIntoScan(context.getScan(), JoinCompiler.getScanProjector(initialProjectedTable));
}
context.setCurrentTable(join.getMainTable());
- context.setResolver(needsProject ? JoinCompiler.getColumnResolver(projectedTable) : join.getOriginalResolver());
+ context.setResolver(needsProject ? join.getColumnResolver(projectedTable) : join.getOriginalResolver());
join.projectColumns(context.getScan(), join.getMainTable());
BasicQueryPlan plan = compileSingleQuery(context, JoinCompiler.getSubqueryWithoutJoin(select, join), binds, parallelIteratorFactory);
Expression postJoinFilterExpression = join.compilePostFilterExpression(context);
@@ -226,7 +226,7 @@ public class QueryCompiler {
QueryPlan lhsPlan = compileJoinQuery(lhsCtx, lhs, binds, lhsJoin, true);
ColumnResolver lhsResolver = lhsCtx.getResolver();
PTableWrapper lhsProjTable = ((JoinedTableColumnResolver) (lhsResolver)).getPTableWrapper();
- ProjectedPTableWrapper rhsProjTable = join.createProjectedTable(lastJoinTable.getTable(), !asSubquery, lastJoinTable.getTableNode().isRewrite());
+ ProjectedPTableWrapper rhsProjTable = join.createProjectedTable(lastJoinTable.getTable(), !asSubquery);
ColumnResolver rhsResolver = join.getOriginalResolver();
ImmutableBytesPtr[] joinIds = new ImmutableBytesPtr[] {new ImmutableBytesPtr(emptyByteArray)};
Pair<List<Expression>, List<Expression>> joinConditions = lastJoinTable.compileJoinConditions(context, lhsResolver, rhsResolver);
@@ -236,7 +236,7 @@ public class QueryCompiler {
PTableWrapper projectedTable = JoinCompiler.mergeProjectedTables(rhsProjTable, lhsProjTable, type == JoinType.Inner);
ScanProjector.serializeProjectorIntoScan(context.getScan(), JoinCompiler.getScanProjector(rhsProjTable));
context.setCurrentTable(lastJoinTable.getTable());
- context.setResolver(JoinCompiler.getColumnResolver(projectedTable));
+ context.setResolver(join.getColumnResolver(projectedTable));
join.projectColumns(context.getScan(), lastJoinTable.getTable());
BasicQueryPlan rhsPlan = compileSingleQuery(context, rhs, binds, parallelIteratorFactory);
Expression postJoinFilterExpression = join.compilePostFilterExpression(context);
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/compile/StatementNormalizer.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/compile/StatementNormalizer.java b/phoenix-core/src/main/java/org/apache/phoenix/compile/StatementNormalizer.java
index 01e54a9..be22405 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/StatementNormalizer.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/StatementNormalizer.java
@@ -20,18 +20,29 @@
package org.apache.phoenix.compile;
import java.sql.SQLException;
+import java.sql.SQLFeatureNotSupportedException;
import java.util.List;
import com.google.common.collect.Lists;
+import org.apache.phoenix.parse.AliasedNode;
import org.apache.phoenix.parse.BetweenParseNode;
+import org.apache.phoenix.parse.BindTableNode;
import org.apache.phoenix.parse.ColumnParseNode;
import org.apache.phoenix.parse.ComparisonParseNode;
+import org.apache.phoenix.parse.DerivedTableNode;
+import org.apache.phoenix.parse.FamilyWildcardParseNode;
+import org.apache.phoenix.parse.JoinTableNode;
import org.apache.phoenix.parse.LessThanOrEqualParseNode;
+import org.apache.phoenix.parse.NamedTableNode;
import org.apache.phoenix.parse.ParseNode;
import org.apache.phoenix.parse.ParseNodeRewriter;
import org.apache.phoenix.parse.SelectStatement;
import org.apache.phoenix.parse.TableName;
+import org.apache.phoenix.parse.TableNode;
+import org.apache.phoenix.parse.TableNodeVisitor;
+import org.apache.phoenix.parse.TableWildcardParseNode;
+import org.apache.phoenix.parse.WildcardParseNode;
import org.apache.phoenix.util.SchemaUtil;
@@ -45,11 +56,11 @@ import org.apache.phoenix.util.SchemaUtil;
* @since 0.1
*/
public class StatementNormalizer extends ParseNodeRewriter {
- private boolean useFullNameForAlias;
+ private boolean multiTable;
- public StatementNormalizer(ColumnResolver resolver, int expectedAliasCount, boolean useFullNameForAlias) {
+ public StatementNormalizer(ColumnResolver resolver, int expectedAliasCount, boolean multiTable) {
super(resolver, expectedAliasCount);
- this.useFullNameForAlias = useFullNameForAlias;
+ this.multiTable = multiTable;
}
public static ParseNode normalize(ParseNode where, ColumnResolver resolver) throws SQLException {
@@ -65,8 +76,68 @@ public class StatementNormalizer extends ParseNodeRewriter {
* @throws SQLException
*/
public static SelectStatement normalize(SelectStatement statement, ColumnResolver resolver) throws SQLException {
- return rewrite(statement, new StatementNormalizer(resolver, statement.getSelect().size(), statement.getFrom().size() > 1));
+ List<TableNode> from = statement.getFrom();
+ boolean multiTable = from.size() > 1;
+ // Replace WildcardParse with a list of TableWildcardParseNode for multi-table queries
+ if (multiTable) {
+ List<AliasedNode> selectNodes = statement.getSelect();
+ List<AliasedNode> normSelectNodes = selectNodes;
+ for (int i = 0; i < selectNodes.size(); i++) {
+ AliasedNode aliasedNode = selectNodes.get(i);
+ ParseNode selectNode = aliasedNode.getNode();
+ if (selectNode == WildcardParseNode.INSTANCE) {
+ if (selectNodes == normSelectNodes) {
+ normSelectNodes = Lists.newArrayList(selectNodes.subList(0, i));
+ }
+ for (TableNode tNode : from) {
+ TableNameVisitor visitor = new TableNameVisitor();
+ tNode.accept(visitor);
+ TableWildcardParseNode node = NODE_FACTORY.tableWildcard(visitor.getTableName());
+ normSelectNodes.add(NODE_FACTORY.aliasedNode(null, node));
+ }
+ } else if (selectNodes != normSelectNodes) {
+ normSelectNodes.add(aliasedNode);
+ }
+ }
+ if (selectNodes != normSelectNodes) {
+ statement = NODE_FACTORY.select(statement.getFrom(), statement.getHint(), statement.isDistinct(),
+ normSelectNodes, statement.getWhere(), statement.getGroupBy(), statement.getHaving(), statement.getOrderBy(),
+ statement.getLimit(), statement.getBindCount(), statement.isAggregate());
+ }
+ }
+
+ return rewrite(statement, new StatementNormalizer(resolver, statement.getSelect().size(), multiTable));
}
+
+ private static class TableNameVisitor implements TableNodeVisitor {
+ private TableName tableName;
+
+ public TableName getTableName() {
+ return tableName;
+ }
+
+ @Override
+ public void visit(BindTableNode boundTableNode) throws SQLException {
+ tableName = boundTableNode.getAlias() == null ? boundTableNode.getName() : TableName.create(null, boundTableNode.getAlias());
+ }
+
+ @Override
+ public void visit(JoinTableNode joinNode) throws SQLException {
+ joinNode.getTable().accept(this);
+ }
+
+ @Override
+ public void visit(NamedTableNode namedTableNode)
+ throws SQLException {
+ tableName = namedTableNode.getAlias() == null ? namedTableNode.getName() : TableName.create(null, namedTableNode.getAlias());
+ }
+
+ @Override
+ public void visit(DerivedTableNode subselectNode)
+ throws SQLException {
+ throw new SQLFeatureNotSupportedException();
+ }
+ };
@Override
public ParseNode visitLeave(ComparisonParseNode node, List<ParseNode> nodes) throws SQLException {
@@ -93,7 +164,7 @@ public class StatementNormalizer extends ParseNodeRewriter {
@Override
public ParseNode visit(ColumnParseNode node) throws SQLException {
- if (useFullNameForAlias
+ if (multiTable
&& node.getAlias() != null
&& node.getTableName() != null
&& SchemaUtil.normalizeIdentifier(node.getAlias()).equals(node.getName())) {
@@ -103,5 +174,13 @@ public class StatementNormalizer extends ParseNodeRewriter {
}
return super.visit(node);
}
+
+ @Override
+ public ParseNode visit(FamilyWildcardParseNode node) throws SQLException {
+ if (!multiTable)
+ return super.visit(node);
+
+ return super.visit(NODE_FACTORY.tableWildcard(NODE_FACTORY.table(null, node.isCaseSensitive() ? '"' + node.getName() + '"' : node.getName())));
+ }
}
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/BindTableNode.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/BindTableNode.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/BindTableNode.java
index 4ea51a7..968c64c 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/parse/BindTableNode.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/BindTableNode.java
@@ -31,17 +31,9 @@ import java.sql.SQLException;
* @since 0.1
*/
public class BindTableNode extends ConcreteTableNode {
-
- public static BindTableNode create(String alias, TableName name, boolean isRewrite) {
- return new BindTableNode(alias, name, isRewrite);
- }
BindTableNode(String alias, TableName name) {
- this(alias, name, false);
- }
-
- BindTableNode(String alias, TableName name, boolean isRewrite) {
- super(alias, name, isRewrite);
+ super(alias, name);
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/ConcreteTableNode.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/ConcreteTableNode.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/ConcreteTableNode.java
index b110f2a..b6671b5 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/parse/ConcreteTableNode.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/ConcreteTableNode.java
@@ -31,8 +31,8 @@ import org.apache.phoenix.util.SchemaUtil;
public abstract class ConcreteTableNode extends TableNode {
private final TableName name;
- ConcreteTableNode(String alias, TableName name, boolean isRewrite) {
- super(SchemaUtil.normalizeIdentifier(alias), isRewrite);
+ ConcreteTableNode(String alias, TableName name) {
+ super(SchemaUtil.normalizeIdentifier(alias));
this.name = name;
}
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/DerivedTableNode.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/DerivedTableNode.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/DerivedTableNode.java
index 8d9383c..f1b5282 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/parse/DerivedTableNode.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/DerivedTableNode.java
@@ -21,6 +21,8 @@ package org.apache.phoenix.parse;
import java.sql.SQLException;
+import org.apache.phoenix.util.SchemaUtil;
+
/**
@@ -35,7 +37,7 @@ public class DerivedTableNode extends TableNode {
private final SelectStatement select;
DerivedTableNode(String alias, SelectStatement select) {
- super(alias);
+ super(SchemaUtil.normalizeIdentifier(alias));
this.select = select;
}
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/JoinTableNode.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/JoinTableNode.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/JoinTableNode.java
index 54840be..6a993c4 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/parse/JoinTableNode.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/JoinTableNode.java
@@ -38,7 +38,7 @@ public class JoinTableNode extends TableNode {
private final TableNode table;
JoinTableNode(JoinType type, ParseNode on, TableNode table) {
- super(table.getAlias(), table.isRewrite());
+ super(table.getAlias());
this.type = type;
this.on = on;
this.table = table;
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/NamedTableNode.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/NamedTableNode.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/NamedTableNode.java
index 86fdc94..7bc2bd6 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/parse/NamedTableNode.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/NamedTableNode.java
@@ -38,22 +38,14 @@ public class NamedTableNode extends ConcreteTableNode {
public static NamedTableNode create (String alias, TableName name, List<ColumnDef> dynColumns) {
return new NamedTableNode(alias, name, dynColumns);
}
-
- public static NamedTableNode create (String alias, TableName name, List<ColumnDef> dynColumns, boolean isRewrite) {
- return new NamedTableNode(alias, name, dynColumns, isRewrite);
- }
NamedTableNode(String alias, TableName name) {
- super(alias, name, false);
+ super(alias, name);
dynColumns = Collections.<ColumnDef> emptyList();
}
NamedTableNode(String alias, TableName name, List<ColumnDef> dynColumns) {
- this(alias, name, dynColumns, false);
- }
-
- NamedTableNode(String alias, TableName name, List<ColumnDef> dynColumns, boolean isRewrite) {
- super(alias, name, isRewrite);
+ super(alias, name);
if (dynColumns != null) {
this.dynColumns = ImmutableList.copyOf(dynColumns);
} else {
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeFactory.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeFactory.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeFactory.java
index 7b7589f..dc0f586 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeFactory.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeFactory.java
@@ -208,6 +208,10 @@ public class ParseNodeFactory {
public FamilyWildcardParseNode family(String familyName){
return new FamilyWildcardParseNode(familyName, false);
}
+
+ public TableWildcardParseNode tableWildcard(TableName tableName) {
+ return new TableWildcardParseNode(tableName, false);
+ }
public WildcardParseNode wildcard() {
return WildcardParseNode.INSTANCE;
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeRewriter.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeRewriter.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeRewriter.java
index 20e8c74..8519866 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeRewriter.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeRewriter.java
@@ -420,6 +420,11 @@ public class ParseNodeRewriter extends TraverseAllParseNodeVisitor<ParseNode> {
}
@Override
+ public ParseNode visit(TableWildcardParseNode node) throws SQLException {
+ return node;
+ }
+
+ @Override
public ParseNode visit(FamilyWildcardParseNode node) throws SQLException {
return node;
}
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeVisitor.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeVisitor.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeVisitor.java
index 38eb2fa..b8511ed 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeVisitor.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/ParseNodeVisitor.java
@@ -86,7 +86,8 @@ public interface ParseNodeVisitor<E> {
public E visit(ColumnParseNode node) throws SQLException;
public E visit(LiteralParseNode node) throws SQLException;
public E visit(BindParseNode node) throws SQLException;
- public E visit(WildcardParseNode node) throws SQLException;
+ public E visit(WildcardParseNode node) throws SQLException;
+ public E visit(TableWildcardParseNode node) throws SQLException;
public E visit(FamilyWildcardParseNode node) throws SQLException;
public E visit(ParseNode node) throws SQLException;
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/TableNode.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/TableNode.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/TableNode.java
index 8a592ae..8130d65 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/parse/TableNode.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/TableNode.java
@@ -32,24 +32,14 @@ import java.sql.SQLException;
*/
public abstract class TableNode {
private final String alias;
- private final boolean isRewrite;
TableNode(String alias) {
- this(alias, false);
- }
-
- TableNode(String alias, boolean isRewrite) {
this.alias = alias;
- this.isRewrite = isRewrite;
}
public String getAlias() {
return alias;
}
-
- public boolean isRewrite() {
- return isRewrite;
- }
public abstract void accept(TableNodeVisitor visitor) throws SQLException;
}
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/TableWildcardParseNode.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/TableWildcardParseNode.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/TableWildcardParseNode.java
new file mode 100644
index 0000000..af72b15
--- /dev/null
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/TableWildcardParseNode.java
@@ -0,0 +1,52 @@
+/*
+ * Copyright 2014 The Apache Software Foundation
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.phoenix.parse;
+
+import java.sql.SQLException;
+
+public class TableWildcardParseNode extends NamedParseNode {
+ private final TableName tableName;
+ private final boolean isRewrite;
+
+ public static TableWildcardParseNode create(TableName tableName, boolean isRewrite) {
+ return new TableWildcardParseNode(tableName, isRewrite);
+ }
+
+ TableWildcardParseNode(TableName tableName, boolean isRewrite) {
+ super(tableName.toString());
+ this.tableName = tableName;
+ this.isRewrite = isRewrite;
+ }
+
+ public TableName getTableName() {
+ return tableName;
+ }
+
+ public boolean isRewrite() {
+ return isRewrite;
+ }
+
+ @Override
+ public <T> T accept(ParseNodeVisitor<T> visitor) throws SQLException {
+ return visitor.visit(this);
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/TraverseAllParseNodeVisitor.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/TraverseAllParseNodeVisitor.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/TraverseAllParseNodeVisitor.java
index 5e85f9d..14f9784 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/parse/TraverseAllParseNodeVisitor.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/TraverseAllParseNodeVisitor.java
@@ -132,6 +132,11 @@ public abstract class TraverseAllParseNodeVisitor<T> extends BaseParseNodeVisito
}
@Override
+ public T visit(TableWildcardParseNode node) throws SQLException {
+ return null;
+ }
+
+ @Override
public T visit(FamilyWildcardParseNode node) throws SQLException {
return null;
}
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/TraverseNoParseNodeVisitor.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/TraverseNoParseNodeVisitor.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/TraverseNoParseNodeVisitor.java
index f64fb97..cc38562 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/parse/TraverseNoParseNodeVisitor.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/TraverseNoParseNodeVisitor.java
@@ -132,6 +132,11 @@ public abstract class TraverseNoParseNodeVisitor<T> extends BaseParseNodeVisitor
}
@Override
+ public T visit(TableWildcardParseNode node) throws SQLException {
+ return null;
+ }
+
+ @Override
public T visit(FamilyWildcardParseNode node) throws SQLException {
return null;
}
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/main/java/org/apache/phoenix/parse/UnsupportedAllParseNodeVisitor.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/parse/UnsupportedAllParseNodeVisitor.java b/phoenix-core/src/main/java/org/apache/phoenix/parse/UnsupportedAllParseNodeVisitor.java
index b408f91..0cb1b31 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/parse/UnsupportedAllParseNodeVisitor.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/parse/UnsupportedAllParseNodeVisitor.java
@@ -68,6 +68,11 @@ abstract public class UnsupportedAllParseNodeVisitor<E> extends BaseParseNodeVis
}
@Override
+ public E visit(TableWildcardParseNode node) throws SQLException {
+ throw new SQLFeatureNotSupportedException(node.toString());
+ }
+
+ @Override
public E visit(FamilyWildcardParseNode node) throws SQLException {
throw new SQLFeatureNotSupportedException(node.toString());
}
http://git-wip-us.apache.org/repos/asf/incubator-phoenix/blob/7ac4ee2d/phoenix-core/src/test/java/org/apache/phoenix/compile/JoinQueryCompileTest.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/compile/JoinQueryCompileTest.java b/phoenix-core/src/test/java/org/apache/phoenix/compile/JoinQueryCompileTest.java
index b515697..63ddcdc 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/compile/JoinQueryCompileTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/compile/JoinQueryCompileTest.java
@@ -19,14 +19,14 @@
*/
package org.apache.phoenix.compile;
-import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE_NORMALIZED;
-import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE_NORMALIZED;
-import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE_NORMALIZED;
-import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE;
-import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE_NORMALIZED;
+import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_CUSTOMER_TABLE_DISPLAY_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_ITEM_TABLE_DISPLAY_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_ORDER_TABLE_DISPLAY_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE_FULL_NAME;
+import static org.apache.phoenix.util.TestUtil.JOIN_SUPPLIER_TABLE_DISPLAY_NAME;
import static org.apache.phoenix.util.TestUtil.TEST_PROPERTIES;
import static org.junit.Assert.assertEquals;
@@ -55,32 +55,32 @@ public class JoinQueryCompileTest extends BaseConnectionlessQueryTest {
@Test
public void testExplainPlan() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
- String query = "EXPLAIN SELECT s.\"supplier_id\", \"order_id\", c.name, i.name, quantity, o.date FROM " + JOIN_ORDER_TABLE + " o LEFT JOIN "
- + JOIN_CUSTOMER_TABLE + " c ON o.\"customer_id\" = c.\"customer_id\" AND c.name LIKE 'C%' LEFT JOIN "
- + JOIN_ITEM_TABLE + " i ON o.\"item_id\" = i.\"item_id\" RIGHT JOIN "
- + JOIN_SUPPLIER_TABLE + " s ON s.\"supplier_id\" = i.\"supplier_id\" WHERE i.name LIKE 'T%'";
+ String query = "EXPLAIN SELECT s.\"supplier_id\", \"order_id\", c.name, i.name, quantity, o.date FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o LEFT JOIN "
+ + JOIN_CUSTOMER_TABLE_FULL_NAME + " c ON o.\"customer_id\" = c.\"customer_id\" AND c.name LIKE 'C%' LEFT JOIN "
+ + JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" RIGHT JOIN "
+ + JOIN_SUPPLIER_TABLE_FULL_NAME + " s ON s.\"supplier_id\" = i.\"supplier_id\" WHERE i.name LIKE 'T%'";
ResultSet rs = conn.createStatement().executeQuery(query);
assertEquals(
- "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_NORMALIZED + "\n" +
+ "CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_SUPPLIER_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY FIRST KEY ONLY\n" +
" PARALLEL EQUI-JOIN 1 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_NORMALIZED + "\n" +
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ORDER_TABLE_DISPLAY_NAME + "\n" +
" PARALLEL EQUI-JOIN 2 HASH TABLES:\n" +
" BUILD HASH TABLE 0\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_CUSTOMER_TABLE_NORMALIZED + "\n" +
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_CUSTOMER_TABLE_DISPLAY_NAME + "\n" +
" SERVER FILTER BY NAME LIKE 'C%'\n" +
" BUILD HASH TABLE 1\n" +
- " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_NORMALIZED + "\n" +
+ " CLIENT PARALLEL 1-WAY FULL SCAN OVER " + JOIN_ITEM_TABLE_DISPLAY_NAME + "\n" +
" AFTER-JOIN SERVER FILTER BY I.NAME LIKE 'T%'", QueryUtil.getExplainPlan(rs));
}
@Test
public void testWhereClauseOptimization() throws Exception {
PhoenixConnection pconn = DriverManager.getConnection(getUrl(), TEST_PROPERTIES).unwrap(PhoenixConnection.class);
- String queryTemplate = "SELECT t1.\"item_id\", t2.\"item_id\", t3.\"item_id\" FROM " + JOIN_ITEM_TABLE + " t1 "
- + "%s JOIN " + JOIN_ITEM_TABLE + " t2 ON t1.\"item_id\" = t2.\"item_id\" "
- + "%s JOIN " + JOIN_ITEM_TABLE + " t3 ON t1.\"item_id\" = t3.\"item_id\" "
+ String queryTemplate = "SELECT t1.\"item_id\", t2.\"item_id\", t3.\"item_id\" FROM " + JOIN_ITEM_TABLE_FULL_NAME + " t1 "
+ + "%s JOIN " + JOIN_ITEM_TABLE_FULL_NAME + " t2 ON t1.\"item_id\" = t2.\"item_id\" "
+ + "%s JOIN " + JOIN_ITEM_TABLE_FULL_NAME + " t3 ON t1.\"item_id\" = t3.\"item_id\" "
+ "WHERE t1.\"item_id\" = '0000000001' AND t2.\"item_id\" = '0000000002' AND t3.\"item_id\" = '0000000003'";
String query = String.format(queryTemplate, "INNER", "INNER");