[jira] [Created] (PHOENIX-5434) IndexTool rebuild doesn't work if # of rows in base table/view > index table

[Swaroopa Kadam (JIRA)]

Swaroopa Kadam created PHOENIX-5434:
---------------------------------------

             Summary: IndexTool rebuild doesn't work if # of rows in base 
table/view > index table
                 Key: PHOENIX-5434
                 URL: https://issues.apache.org/jira/browse/PHOENIX-5434
             Project: Phoenix
          Issue Type: Bug
    Affects Versions: 4.14.2, 5.0.0
            Reporter: Swaroopa Kadam
            Assignee: Swaroopa Kadam
             Fix For: 4.15.0, 4.14.3


{code:java}
@Test
public void testIndexRebuildWithNoIndexRows() throws Throwable {

    String baseTable = generateUniqueName();
    String viewName = generateUniqueName();
    Connection conn = null;
    try {
        conn = DriverManager.getConnection(getUrl());
        conn.setAutoCommit(true);

        String ddlFormat =
                "CREATE TABLE IF NOT EXISTS " + baseTable + "  ("
                        + " PK2 VARCHAR NOT NULL, V1 VARCHAR, V2 VARCHAR "
                        + " CONSTRAINT NAME_PK PRIMARY KEY (PK2) )";
        conn.createStatement().execute(ddlFormat);
        // Create a view
        String viewDDL = "CREATE VIEW " + viewName + " AS SELECT * FROM " + 
baseTable;
        conn.createStatement().execute(viewDDL);

        // Create index
        String indexName = generateUniqueName();
        String idxSDDL = String.format("CREATE INDEX %s ON %s (V1)", indexName, 
viewName);

        conn.createStatement().execute(idxSDDL);

        // Insert rows
        int numOfValues = 1000;
        for (int i=0; i < numOfValues; i++){
            conn.createStatement().execute(
                    String.format("UPSERT INTO %s VALUES('%s', '%s', '%s')", 
viewName, String.valueOf(i), "y",
                            "z"));
        }

        for (int i=numOfValues; i < numOfValues*2; i++){
            conn.createStatement().execute(
                    String.format("UPSERT INTO %s VALUES('%s', '%s', '%s')", 
viewName, String.valueOf(i), "x",
                            "y"));
        }

        conn.createStatement().execute("DELETE FROM "+indexName+" WHERE 
\"0:V1\" = 'x'");

        String viewIndexTableName = 
MetaDataUtil.getViewIndexPhysicalName(baseTable);
        ConnectionQueryServices queryServices = 
conn.unwrap(PhoenixConnection.class).getQueryServices();
        int count = 
getUtility().countRows(queryServices.getTable(Bytes.toBytes(viewIndexTableName)));
        assertTrue(count == numOfValues);

        count = 
getUtility().countRows(queryServices.getTable(Bytes.toBytes(baseTable)));

        assertTrue(count == 2*numOfValues);
        IndexToolIT.runIndexTool(true, false, "", viewName, indexName);
        // See that index is rebuilt and confirm index has rows
        Table htable= queryServices.getTable(Bytes.toBytes(viewIndexTableName));
        count = getUtility().countRows(htable);
        assertEquals(numOfValues*2, count); //fails here
    } finally {
        if (conn != null) {
            conn.commit();
            conn.close();
        }
    }
}
{code}



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)