[
https://issues.apache.org/jira/browse/PHOENIX-6202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swaroopa Kadam updated PHOENIX-6202:
------------------------------------
Description:
{code:java}
@Test
public void testGlobalAddColumns() throws Exception {
Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); try (Connection
conn = DriverManager.getConnection(getUrl(), props))
{ conn.setAutoCommit(true); String tableName = "TBL_" + generateUniqueName();
String idxName = "IND_" + generateUniqueName(); String baseTableDDL = "CREATE
TABLE " + tableName + " (PK1 VARCHAR NOT NULL, V1 VARCHAR, V2 CHAR(15)
CONSTRAINT NAME_PK PRIMARY KEY(PK1)) ";
conn.createStatement().execute(baseTableDDL); String indexDDL = "CREATE INDEX "
+ idxName + " ON " + tableName + " (PK1) include (V1, V2)
";//IMMUTABLE_STORAGE_SCHEME=SINGLE_CELL_ARRAY_WITH_OFFSETS,
COLUMN_ENCODED_BYTES=2"; conn.createStatement().execute(indexDDL); String
upsert = "UPSERT INTO " + tableName + " (PK1, V1, V2) VALUES ('PK1', 'V1',
'V2')"; conn.createStatement().executeUpdate(upsert); conn.commit();
dumpTable(idxName); String alterTable = "ALTER TABLE " + tableName + " ADD V3
VARCHAR CASCADE INDEX ALL"; conn.createStatement().execute(alterTable); String
upsert2 = "UPSERT INTO " + tableName + " (PK1, V1, V2,V3) VALUES ('PK2', 'V1',
'V2', 'V3')"; conn.createStatement().executeUpdate(upsert2); conn.commit();
dumpTable(idxName); String selectFromIndex = "SELECT PK1, V3, V1, V2 FROM " +
tableName + " where V1='V1' AND V2='V2'"; ResultSet rs =
conn.createStatement().executeQuery("EXPLAIN " + selectFromIndex); String
actualExplainPlan = QueryUtil.getExplainPlan(rs);
assertTrue(actualExplainPlan.contains(idxName)); rs =
conn.createStatement().executeQuery(selectFromIndex); assertTrue(rs.next());
assertEquals("PK1", rs.getString(1)); assertTrue(rs.next());
assertEquals("PK2", rs.getString(1)); assertEquals("V3", rs.getString(2)); }
}
public static void dumpTable(Table hTable) {
try {
Scan scan = new Scan();
scan.setRaw(true);
scan.setMaxVersions();
System.out.println("Table Name : " + hTable.getName().getNameAsString());
ResultScanner scanner = hTable.getScanner(scan);
for (Result result = scanner.next(); result != null; result = scanner.next()) {
for (Cell cell : result.rawCells())
{ String cellString = cell.toString(); System.out.println(cellString + " value
: " + Bytes.toStringBinary(CellUtil.cloneValue(cell))); }
}
} catch (Exception e) {
//ignore
}
}
{code}
output:
PK1/0:\x00\x00\x00\x00/1603217119002/Put/vlen=1/seqid=0 ****** value : \x01
PK1/0:\x80\x0B/1603217119002/Put/vlen=2/seqid=0 ****** value : V1
PK1/0:\x80\x0C/1603217119002/Put/vlen=15/seqid=0 ****** value : V2
PK2\x00V3/0:\x00\x00\x00\x00/1603217125595/Put/vlen=1/seqid=0 ****** value :
\x01
PK2\x00V3/0:\x80\x0B/1603217125595/Put/vlen=2/seqid=0 ****** value : V1
PK2\x00V3/0:\x80\x0C/1603217125595/Put/vlen=15/seqid=0 ****** value : V2
was:
@Test
public void testGlobalAddColumns() throws Exception {
Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); try
(Connection conn = DriverManager.getConnection(getUrl(), props)) {
conn.setAutoCommit(true); String tableName = "TBL_" +
generateUniqueName();
String idxName = "IND_" + generateUniqueName(); String
baseTableDDL = "CREATE TABLE " + tableName + " (PK1 VARCHAR NOT NULL, V1
VARCHAR, V2 CHAR(15) CONSTRAINT NAME_PK PRIMARY KEY(PK1)) ";
conn.createStatement().execute(baseTableDDL); String indexDDL =
"CREATE INDEX " + idxName + " ON " + tableName + " (PK1) include (V1, V2)
";//IMMUTABLE_STORAGE_SCHEME=SINGLE_CELL_ARRAY_WITH_OFFSETS,
COLUMN_ENCODED_BYTES=2";
conn.createStatement().execute(indexDDL); String upsert =
"UPSERT INTO " + tableName + " (PK1, V1, V2) VALUES ('PK1', 'V1', 'V2')";
conn.createStatement().executeUpdate(upsert);
conn.commit(); dumpTable(idxName); String alterTable =
"ALTER TABLE " + tableName + " ADD V3 VARCHAR CASCADE INDEX ALL";
conn.createStatement().execute(alterTable); String upsert2 =
"UPSERT INTO " + tableName + " (PK1, V1, V2,V3) VALUES ('PK2', 'V1', 'V2',
'V3')"; conn.createStatement().executeUpdate(upsert2);
conn.commit(); dumpTable(idxName); String selectFromIndex
= "SELECT PK1, V3, V1, V2 FROM " + tableName + " where V1='V1' AND V2='V2'";
ResultSet rs = conn.createStatement().executeQuery("EXPLAIN " +
selectFromIndex);
String actualExplainPlan = QueryUtil.getExplainPlan(rs);
assertTrue(actualExplainPlan.contains(idxName)); rs =
conn.createStatement().executeQuery(selectFromIndex);
assertTrue(rs.next());
assertEquals("PK1", rs.getString(1));
assertTrue(rs.next());
assertEquals("PK2", rs.getString(1));
assertEquals("V3", rs.getString(2));
}
}
public static void dumpTable(Table hTable) \{
try {
Scan scan = new Scan();
scan.setRaw(true);
scan.setMaxVersions();
System.out.println("Table Name : " +
hTable.getName().getNameAsString());
ResultScanner scanner = hTable.getScanner(scan);
for (Result result = scanner.next(); result != null; result =
scanner.next()) {
for (Cell cell : result.rawCells()) {
String cellString = cell.toString();
System.out.println(cellString + " value : " +
Bytes.toStringBinary(CellUtil.cloneValue(cell)));
}
}
} catch (Exception e) \{
//ignore
}
}
output:
PK1/0:\x00\x00\x00\x00/1603217119002/Put/vlen=1/seqid=0 ****** value : \x01
PK1/0:\x80\x0B/1603217119002/Put/vlen=2/seqid=0 ****** value : V1
PK1/0:\x80\x0C/1603217119002/Put/vlen=15/seqid=0 ****** value : V2
PK2\x00V3/0:\x00\x00\x00\x00/1603217125595/Put/vlen=1/seqid=0 ****** value :
\x01
PK2\x00V3/0:\x80\x0B/1603217125595/Put/vlen=2/seqid=0 ****** value : V1
PK2\x00V3/0:\x80\x0C/1603217125595/Put/vlen=15/seqid=0 ****** value : V2
> New column in index gets added as PK with CASCADE INDEX
> -------------------------------------------------------
>
> Key: PHOENIX-6202
> URL: https://issues.apache.org/jira/browse/PHOENIX-6202
> Project: Phoenix
> Issue Type: Improvement
> Reporter: Swaroopa Kadam
> Assignee: Swaroopa Kadam
> Priority: Major
>
>
> {code:java}
> @Test
> public void testGlobalAddColumns() throws Exception {
> Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); try (Connection
> conn = DriverManager.getConnection(getUrl(), props))
> { conn.setAutoCommit(true); String tableName = "TBL_" + generateUniqueName();
> String idxName = "IND_" + generateUniqueName(); String baseTableDDL = "CREATE
> TABLE " + tableName + " (PK1 VARCHAR NOT NULL, V1 VARCHAR, V2 CHAR(15)
> CONSTRAINT NAME_PK PRIMARY KEY(PK1)) ";
> conn.createStatement().execute(baseTableDDL); String indexDDL = "CREATE INDEX
> " + idxName + " ON " + tableName + " (PK1) include (V1, V2)
> ";//IMMUTABLE_STORAGE_SCHEME=SINGLE_CELL_ARRAY_WITH_OFFSETS,
> COLUMN_ENCODED_BYTES=2"; conn.createStatement().execute(indexDDL); String
> upsert = "UPSERT INTO " + tableName + " (PK1, V1, V2) VALUES ('PK1', 'V1',
> 'V2')"; conn.createStatement().executeUpdate(upsert); conn.commit();
> dumpTable(idxName); String alterTable = "ALTER TABLE " + tableName + " ADD V3
> VARCHAR CASCADE INDEX ALL"; conn.createStatement().execute(alterTable);
> String upsert2 = "UPSERT INTO " + tableName + " (PK1, V1, V2,V3) VALUES
> ('PK2', 'V1', 'V2', 'V3')"; conn.createStatement().executeUpdate(upsert2);
> conn.commit(); dumpTable(idxName); String selectFromIndex = "SELECT PK1, V3,
> V1, V2 FROM " + tableName + " where V1='V1' AND V2='V2'"; ResultSet rs =
> conn.createStatement().executeQuery("EXPLAIN " + selectFromIndex); String
> actualExplainPlan = QueryUtil.getExplainPlan(rs);
> assertTrue(actualExplainPlan.contains(idxName)); rs =
> conn.createStatement().executeQuery(selectFromIndex); assertTrue(rs.next());
> assertEquals("PK1", rs.getString(1)); assertTrue(rs.next());
> assertEquals("PK2", rs.getString(1)); assertEquals("V3", rs.getString(2)); }
> }
> public static void dumpTable(Table hTable) {
> try {
> Scan scan = new Scan();
> scan.setRaw(true);
> scan.setMaxVersions();
> System.out.println("Table Name : " + hTable.getName().getNameAsString());
> ResultScanner scanner = hTable.getScanner(scan);
> for (Result result = scanner.next(); result != null; result =
> scanner.next()) {
> for (Cell cell : result.rawCells())
> { String cellString = cell.toString(); System.out.println(cellString + "
> value : " + Bytes.toStringBinary(CellUtil.cloneValue(cell))); }
> }
> } catch (Exception e) {
> //ignore
> }
> }
> {code}
>
>
> output:
>
> PK1/0:\x00\x00\x00\x00/1603217119002/Put/vlen=1/seqid=0 ****** value : \x01
> PK1/0:\x80\x0B/1603217119002/Put/vlen=2/seqid=0 ****** value : V1
> PK1/0:\x80\x0C/1603217119002/Put/vlen=15/seqid=0 ****** value : V2
> PK2\x00V3/0:\x00\x00\x00\x00/1603217125595/Put/vlen=1/seqid=0 ****** value :
> \x01
> PK2\x00V3/0:\x80\x0B/1603217125595/Put/vlen=2/seqid=0 ****** value : V1
> PK2\x00V3/0:\x80\x0C/1603217125595/Put/vlen=15/seqid=0 ****** value : V2
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
