[
https://issues.apache.org/jira/browse/PHOENIX-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14169077#comment-14169077
]
Hudson commented on PHOENIX-1337:
---------------------------------
FAILURE: Integrated in Phoenix | 3.0 | Hadoop1 #251 (See
[https://builds.apache.org/job/Phoenix-3.0-hadoop1/251/])
PHOENIX-1337 Unpadded fixed length tenant ID causes erroneous results
(ramkrishna: rev ed3e3f55f1e9d91cec8a02882ae4c61ced9e49f0)
* phoenix-core/src/main/java/org/apache/phoenix/compile/ProjectionCompiler.java
* phoenix-core/src/main/java/org/apache/phoenix/compile/WhereOptimizer.java
* phoenix-core/src/main/java/org/apache/phoenix/compile/UpsertCompiler.java
* phoenix-core/src/main/java/org/apache/phoenix/compile/DeleteCompiler.java
*
phoenix-core/src/it/java/org/apache/phoenix/end2end/TenantSpecificViewIndexIT.java
* phoenix-core/src/main/java/org/apache/phoenix/util/ScanUtil.java
> Unpadded fixed length tenant ID causes erroneous results
> --------------------------------------------------------
>
> Key: PHOENIX-1337
> URL: https://issues.apache.org/jira/browse/PHOENIX-1337
> Project: Phoenix
> Issue Type: Bug
> Affects Versions: 5.0.0, 4.1
> Reporter: Samarth Jain
> Assignee: James Taylor
> Priority: Critical
> Fix For: 4.2, 3.2
>
>
> The test fails both on 4.1.0 and master. The test can be added in any class
> that extends our BaseHBaseManagedTimeTest.
> {code}
> @Test
> public void testQueryingUsingTenantSpecific() throws Exception {
> String tenantId1 = "org1";
> String tenantId2 = "org2";
> String ddl = "CREATE TABLE T (tenantId char(15) NOT NULL, pk1 varchar
> NOT NULL, pk2 INTEGER NOT NULL, val1 VARCHAR CONSTRAINT pk primary key
> (tenantId,pk1,pk2)) MULTI_TENANT = true";
> Connection conn = DriverManager.getConnection(getUrl());
> conn.createStatement().execute(ddl);
> String dml = "UPSERT INTO T (tenantId, pk1, pk2, val1) VALUES (?, ?,
> ?, ?)";
> PreparedStatement stmt = conn.prepareStatement(dml);
>
> // insert two rows in table T. One for tenantId1 and other for
> tenantId2.
> stmt.setString(1, tenantId1);
> stmt.setString(2, "pk1b");
> stmt.setInt(3, 100);
> stmt.setString(4, "value1");
> stmt.executeUpdate();
>
> stmt.setString(1, tenantId2);
> stmt.setString(2, "pk1b");
> stmt.setInt(3, 200);
> stmt.setString(4, "value2");
> stmt.executeUpdate();
> conn.commit();
>
> // get a tenant specific url.
> String tenantUrl = getUrl() + ';' + TENANT_ID_ATTRIB + '=' +
> tenantId1;
> Connection tenantConn = DriverManager.getConnection(tenantUrl);
>
> // create a tenant specific view.
> tenantConn.createStatement().execute("CREATE VIEW V AS select * from
> T");
> String query = "SELECT val1 FROM V WHERE pk1 = ?";
>
> // using the tenant connection query the view.
> PreparedStatement stmt2 = tenantConn.prepareStatement(query);
> stmt2.setString(1, "pk1b"); // for tenantId1 the row inserted has pk1
> = "pk1b"
> ResultSet rs = stmt2.executeQuery();
> assertTrue(rs.next());
> assertEquals("value1", rs.getString(1));
> assertFalse("No other rows should have been returned for the tenant",
> rs.next()); // should have just returned one record since for org1 we have
> only one row.
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
