[
https://issues.apache.org/jira/browse/PHOENIX-106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13920378#comment-13920378
]
Hudson commented on PHOENIX-106:
--------------------------------
SUCCESS: Integrated in Apache Phoenix - Branch:master #106 (See
[https://builds.apache.org/job/Phoenix/106/])
PHOENIX-106 NPE when adding dynamic columns to a salted table (JamesTaylor)
(jamestaylor: rev b355c2a08f92763f1d7272f2a2300e024e70d756)
* phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
*
phoenix-core/src/test/java/org/apache/phoenix/end2end/UpsertSelectAutoCommitTest.java
> NPE when adding dynamic columns to a salted table
> -------------------------------------------------
>
> Key: PHOENIX-106
> URL: https://issues.apache.org/jira/browse/PHOENIX-106
> Project: Phoenix
> Issue Type: Bug
> Affects Versions: 3.0.0
> Reporter: James Taylor
> Assignee: James Taylor
> Fix For: 3.0.0
>
> Attachments: patch.diff
>
>
> Thanks for the test, [~samarthjain].
> @Test
> public void testDynamicUpsertSelect() throws Exception {
> Connection conn = DriverManager.getConnection(getUrl());
> String cursorDDL = " CREATE TABLE IF NOT EXISTS CURSOR
> (ORGANIZATION_ID VARCHAR(15) NOT NULL, \n"
> + "QUERY_ID VARCHAR(15) NOT NULL, \n"
> + "CURSOR_ORDER UNSIGNED_LONG NOT NULL, \n"
> + "CONSTRAINT API_HBASE_CURSOR_STORAGE_PK PRIMARY KEY
> (ORGANIZATION_ID, QUERY_ID, CURSOR_ORDER))\n"
> + "SALT_BUCKETS = 4";
> conn.createStatement().execute(cursorDDL);
>
> String dataTableDDL = "CREATE TABLE IF NOT EXISTS PLINYTEST" +
> "(" +
> "ORGANIZATION_ID CHAR(15) NOT NULL, " +
> "PLINY_ID CHAR(15) NOT NULL, " +
> "CREATED_DATE DATE NOT NULL, " +
> "TEXT VARCHAR, " +
> "CONSTRAINT PK PRIMARY KEY " +
> "(" +
> "ORGANIZATION_ID, " +
> "PLINY_ID, " +
> "CREATED_DATE" +
> ")" +
> ")";
>
> conn.createStatement().execute(dataTableDDL);
> PreparedStatement stmt = null;
> String upsert = "UPSERT INTO PLINYTEST VALUES (?, ?, ?, ?)";
> stmt = conn.prepareStatement(upsert);
> stmt.setString(1, getOrganizationId());
> stmt.setString(2, "aaaaaaaaaaaaaaa");
> stmt.setDate(3, new Date(System.currentTimeMillis()));
> stmt.setString(4, "text");
> stmt.executeUpdate();
> conn.commit();
>
> String upsertSelect = "UPSERT INTO CURSOR (ORGANIZATION_ID, QUERY_ID,
> CURSOR_ORDER, PLINY_ID CHAR(15),CREATED_DATE DATE) SELECT ?, ?, ?, PLINY_ID,
> CREATED_DATE FROM PLINYTEST WHERE ORGANIZATION_ID = ?";
> stmt = conn.prepareStatement(upsertSelect);
> String orgId = getOrganizationId();
> stmt.setString(1, orgId);
> stmt.setString(2, "queryqueryquery");
> stmt.setInt(3, 1);
> stmt.setString(4, orgId);
> stmt.executeUpdate();
> conn.commit();
> }
--
This message was sent by Atlassian JIRA
(v6.2#6252)
