Return-Path: X-Original-To: apmail-phoenix-commits-archive@minotaur.apache.org Delivered-To: apmail-phoenix-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id DB85E1761E for ; Tue, 7 Oct 2014 06:34:47 +0000 (UTC) Received: (qmail 14600 invoked by uid 500); 7 Oct 2014 06:34:47 -0000 Delivered-To: apmail-phoenix-commits-archive@phoenix.apache.org Received: (qmail 14560 invoked by uid 500); 7 Oct 2014 06:34:47 -0000 Mailing-List: contact commits-help@phoenix.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@phoenix.apache.org Delivered-To: mailing list commits@phoenix.apache.org Received: (qmail 14551 invoked by uid 99); 7 Oct 2014 06:34:47 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 07 Oct 2014 06:34:47 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 6CDFA8B4CBD; Tue, 7 Oct 2014 06:34:47 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: ravimagham@apache.org To: commits@phoenix.apache.org Message-Id: X-Mailer: ASF-Git Admin Mailer Subject: git commit: PHOENIX-1317-Test on loading data from Index table Date: Tue, 7 Oct 2014 06:34:47 +0000 (UTC) Repository: phoenix Updated Branches: refs/heads/4.0 5668817de -> f21bf2a05 PHOENIX-1317-Test on loading data from Index table Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/f21bf2a0 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/f21bf2a0 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/f21bf2a0 Branch: refs/heads/4.0 Commit: f21bf2a0584453b0247e03041d2acdae76531d1b Parents: 5668817 Author: ravimagham Authored: Mon Oct 6 23:34:05 2014 -0700 Committer: ravimagham Committed: Mon Oct 6 23:34:05 2014 -0700 ---------------------------------------------------------------------- .../phoenix/pig/PhoenixHBaseLoaderIT.java | 40 +++++++++++++++++++- 1 file changed, 39 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/f21bf2a0/phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java ---------------------------------------------------------------------- diff --git a/phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java b/phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java index 6db97f5..7c4306f 100644 --- a/phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java +++ b/phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java @@ -72,6 +72,7 @@ public class PhoenixHBaseLoaderIT { private static final Log LOG = LogFactory.getLog(PhoenixHBaseLoaderIT.class); private static final String SCHEMA_NAME = "T"; private static final String TABLE_NAME = "A"; + private static final String INDEX_NAME = "I"; private static final String TABLE_FULL_NAME = SchemaUtil.getTableName(SCHEMA_NAME, TABLE_NAME); private static HBaseTestingUtility hbaseTestUtil; private static String zkQuorum; @@ -564,6 +565,43 @@ public class PhoenixHBaseLoaderIT { } } + + @Test + public void testDataFromIndexTable() throws Exception { + try { + //create the table + String ddl = "CREATE TABLE " + TABLE_NAME + + " (ID INTEGER NOT NULL, NAME VARCHAR NOT NULL, EMPLID INTEGER CONSTRAINT pk PRIMARY KEY (ID, NAME)) IMMUTABLE_ROWS=true"; + + conn.createStatement().execute(ddl); + + //create a index table + String indexDdl = " CREATE INDEX " + INDEX_NAME + " ON " + TABLE_NAME + " (EMPLID) INCLUDE (NAME) "; + conn.createStatement().execute(indexDdl); + + //upsert the data. + final String dml = "UPSERT INTO " + TABLE_NAME + " VALUES(?,?,?)"; + PreparedStatement stmt = conn.prepareStatement(dml); + int rows = 20; + for(int i = 0 ; i < rows; i++) { + stmt.setInt(1, i); + stmt.setString(2, "a"+i); + stmt.setInt(3, i * 5); + stmt.execute(); + } + conn.commit(); + pigServer.registerQuery("A = load 'hbase://query/SELECT NAME , EMPLID FROM A WHERE EMPLID = 25 ' using " + PhoenixHBaseLoader.class.getName() + "('"+zkQuorum + "') ;"); + Iterator iterator = pigServer.openIterator("A"); + while (iterator.hasNext()) { + Tuple tuple = iterator.next(); + assertEquals("a5", tuple.get(0)); + assertEquals(25, tuple.get(1)); + } + } finally { + dropTable(TABLE_NAME); + dropTable(INDEX_NAME); + } + } @After public void tearDown() throws Exception { @@ -574,7 +612,7 @@ public class PhoenixHBaseLoaderIT { private void dropTable(String tableFullName) throws SQLException { Preconditions.checkNotNull(conn); - conn.createStatement().execute(String.format("DROP TABLE %s",tableFullName)); + conn.createStatement().execute(String.format("DROP TABLE IF EXISTS %s",tableFullName)); } @AfterClass