http://git-wip-us.apache.org/repos/asf/phoenix/blob/ea3b8eaf/phoenix-core/src/it/java/org/apache/phoenix/end2end/DynamicFamilyIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DynamicFamilyIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DynamicFamilyIT.java index 370cfab..52e2a64 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DynamicFamilyIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DynamicFamilyIT.java @@ -62,8 +62,8 @@ import org.junit.Test; value="RV_RETURN_VALUE_IGNORED", justification="Designed to ignore.") -public class DynamicFamilyIT extends BaseHBaseManagedTimeIT { - private static final String WEB_STATS = "WEB_STATS"; +public class DynamicFamilyIT extends BaseHBaseManagedTimeTableReuseIT { + private static final String WEB_STATS = generateRandomString(); private static final String WEB_STATS_SCHEMA_NAME = ""; private static final byte[] A_CF = Bytes.toBytes(SchemaUtil.normalizeIdentifier("A")); private static final byte[] B_CF = Bytes.toBytes(SchemaUtil.normalizeIdentifier("B")); @@ -176,7 +176,7 @@ public class DynamicFamilyIT extends BaseHBaseManagedTimeIT { */ // FIXME @Test public void testGetAllDynColsInFamily() throws Exception { - String query = "SELECT A.* FROM WEB_STATS WHERE entry='entry1'"; + String query = "SELECT A.* FROM " + WEB_STATS + " WHERE entry='entry1'"; String url = getUrl() + ";"; Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); Connection conn = DriverManager.getConnection(url, props); @@ -204,7 +204,7 @@ public class DynamicFamilyIT extends BaseHBaseManagedTimeIT { */ // FIXME @Test public void testGetAllDynCols() throws Exception { - String query = "SELECT * FROM WEB_STATS WHERE entry='entry1'"; + String query = "SELECT * FROM " + WEB_STATS + "WHERE entry='entry1'"; String url = getUrl() + ";"; Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); Connection conn = DriverManager.getConnection(url, props); @@ -229,7 +229,7 @@ public class DynamicFamilyIT extends BaseHBaseManagedTimeIT { */ @Test public void testGetCaseInsensitiveDynCol() throws Exception { - String query = "SELECT B.* FROM WEB_STATS(" + + String query = "SELECT B.* FROM "+ WEB_STATS+ "(" + "B." + LAST_LOGIN_TIME_PREFIX + USER_ID2 + " TIME," + "B." + LAST_LOGIN_TIME_PREFIX + USER_ID3 + " TIME) WHERE entry='entry2'"; String url = getUrl() + ";"; @@ -254,7 +254,7 @@ public class DynamicFamilyIT extends BaseHBaseManagedTimeIT { */ // FIXME @Test public void testGetCaseSensitiveDynCol() throws Exception { - String query = "SELECT B.* FROM WEB_STATS(" + + String query = "SELECT B.* FROM "+WEB_STATS +"(" + "B.\"" + LAST_LOGIN_TIME_PREFIX + USER_ID2 + "\"" + " TIME," + "B.\"" + LAST_LOGIN_TIME_PREFIX + USER_ID3 + "\"" + " TIME) WHERE entry='entry2'"; String url = getUrl() + ";"; @@ -281,7 +281,7 @@ public class DynamicFamilyIT extends BaseHBaseManagedTimeIT { */ // FIXME @Test public void testProjectStaticAndDynamic() throws Exception { - String query = "SELECT ENTRY, A.DUMMY, B.DUMMY, A.*,B.* FROM WEB_STATS WHERE entry='entry3'"; + String query = "SELECT ENTRY, A.DUMMY, B.DUMMY, A.*,B.* FROM "+ WEB_STATS +" WHERE entry='entry3'"; String url = getUrl() + ";"; Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); Connection conn = DriverManager.getConnection(url, props); @@ -308,7 +308,7 @@ public class DynamicFamilyIT extends BaseHBaseManagedTimeIT { @Test(expected = ColumnFamilyNotFoundException.class) public void testDynamicFamilyException() throws Exception { - String query = "SELECT C.* FROM WEB_STATS"; + String query = "SELECT C.* FROM " + WEB_STATS; String url = getUrl() + ";"; Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); Connection conn = DriverManager.getConnection(url, props); @@ -322,7 +322,7 @@ public class DynamicFamilyIT extends BaseHBaseManagedTimeIT { @Test(expected = PhoenixParserException.class) public void testDynamicFamilyFunctionException() throws Exception { - String query = "SELECT count(C.*) FROM WEB_STATS"; + String query = "SELECT count(C.*) FROM " + WEB_STATS; String url = getUrl() + ";"; Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); Connection conn = DriverManager.getConnection(url, props); @@ -339,21 +339,24 @@ public class DynamicFamilyIT extends BaseHBaseManagedTimeIT { ResultSet rs; Connection conn = DriverManager.getConnection(getUrl()); conn.setAutoCommit(true); - conn.createStatement().execute("CREATE TABLE TESTTABLE (Id VARCHAR NOT NULL PRIMARY KEY, COLFAM1.A VARCHAR, COLFAM1.B VARCHAR, COLFAM2.A VARCHAR )"); - conn.createStatement().execute("UPSERT INTO TESTTABLE (Id, COLFAM1.A, COLFAM1.B, COLFAM2.A) values ('row-2', '100', '200', '300')"); - rs = conn.createStatement().executeQuery("SELECT COLFAM1.A,COLFAM1.B FROM TESTTABLE"); + String tableName = generateRandomString(); + conn.createStatement().execute("CREATE TABLE " + tableName + + " (Id VARCHAR NOT NULL PRIMARY KEY, COLFAM1.A VARCHAR, COLFAM1.B VARCHAR, COLFAM2.A VARCHAR )"); + conn.createStatement().execute("UPSERT INTO " + tableName + + " (Id, COLFAM1.A, COLFAM1.B, COLFAM2.A) values ('row-2', '100', '200', '300')"); + rs = conn.createStatement().executeQuery("SELECT COLFAM1.A,COLFAM1.B FROM " + tableName); assertTrue(rs.next()); assertEquals("100",rs.getString(1)); assertEquals("200",rs.getString(2)); assertFalse(rs.next()); - rs = conn.createStatement().executeQuery("SELECT COLFAM1.* FROM TESTTABLE"); + rs = conn.createStatement().executeQuery("SELECT COLFAM1.* FROM " + tableName); assertTrue(rs.next()); assertEquals("100",rs.getString(1)); assertEquals("200",rs.getString(2)); assertFalse(rs.next()); - rs = conn.createStatement().executeQuery("SELECT COLFAM1.*,COLFAM1.A FROM TESTTABLE"); + rs = conn.createStatement().executeQuery("SELECT COLFAM1.*,COLFAM1.A FROM " + tableName); assertTrue(rs.next()); assertEquals("100",rs.getString(1)); assertEquals("200",rs.getString(2));
http://git-wip-us.apache.org/repos/asf/phoenix/blob/ea3b8eaf/phoenix-core/src/it/java/org/apache/phoenix/end2end/FirstValueFunctionIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/FirstValueFunctionIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/FirstValueFunctionIT.java index 6c080d3..7978291 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/FirstValueFunctionIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/FirstValueFunctionIT.java @@ -27,26 +27,33 @@ import java.sql.ResultSet; import org.junit.Test; -public class FirstValueFunctionIT extends BaseHBaseManagedTimeIT { +public class FirstValueFunctionIT extends BaseHBaseManagedTimeTableReuseIT { @Test public void signedLongAsBigInt() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS first_value_table " + String tableName = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + tableName + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG," + " date BIGINT, \"value\" BIGINT)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (1, 8, 1, 3)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (2, 8, 2, 7)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (3, 8, 3, 9)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (5, 8, 5, 158)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (4, 8, 4, 5)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (1, 8, 1, 3)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (2, 8, 2, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (3, 8, 3, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (5, 8, 5, 158)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (4, 8, 4, 5)"); conn.commit(); ResultSet rs = conn.createStatement().executeQuery( - "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY date ASC) FROM first_value_table GROUP BY page_id"); + "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY date ASC) FROM " + tableName + + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals(rs.getLong(1), 3); @@ -57,20 +64,27 @@ public class FirstValueFunctionIT extends BaseHBaseManagedTimeIT { public void testSortOrderInSortCol() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS first_value_table " + String tableName = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + tableName + " " + "(id INTEGER NOT NULL, page_id UNSIGNED_LONG," + " dates BIGINT NOT NULL, \"value\" BIGINT CONSTRAINT pk PRIMARY KEY (id, dates DESC))"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, dates, \"value\") VALUES (1, 8, 1, 3)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, dates, \"value\") VALUES (2, 8, 2, 7)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, dates, \"value\") VALUES (3, 8, 3, 9)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, dates, \"value\") VALUES (5, 8, 5, 158)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, dates, \"value\") VALUES (4, 8, 4, 5)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, dates, \"value\") VALUES (1, 8, 1, 3)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, dates, \"value\") VALUES (2, 8, 2, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, dates, \"value\") VALUES (3, 8, 3, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, dates, \"value\") VALUES (5, 8, 5, 158)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, dates, \"value\") VALUES (4, 8, 4, 5)"); conn.commit(); ResultSet rs = conn.createStatement().executeQuery( - "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY dates ASC) FROM first_value_table GROUP BY page_id"); + "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY dates ASC) FROM " + tableName + + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals(rs.getLong(1), 3); @@ -81,20 +95,27 @@ public class FirstValueFunctionIT extends BaseHBaseManagedTimeIT { public void testSortOrderInDataCol() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS first_value_table " + String tableName = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + tableName + " " + "(id INTEGER NOT NULL, page_id UNSIGNED_LONG," + " dates BIGINT NOT NULL, \"value\" BIGINT NOT NULL CONSTRAINT pk PRIMARY KEY (id, dates, \"value\" DESC))"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, dates, \"value\") VALUES (1, 8, 1, 3)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, dates, \"value\") VALUES (2, 8, 2, 7)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, dates, \"value\") VALUES (3, 8, 3, 9)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, dates, \"value\") VALUES (5, 8, 5, 158)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, dates, \"value\") VALUES (4, 8, 4, 5)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, dates, \"value\") VALUES (1, 8, 1, 3)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, dates, \"value\") VALUES (2, 8, 2, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, dates, \"value\") VALUES (3, 8, 3, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, dates, \"value\") VALUES (5, 8, 5, 158)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, dates, \"value\") VALUES (4, 8, 4, 5)"); conn.commit(); ResultSet rs = conn.createStatement().executeQuery( - "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY dates ASC) FROM first_value_table GROUP BY page_id"); + "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY dates ASC) FROM " + tableName + + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals(rs.getLong(1), 3); @@ -105,20 +126,27 @@ public class FirstValueFunctionIT extends BaseHBaseManagedTimeIT { public void doubleDataType() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS first_value_table " + String tableName = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + tableName + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG, " + "date DOUBLE, \"value\" DOUBLE)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (1, 8, 1, 300)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (2, 8, 2, 7)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (3, 8, 3, 9)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (5, 8, 4, 2)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (4, 8, 5, 400)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (1, 8, 1, 300)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (2, 8, 2, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (3, 8, 3, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (5, 8, 4, 2)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (4, 8, 5, 400)"); conn.commit(); ResultSet rs = conn.createStatement().executeQuery( - "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY date ASC) FROM first_value_table GROUP BY page_id"); + "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY date ASC) FROM " + tableName + + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals("doubles", rs.getDouble(1), 300, 0.00001); @@ -129,20 +157,27 @@ public class FirstValueFunctionIT extends BaseHBaseManagedTimeIT { public void varcharFixedLenghtDatatype() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS first_value_table " + String table_name = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + table_name + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG, " + "date VARCHAR(3), \"value\" VARCHAR(3))"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (1, 8, '1', '3')"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (2, 8, '2', '7')"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (3, 8, '3', '9')"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (5, 8, '4', '2')"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (4, 8, '5', '4')"); + conn.createStatement().execute( + "UPSERT INTO " + table_name + " (id, page_id, date, \"value\") VALUES (1, 8, '1', '3')"); + conn.createStatement().execute( + "UPSERT INTO " + table_name + " (id, page_id, date, \"value\") VALUES (2, 8, '2', '7')"); + conn.createStatement().execute( + "UPSERT INTO " + table_name + " (id, page_id, date, \"value\") VALUES (3, 8, '3', '9')"); + conn.createStatement().execute( + "UPSERT INTO " + table_name + " (id, page_id, date, \"value\") VALUES (5, 8, '4', '2')"); + conn.createStatement().execute( + "UPSERT INTO " + table_name + " (id, page_id, date, \"value\") VALUES (4, 8, '5', '4')"); conn.commit(); ResultSet rs = conn.createStatement().executeQuery( - "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY date ASC) FROM first_value_table GROUP BY page_id"); + "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY date ASC) FROM " + table_name + + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals(rs.getString(1), "3"); @@ -153,20 +188,27 @@ public class FirstValueFunctionIT extends BaseHBaseManagedTimeIT { public void floatDataType() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS first_value_table " + String tableName = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + tableName + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG," + " date FLOAT, \"value\" FLOAT)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (1, 8, 1, 300)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (2, 8, 2, 7)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (3, 8, 3, 9)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (5, 8, 4, 2)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id, date, \"value\") VALUES (4, 8, 5, 400)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (1, 8, 1, 300)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (2, 8, 2, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (3, 8, 3, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (5, 8, 4, 2)"); + conn.createStatement().execute( + "UPSERT INTO " + tableName + " (id, page_id, date, \"value\") VALUES (4, 8, 5, 400)"); conn.commit(); ResultSet rs = conn.createStatement().executeQuery( - "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY date ASC) FROM first_value_table GROUP BY page_id"); + "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY date ASC) FROM " + tableName + + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals(rs.getFloat(1), 300.0, 0.000001); @@ -178,20 +220,22 @@ public class FirstValueFunctionIT extends BaseHBaseManagedTimeIT { public void allColumnsNull() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS first_value_table " + String tableName = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + tableName + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG," + " date FLOAT, \"value\" FLOAT)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id) VALUES (1, 8)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id) VALUES (2, 8)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id) VALUES (3, 8)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id) VALUES (5, 8)"); - conn.createStatement().execute("UPSERT INTO first_value_table (id, page_id) VALUES (4, 8)"); + conn.createStatement().execute("UPSERT INTO " + tableName + " (id, page_id) VALUES (1, 8)"); + conn.createStatement().execute("UPSERT INTO " + tableName + " (id, page_id) VALUES (2, 8)"); + conn.createStatement().execute("UPSERT INTO " + tableName + " (id, page_id) VALUES (3, 8)"); + conn.createStatement().execute("UPSERT INTO " + tableName + " (id, page_id) VALUES (5, 8)"); + conn.createStatement().execute("UPSERT INTO " + tableName + " (id, page_id) VALUES (4, 8)"); conn.commit(); ResultSet rs = conn.createStatement().executeQuery( - "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY date ASC) FROM first_value_table GROUP BY page_id"); + "SELECT FIRST_VALUE(\"value\") WITHIN GROUP (ORDER BY date ASC) FROM " + tableName + + " GROUP BY page_id"); assertTrue(rs.next()); byte[] nothing = rs.getBytes(1); http://git-wip-us.apache.org/repos/asf/phoenix/blob/ea3b8eaf/phoenix-core/src/it/java/org/apache/phoenix/end2end/GetSetByteBitFunctionEnd2EndIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/GetSetByteBitFunctionEnd2EndIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/GetSetByteBitFunctionEnd2EndIT.java index a7f7ca3..734f2c4 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/GetSetByteBitFunctionEnd2EndIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/GetSetByteBitFunctionEnd2EndIT.java @@ -32,24 +32,27 @@ import org.apache.phoenix.expression.function.GetByteFunction; import org.apache.phoenix.expression.function.SetBitFunction; import org.apache.phoenix.expression.function.SetByteFunction; import org.junit.Before; +import org.junit.BeforeClass; import org.junit.Test; /** * End to end tests for {@link GetByteFunction} {@link SetByteFunction} {@link GetBitFunction} * {@link SetBitFunction} */ -public class GetSetByteBitFunctionEnd2EndIT extends BaseHBaseManagedTimeIT { +public class GetSetByteBitFunctionEnd2EndIT extends BaseHBaseManagedTimeTableReuseIT { private static final String KEY = "key"; + private static final String TABLE_NAME = generateRandomString(); - @Before - public void initTable() throws Exception { + @BeforeClass + public static void initTable() throws Exception { Connection conn = null; PreparedStatement stmt = null; try { conn = DriverManager.getConnection(getUrl()); String ddl; - ddl = "CREATE TABLE ta (k VARCHAR NOT NULL PRIMARY KEY, b BINARY(4), vb VARBINARY)"; + ddl = "CREATE TABLE " + TABLE_NAME + + " (k VARCHAR NOT NULL PRIMARY KEY, b BINARY(4), vb VARBINARY)"; conn.createStatement().execute(ddl); conn.commit(); } finally { @@ -60,7 +63,8 @@ public class GetSetByteBitFunctionEnd2EndIT extends BaseHBaseManagedTimeIT { @Test public void test() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - PreparedStatement stmt = conn.prepareStatement("UPSERT INTO ta VALUES (?, ?, ?)"); + PreparedStatement stmt = conn.prepareStatement( + "UPSERT INTO " + TABLE_NAME + " VALUES (?, ?, ?)"); stmt.setString(1, KEY); stmt.setBytes(2, new byte[] { 1, 2, 3, 4 }); stmt.setBytes(3, new byte[] { 1, 2, 3, 4 }); @@ -68,30 +72,30 @@ public class GetSetByteBitFunctionEnd2EndIT extends BaseHBaseManagedTimeIT { conn.commit(); ResultSet rs = conn.createStatement() - .executeQuery( - "SELECT GET_BYTE(vb, 1), GET_BYTE(b, 1) FROM ta WHERE GET_BYTE(vb, 1)=2 and GET_BYTE(b, 1)=2"); + .executeQuery("SELECT GET_BYTE(vb, 1), GET_BYTE(b, 1) FROM " + TABLE_NAME + + " WHERE GET_BYTE(vb, 1)=2 and GET_BYTE(b, 1)=2"); assertTrue(rs.next()); assertEquals(2, rs.getInt(1)); assertEquals(2, rs.getInt(2)); assertTrue(!rs.next()); rs = conn.createStatement() - .executeQuery( - "SELECT GET_BIT(b, 0),GET_BIT(b, 9) FROM ta WHERE GET_BIT(vb, 0)=1 and GET_BIT(vb, 9)=1"); + .executeQuery("SELECT GET_BIT(b, 0),GET_BIT(b, 9) FROM " + TABLE_NAME + + " WHERE GET_BIT(vb, 0)=1 and GET_BIT(vb, 9)=1"); assertTrue(rs.next()); assertEquals(1, rs.getInt(1)); assertEquals(1, rs.getInt(2)); assertTrue(!rs.next()); rs = conn.createStatement().executeQuery( - "SELECT SET_BYTE(vb, 1, 1), SET_BYTE(b, 1, 1) FROM ta"); + "SELECT SET_BYTE(vb, 1, 1), SET_BYTE(b, 1, 1) FROM " + TABLE_NAME); assertTrue(rs.next()); assertArrayEquals(new byte[] { 1, 1, 3, 4 }, rs.getBytes(1)); assertArrayEquals(new byte[] { 1, 1, 3, 4 }, rs.getBytes(2)); assertTrue(!rs.next()); rs = conn.createStatement().executeQuery( - "SELECT SET_BIT(vb, 8, 1), SET_BIT(b, 8, 1) FROM ta"); + "SELECT SET_BIT(vb, 8, 1), SET_BIT(b, 8, 1) FROM " + TABLE_NAME); assertTrue(rs.next()); assertArrayEquals(new byte[] { 1, 3, 3, 4 }, rs.getBytes(1)); assertArrayEquals(new byte[] { 1, 3, 3, 4 }, rs.getBytes(2)); http://git-wip-us.apache.org/repos/asf/phoenix/blob/ea3b8eaf/phoenix-core/src/it/java/org/apache/phoenix/end2end/LikeExpressionIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/LikeExpressionIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/LikeExpressionIT.java index ecd1e8c..00a6a64 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/LikeExpressionIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/LikeExpressionIT.java @@ -30,17 +30,21 @@ import java.sql.SQLException; import java.sql.Statement; import org.junit.Before; +import org.junit.BeforeClass; import org.junit.Test; public class LikeExpressionIT extends BaseHBaseManagedTimeIT { - @Before - public void doBeforeTestSetup() throws Exception { + + private static final String TEST_TABLE = generateRandomString(); + + @BeforeClass + public static void doBeforeTestSetup() throws Exception { Connection conn = null; PreparedStatement stmt = null; try { conn = DriverManager.getConnection(getUrl()); String ddl; - ddl = "CREATE TABLE testTable (k VARCHAR NOT NULL PRIMARY KEY, i INTEGER)"; + ddl = "CREATE TABLE " + TEST_TABLE + " (k VARCHAR NOT NULL PRIMARY KEY, i INTEGER)"; conn.createStatement().execute(ddl); conn.commit(); } finally { @@ -54,8 +58,9 @@ public class LikeExpressionIT extends BaseHBaseManagedTimeIT { insertRow(conn, "321n7-App-2-", 32); } - private void insertRow(Connection conn, String k, int i) throws SQLException { - PreparedStatement stmt = conn.prepareStatement("UPSERT INTO testTable VALUES (?, ?)"); + private static void insertRow(Connection conn, String k, int i) throws SQLException { + PreparedStatement stmt = conn.prepareStatement( + "UPSERT INTO " + TEST_TABLE + " VALUES (?, ?)"); stmt.setString(1, k); stmt.setInt(2, i); stmt.executeUpdate(); @@ -64,7 +69,7 @@ public class LikeExpressionIT extends BaseHBaseManagedTimeIT { private void testLikeExpression(Connection conn, String likeStr, int numResult, int expectedSum) throws Exception { - String cmd = "select k, i from testTable where k like '" + likeStr + "'"; + String cmd = "select k, i from " + TEST_TABLE + " where k like '" + likeStr + "'"; Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(cmd); int sum = 0; @@ -89,15 +94,18 @@ public class LikeExpressionIT extends BaseHBaseManagedTimeIT { @Test public void testLikeEverythingExpression() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE t (k1 VARCHAR, k2 VARCHAR, CONSTRAINT pk PRIMARY KEY (k1,k2))"; + String table = generateRandomString(); + String ddl = "CREATE TABLE " + table + + " (k1 VARCHAR, k2 VARCHAR, CONSTRAINT pk PRIMARY KEY (k1,k2))"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO t VALUES('aa','bb')"); - conn.createStatement().execute("UPSERT INTO t VALUES('ab','bc')"); - conn.createStatement().execute("UPSERT INTO t VALUES(null,'cc')"); - conn.createStatement().execute("UPSERT INTO t VALUES('dd',null)"); + conn.createStatement().execute("UPSERT INTO " + table + " VALUES('aa','bb')"); + conn.createStatement().execute("UPSERT INTO " + table + " VALUES('ab','bc')"); + conn.createStatement().execute("UPSERT INTO " + table + " VALUES(null,'cc')"); + conn.createStatement().execute("UPSERT INTO " + table + " VALUES('dd',null)"); conn.commit(); - ResultSet rs = conn.createStatement().executeQuery("SELECT * FROM t WHERE k1 LIKE '%'"); + ResultSet rs = conn.createStatement().executeQuery( + "SELECT * FROM " + table + " WHERE k1 LIKE '%'"); assertTrue(rs.next()); assertEquals("aa", rs.getString(1)); assertEquals("bb", rs.getString(2)); @@ -109,7 +117,7 @@ public class LikeExpressionIT extends BaseHBaseManagedTimeIT { assertEquals(null, rs.getString(2)); assertFalse(rs.next()); - rs = conn.createStatement().executeQuery("SELECT * FROM t WHERE k2 LIKE '%'"); + rs = conn.createStatement().executeQuery("SELECT * FROM " + table + " WHERE k2 LIKE '%'"); assertTrue(rs.next()); assertEquals(null, rs.getString(1)); assertEquals("cc", rs.getString(2)); http://git-wip-us.apache.org/repos/asf/phoenix/blob/ea3b8eaf/phoenix-core/src/it/java/org/apache/phoenix/end2end/MD5FunctionIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/MD5FunctionIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/MD5FunctionIT.java index a6107df..0b63aa8 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/MD5FunctionIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/MD5FunctionIT.java @@ -30,20 +30,22 @@ import java.sql.ResultSet; import org.junit.Test; -public class MD5FunctionIT extends BaseHBaseManagedTimeIT { +public class MD5FunctionIT extends BaseHBaseManagedTimeTableReuseIT { @Test public void testRetrieve() throws Exception { String testString = "mwalsh"; Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS MD5_RETRIEVE_TEST (pk VARCHAR NOT NULL PRIMARY KEY)"; + String md5_retrieve_test = generateRandomString(); + String ddl = + "CREATE TABLE IF NOT EXISTS " + md5_retrieve_test + " (pk VARCHAR NOT NULL PRIMARY KEY)"; conn.createStatement().execute(ddl); - String dml = String.format("UPSERT INTO MD5_RETRIEVE_TEST VALUES('%s')", testString); + String dml = String.format("UPSERT INTO " + md5_retrieve_test + " VALUES('%s')", testString); conn.createStatement().execute(dml); conn.commit(); - ResultSet rs = conn.createStatement().executeQuery("SELECT MD5(pk) FROM MD5_RETRIEVE_TEST"); + ResultSet rs = conn.createStatement().executeQuery("SELECT MD5(pk) FROM " + md5_retrieve_test); assertTrue(rs.next()); byte[] first = MessageDigest.getInstance("MD5").digest(testString.getBytes()); byte[] second = rs.getBytes(1); @@ -56,13 +58,16 @@ public class MD5FunctionIT extends BaseHBaseManagedTimeIT { String testString = "FOOBAR"; Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS MD5_RETRIEVE_TEST (k1 CHAR(3) NOT NULL, k2 CHAR(3) NOT NULL, CONSTRAINT PK PRIMARY KEY (K1,K2))"; + String md5_retrieve_test = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + md5_retrieve_test + + " (k1 CHAR(3) NOT NULL, k2 CHAR(3) NOT NULL, CONSTRAINT PK PRIMARY KEY (K1,K2))"; conn.createStatement().execute(ddl); - String dml = "UPSERT INTO MD5_RETRIEVE_TEST VALUES('FOO','BAR')"; + String dml = "UPSERT INTO " + md5_retrieve_test + " VALUES('FOO','BAR')"; conn.createStatement().execute(dml); conn.commit(); - ResultSet rs = conn.createStatement().executeQuery("SELECT MD5((K1,K2)) FROM MD5_RETRIEVE_TEST"); + ResultSet rs = conn.createStatement().executeQuery( + "SELECT MD5((K1,K2)) FROM " + md5_retrieve_test); assertTrue(rs.next()); byte[] first = MessageDigest.getInstance("MD5").digest(testString.getBytes()); byte[] second = rs.getBytes(1); @@ -76,20 +81,23 @@ public class MD5FunctionIT extends BaseHBaseManagedTimeIT { String testString2 = "mwalsh2"; Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS MD5_UPSERT_TEST (k1 binary(16) NOT NULL,k2 binary(16) NOT NULL CONSTRAINT pk PRIMARY KEY (k1, k2))"; + String md5_upsert_test = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + md5_upsert_test + + " (k1 binary(16) NOT NULL,k2 binary(16) NOT NULL CONSTRAINT pk PRIMARY KEY (k1, k2))"; conn.createStatement().execute(ddl); - String dml = String.format("UPSERT INTO MD5_UPSERT_TEST VALUES(md5('%s'),md5('%s'))", testString1, testString2); + String dml = String.format("UPSERT INTO " + md5_upsert_test + " VALUES(md5('%s'),md5('%s'))", testString1, testString2); conn.createStatement().execute(dml); conn.commit(); - ResultSet rs = conn.createStatement().executeQuery("SELECT k1,k2 FROM MD5_UPSERT_TEST"); + ResultSet rs = conn.createStatement().executeQuery("SELECT k1,k2 FROM " + md5_upsert_test); assertTrue(rs.next()); byte[] pk1 = MessageDigest.getInstance("MD5").digest(testString1.getBytes()); byte[] pk2 = MessageDigest.getInstance("MD5").digest(testString2.getBytes()); assertArrayEquals(pk1, rs.getBytes(1)); assertArrayEquals(pk2, rs.getBytes(2)); assertFalse(rs.next()); - PreparedStatement stmt = conn.prepareStatement("SELECT k1,k2 FROM MD5_UPSERT_TEST WHERE k1=md5(?)"); + PreparedStatement stmt = conn.prepareStatement( + "SELECT k1,k2 FROM " + md5_upsert_test + " WHERE k1=md5(?)"); stmt.setString(1, testString1); rs = stmt.executeQuery(); assertTrue(rs.next()); http://git-wip-us.apache.org/repos/asf/phoenix/blob/ea3b8eaf/phoenix-core/src/it/java/org/apache/phoenix/end2end/MappingTableDataTypeIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/MappingTableDataTypeIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/MappingTableDataTypeIT.java index 9617e37..6c51ebd 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/MappingTableDataTypeIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/MappingTableDataTypeIT.java @@ -52,7 +52,8 @@ import org.junit.Test; public class MappingTableDataTypeIT extends BaseHBaseManagedTimeIT { @Test public void testMappingHbaseTableToPhoenixTable() throws Exception { - final TableName tableName = TableName.valueOf("MTEST"); + String mtest = generateRandomString(); + final TableName tableName = TableName.valueOf(mtest); Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); PhoenixConnection conn = DriverManager.getConnection(getUrl(), props).unwrap(PhoenixConnection.class); @@ -65,13 +66,13 @@ public class MappingTableDataTypeIT extends BaseHBaseManagedTimeIT { descriptor.addFamily(columnDescriptor1); descriptor.addFamily(columnDescriptor2); admin.createTable(descriptor); - HTableInterface t = conn.getQueryServices().getTable(Bytes.toBytes("MTEST")); + HTableInterface t = conn.getQueryServices().getTable(Bytes.toBytes(mtest)); insertData(tableName.getName(), admin, t); t.close(); // create phoenix table that maps to existing HBase table - createPhoenixTable(); + createPhoenixTable(mtest); - String selectSql = "SELECT * FROM MTEST"; + String selectSql = "SELECT * FROM " + mtest; ResultSet rs = conn.createStatement().executeQuery(selectSql); ResultSetMetaData rsMetaData = rs.getMetaData(); assertTrue("Expected single row", rs.next()); @@ -81,7 +82,7 @@ public class MappingTableDataTypeIT extends BaseHBaseManagedTimeIT { assertFalse("Expected single row ", rs.next()); // delete the row - String deleteSql = "DELETE FROM MTEST WHERE id = 'row'"; + String deleteSql = "DELETE FROM " + mtest + " WHERE id = 'row'"; conn.createStatement().executeUpdate(deleteSql); conn.commit(); @@ -116,8 +117,8 @@ public class MappingTableDataTypeIT extends BaseHBaseManagedTimeIT { /** * Create a table in Phoenix that only maps column family cf1 */ - private void createPhoenixTable() throws SQLException { - String ddl = "create table IF NOT EXISTS MTEST (" + " id varchar NOT NULL primary key," + private void createPhoenixTable(String tableName) throws SQLException { + String ddl = "create table IF NOT EXISTS " + tableName+ " (" + " id varchar NOT NULL primary key," + " \"cf1\".\"q1\" varchar" + " ) "; Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); Connection conn = DriverManager.getConnection(getUrl(), props); http://git-wip-us.apache.org/repos/asf/phoenix/blob/ea3b8eaf/phoenix-core/src/it/java/org/apache/phoenix/end2end/MinMaxAggregateFunctionIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/MinMaxAggregateFunctionIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/MinMaxAggregateFunctionIT.java index ca7a676..3a5088d 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/MinMaxAggregateFunctionIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/MinMaxAggregateFunctionIT.java @@ -23,7 +23,9 @@ import java.util.Properties; import org.apache.phoenix.util.PropertiesUtil; import org.junit.Test; -public class MinMaxAggregateFunctionIT extends BaseHBaseManagedTimeIT { +public class MinMaxAggregateFunctionIT extends BaseHBaseManagedTimeTableReuseIT { + + private static final String TABLE_NAME = generateRandomString(); @Test public void testMinMaxAggregateFunctions() throws SQLException { @@ -32,7 +34,7 @@ public class MinMaxAggregateFunctionIT extends BaseHBaseManagedTimeIT { conn.setAutoCommit(false); try { conn.prepareStatement( - "create table TT(" + "create table " + TABLE_NAME + "(" + "VAL1 integer not null, " + "VAL2 char(2), " + "VAL3 varchar, " @@ -40,30 +42,30 @@ public class MinMaxAggregateFunctionIT extends BaseHBaseManagedTimeIT { + "constraint PK primary key (VAL1))").execute(); conn.commit(); - conn.prepareStatement("upsert into TT values (0, '00', '00', '0')").execute(); - conn.prepareStatement("upsert into TT values (1, '01', '01', '1')").execute(); - conn.prepareStatement("upsert into TT values (2, '02', '02', '2')").execute(); + conn.prepareStatement("upsert into " + TABLE_NAME + " values (0, '00', '00', '0')").execute(); + conn.prepareStatement("upsert into " + TABLE_NAME + " values (1, '01', '01', '1')").execute(); + conn.prepareStatement("upsert into " + TABLE_NAME + " values (2, '02', '02', '2')").execute(); conn.commit(); - ResultSet rs = conn.prepareStatement("select min(VAL2) from TT").executeQuery(); + ResultSet rs = conn.prepareStatement("select min(VAL2) from " + TABLE_NAME).executeQuery(); assertTrue(rs.next()); assertEquals("00", rs.getString(1)); - rs = conn.prepareStatement("select min(VAL3) from TT").executeQuery(); + rs = conn.prepareStatement("select min(VAL3) from " + TABLE_NAME).executeQuery(); assertTrue(rs.next()); assertEquals("00", rs.getString(1)); - rs = conn.prepareStatement("select max(VAL2)from TT").executeQuery(); + rs = conn.prepareStatement("select max(VAL2)from " + TABLE_NAME).executeQuery(); assertTrue(rs.next()); assertEquals("02", rs.getString(1)); - rs = conn.prepareStatement("select max(VAL3)from TT").executeQuery(); + rs = conn.prepareStatement("select max(VAL3)from " + TABLE_NAME).executeQuery(); assertTrue(rs.next()); assertEquals("02", rs.getString(1)); rs = conn.prepareStatement( - "select min(VAL1), min(VAL2), min(VAL3), min(VAL4) from TT").executeQuery(); + "select min(VAL1), min(VAL2), min(VAL3), min(VAL4) from " + TABLE_NAME).executeQuery(); assertTrue(rs.next()); assertEquals(0, rs.getInt(1)); assertEquals("00", rs.getString(2)); @@ -72,7 +74,7 @@ public class MinMaxAggregateFunctionIT extends BaseHBaseManagedTimeIT { rs = conn.prepareStatement( - "select max(VAL1), max(VAL2), max(VAL3), max(VAL4) from TT").executeQuery(); + "select max(VAL1), max(VAL2), max(VAL3), max(VAL4) from " + TABLE_NAME).executeQuery(); assertTrue(rs.next()); assertEquals(2, rs.getInt(1)); http://git-wip-us.apache.org/repos/asf/phoenix/blob/ea3b8eaf/phoenix-core/src/it/java/org/apache/phoenix/end2end/NthValueFunctionIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/NthValueFunctionIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/NthValueFunctionIT.java index 11ecc0d..697c04c 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/NthValueFunctionIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/NthValueFunctionIT.java @@ -29,24 +29,31 @@ import java.util.ArrayList; import org.junit.Test; -public class NthValueFunctionIT extends BaseHBaseManagedTimeIT { +public class NthValueFunctionIT extends BaseHBaseManagedTimeTableReuseIT { @Test public void simpleTest() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS nthValue " + String nthValue = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + nthValue + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG," + " dates INTEGER, val INTEGER)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (2, 8, 1, 7)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (3, 8, 2, 9)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (4, 8, 3, 4)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (5, 8, 4, 2)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (2, 8, 1, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (3, 8, 2, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (4, 8, 3, 4)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (5, 8, 4, 2)"); conn.commit(); - ResultSet rs = conn.createStatement().executeQuery("SELECT NTH_VALUE(val, 2) WITHIN GROUP (ORDER BY dates DESC) FROM nthValue GROUP BY page_id"); + ResultSet rs = conn.createStatement().executeQuery( + "SELECT NTH_VALUE(val, 2) WITHIN GROUP (ORDER BY dates DESC) FROM " + nthValue + + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals(rs.getInt(1), 4); @@ -57,21 +64,30 @@ public class NthValueFunctionIT extends BaseHBaseManagedTimeIT { public void offsetValueAscOrder() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS nth_test_table " + String nth_test_table = generateRandomString(); + + String ddl = "CREATE TABLE IF NOT EXISTS " + nth_test_table + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG," + " date INTEGER, \"value\" UNSIGNED_LONG)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (1, 8, 0, 300)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (2, 8, 1, 7)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (3, 8, 2, 9)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (4, 8, 3, 4)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (5, 8, 4, 2)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (6, 8, 5, 150)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, date, \"value\") VALUES (1, 8, 0, 300)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (2, 8, 1, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (3, 8, 2, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (4, 8, 3, 4)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (5, 8, 4, 2)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, date, \"value\") VALUES (6, 8, 5, 150)"); conn.commit(); ResultSet rs = conn.createStatement().executeQuery( - "SELECT NTH_VALUE(\"value\", 2) WITHIN GROUP (ORDER BY date ASC) FROM nth_test_table GROUP BY page_id"); + "SELECT NTH_VALUE(\"value\", 2) WITHIN GROUP (ORDER BY date ASC) FROM " + + nth_test_table + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals(rs.getLong(1), 7); @@ -82,21 +98,29 @@ public class NthValueFunctionIT extends BaseHBaseManagedTimeIT { public void offsetValueDescOrder() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS nth_test_table " + String nth_test_table = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + nth_test_table + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG," + " date INTEGER, \"value\" UNSIGNED_LONG)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (1, 8, 0, 300)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (2, 8, 1, 7)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (3, 8, 2, 9)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (4, 8, 3, 4)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (5, 8, 4, 2)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (6, 8, 5, 150)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, date, \"value\") VALUES (1, 8, 0, 300)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (2, 8, 1, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (3, 8, 2, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (4, 8, 3, 4)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (5, 8, 4, 2)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, date, \"value\") VALUES (6, 8, 5, 150)"); conn.commit(); ResultSet rs = conn.createStatement().executeQuery( - "SELECT NTH_VALUE(\"value\", 2) WITHIN GROUP (ORDER BY date DESC) FROM nth_test_table GROUP BY page_id"); + "SELECT NTH_VALUE(\"value\", 2) WITHIN GROUP (ORDER BY date DESC) FROM " + + nth_test_table + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals(rs.getLong(1), 2); @@ -107,21 +131,29 @@ public class NthValueFunctionIT extends BaseHBaseManagedTimeIT { public void offsetValueLastMismatchByColumn() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS nth_test_table " + String nth_test_table = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + nth_test_table + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG," + " date INTEGER, \"value\" UNSIGNED_LONG)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (1, 8, 5, 8)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (2, 8, 2, 7)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (3, 8, 1, 9)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (4, 8, 4, 4)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (5, 8, 3, 2)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, date, \"value\") VALUES (6, 8, 0, 1)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (1, 8, 5, 8)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (2, 8, 2, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (3, 8, 1, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (4, 8, 4, 4)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (5, 8, 3, 2)"); + conn.createStatement().execute( + "UPSERT INTO " + nth_test_table + " (id, page_id, date, \"value\") VALUES (6, 8, 0, 1)"); conn.commit(); ResultSet rs = conn.createStatement().executeQuery( - "SELECT NTH_VALUE(\"value\", 2) WITHIN GROUP (ORDER BY date DESC) FROM nth_test_table GROUP BY page_id"); + "SELECT NTH_VALUE(\"value\", 2) WITHIN GROUP (ORDER BY date DESC) FROM " + + nth_test_table + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals(rs.getLong(1), 4); @@ -132,20 +164,27 @@ public class NthValueFunctionIT extends BaseHBaseManagedTimeIT { public void testSortOrderInDataColWithOffset() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS nth_test_table " + String nth_test_table = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + nth_test_table + " " + "(id INTEGER NOT NULL, page_id UNSIGNED_LONG," + " dates BIGINT NOT NULL, \"value\" BIGINT NOT NULL CONSTRAINT pk PRIMARY KEY (id, dates, \"value\" DESC))"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, dates, \"value\") VALUES (1, 8, 1, 3)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, dates, \"value\") VALUES (2, 8, 2, 7)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, dates, \"value\") VALUES (3, 8, 3, 9)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, dates, \"value\") VALUES (5, 8, 5, 158)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, dates, \"value\") VALUES (4, 8, 4, 5)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, dates, \"value\") VALUES (1, 8, 1, 3)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, dates, \"value\") VALUES (2, 8, 2, 7)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, dates, \"value\") VALUES (3, 8, 3, 9)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, dates, \"value\") VALUES (5, 8, 5, 158)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, dates, \"value\") VALUES (4, 8, 4, 5)"); conn.commit(); ResultSet rs = conn.createStatement().executeQuery( - "SELECT NTH_VALUE(\"value\", 2) WITHIN GROUP (ORDER BY dates ASC) FROM nth_test_table GROUP BY page_id"); + "SELECT NTH_VALUE(\"value\", 2) WITHIN GROUP (ORDER BY dates ASC) FROM " + + nth_test_table + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals(rs.getLong(1), 7); @@ -156,19 +195,27 @@ public class NthValueFunctionIT extends BaseHBaseManagedTimeIT { public void nonUniqueValuesInOrderByAsc() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS nthValue " + String nthValue = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + nthValue + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG," + " dates INTEGER, val INTEGER)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (2, 8, 1, 7)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (3, 8, 2, 9)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (4, 8, 2, 4)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (5, 8, 2, 2)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (6, 8, 3, 3)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (2, 8, 1, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (3, 8, 2, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (4, 8, 2, 4)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (5, 8, 2, 2)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (6, 8, 3, 3)"); conn.commit(); - ResultSet rs = conn.createStatement().executeQuery("SELECT NTH_VALUE(val, 3) WITHIN GROUP (ORDER BY dates ASC) FROM nthValue GROUP BY page_id"); + ResultSet rs = conn.createStatement().executeQuery( + "SELECT NTH_VALUE(val, 3) WITHIN GROUP (ORDER BY dates ASC) FROM " + nthValue + + " GROUP BY page_id"); assertTrue(rs.next()); assertInIntArray(new int[]{2, 4, 9}, rs.getInt(1)); @@ -179,19 +226,27 @@ public class NthValueFunctionIT extends BaseHBaseManagedTimeIT { public void nonUniqueValuesInOrderByAscSkipDuplicit() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS nthValue " + String nthValue = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + nthValue + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG," + " dates INTEGER, val INTEGER)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (2, 8, 1, 7)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (3, 8, 2, 9)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (4, 8, 2, 4)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (5, 8, 2, 2)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (6, 8, 3, 3)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (2, 8, 1, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (3, 8, 2, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (4, 8, 2, 4)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (5, 8, 2, 2)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (6, 8, 3, 3)"); conn.commit(); - ResultSet rs = conn.createStatement().executeQuery("SELECT NTH_VALUE(val, 5) WITHIN GROUP (ORDER BY dates ASC) FROM nthValue GROUP BY page_id"); + ResultSet rs = conn.createStatement().executeQuery( + "SELECT NTH_VALUE(val, 5) WITHIN GROUP (ORDER BY dates ASC) FROM " + nthValue + + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals(3, rs.getInt(1)); @@ -202,19 +257,27 @@ public class NthValueFunctionIT extends BaseHBaseManagedTimeIT { public void nonUniqueValuesInOrderByDesc() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS nthValue " + String nthValue = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + nthValue + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG," + " dates INTEGER, val INTEGER)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (2, 8, 1, 7)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (3, 8, 2, 9)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (4, 8, 2, 4)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (5, 8, 2, 2)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (6, 8, 3, 3)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (2, 8, 1, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (3, 8, 2, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (4, 8, 2, 4)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (5, 8, 2, 2)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (6, 8, 3, 3)"); conn.commit(); - ResultSet rs = conn.createStatement().executeQuery("SELECT NTH_VALUE(val, 3) WITHIN GROUP (ORDER BY dates DESC) FROM nthValue GROUP BY page_id"); + ResultSet rs = conn.createStatement().executeQuery( + "SELECT NTH_VALUE(val, 3) WITHIN GROUP (ORDER BY dates DESC) FROM " + nthValue + + " GROUP BY page_id"); assertTrue(rs.next()); assertInIntArray(new int[]{2, 4, 9}, rs.getInt(1)); @@ -225,20 +288,29 @@ public class NthValueFunctionIT extends BaseHBaseManagedTimeIT { public void nonUniqueValuesInOrderNextValueDesc() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS nthValue " + String nthValue = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + nthValue + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG," + " dates INTEGER, val INTEGER)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (2, 8, 0, 7)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (3, 8, 1, 9)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (4, 8, 2, 4)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (5, 8, 2, 2)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (6, 8, 3, 3)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (7, 8, 3, 5)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (2, 8, 0, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (3, 8, 1, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (4, 8, 2, 4)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (5, 8, 2, 2)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (6, 8, 3, 3)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (7, 8, 3, 5)"); conn.commit(); - ResultSet rs = conn.createStatement().executeQuery("SELECT NTH_VALUE(val, 2) WITHIN GROUP (ORDER BY dates DESC) FROM nthValue GROUP BY page_id"); + ResultSet rs = conn.createStatement().executeQuery( + "SELECT NTH_VALUE(val, 2) WITHIN GROUP (ORDER BY dates DESC) FROM " + nthValue + + " GROUP BY page_id"); assertTrue(rs.next()); assertInIntArray(new int[]{3, 5}, rs.getInt(1)); @@ -249,20 +321,29 @@ public class NthValueFunctionIT extends BaseHBaseManagedTimeIT { public void nonUniqueValuesInOrderNextValueAsc() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS nthValue " + String nthValue = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + nthValue + " " + "(id INTEGER NOT NULL PRIMARY KEY, page_id UNSIGNED_LONG," + " dates INTEGER, val INTEGER)"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (2, 8, 0, 7)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (3, 8, 1, 9)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (4, 8, 2, 4)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (5, 8, 2, 2)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (6, 8, 3, 3)"); - conn.createStatement().execute("UPSERT INTO nthValue (id, page_id, dates, val) VALUES (7, 8, 3, 5)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (2, 8, 0, 7)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (3, 8, 1, 9)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (4, 8, 2, 4)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (5, 8, 2, 2)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (6, 8, 3, 3)"); + conn.createStatement().execute( + "UPSERT INTO " + nthValue + " (id, page_id, dates, val) VALUES (7, 8, 3, 5)"); conn.commit(); - ResultSet rs = conn.createStatement().executeQuery("SELECT NTH_VALUE(val, 5) WITHIN GROUP (ORDER BY dates ASC) FROM nthValue GROUP BY page_id"); + ResultSet rs = conn.createStatement().executeQuery( + "SELECT NTH_VALUE(val, 5) WITHIN GROUP (ORDER BY dates ASC) FROM " + nthValue + + " GROUP BY page_id"); assertTrue(rs.next()); assertInIntArray(new int[]{3, 5}, rs.getInt(1)); @@ -273,20 +354,27 @@ public class NthValueFunctionIT extends BaseHBaseManagedTimeIT { public void ignoreNullValues() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - String ddl = "CREATE TABLE IF NOT EXISTS nth_test_table " + String nth_test_table = generateRandomString(); + String ddl = "CREATE TABLE IF NOT EXISTS " + nth_test_table + " " + "(id INTEGER NOT NULL, page_id UNSIGNED_LONG," + " dates BIGINT NOT NULL, \"value\" BIGINT NULL CONSTRAINT pk PRIMARY KEY (id, dates))"; conn.createStatement().execute(ddl); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, dates, \"value\") VALUES (1, 8, 1, 1)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, dates, \"value\") VALUES (2, 8, 2, NULL)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, dates, \"value\") VALUES (3, 8, 3, NULL)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, dates, \"value\") VALUES (5, 8, 4, 4)"); - conn.createStatement().execute("UPSERT INTO nth_test_table (id, page_id, dates, \"value\") VALUES (4, 8, 5, 5)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, dates, \"value\") VALUES (1, 8, 1, 1)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, dates, \"value\") VALUES (2, 8, 2, NULL)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, dates, \"value\") VALUES (3, 8, 3, NULL)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, dates, \"value\") VALUES (5, 8, 4, 4)"); + conn.createStatement().execute("UPSERT INTO " + nth_test_table + + " (id, page_id, dates, \"value\") VALUES (4, 8, 5, 5)"); conn.commit(); ResultSet rs = conn.createStatement().executeQuery( - "SELECT NTH_VALUE(\"value\", 2) WITHIN GROUP (ORDER BY dates DESC) FROM nth_test_table GROUP BY page_id"); + "SELECT NTH_VALUE(\"value\", 2) WITHIN GROUP (ORDER BY dates DESC) FROM " + + nth_test_table + " GROUP BY page_id"); assertTrue(rs.next()); assertEquals(rs.getLong(1), 4); http://git-wip-us.apache.org/repos/asf/phoenix/blob/ea3b8eaf/phoenix-core/src/it/java/org/apache/phoenix/end2end/OctetLengthFunctionEnd2EndIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/OctetLengthFunctionEnd2EndIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/OctetLengthFunctionEnd2EndIT.java index 1239e7a..7977ab5 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/OctetLengthFunctionEnd2EndIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/OctetLengthFunctionEnd2EndIT.java @@ -33,9 +33,10 @@ import org.junit.Test; /** * End to end tests for {@link OctetLengthFunction} */ -public class OctetLengthFunctionEnd2EndIT extends BaseHBaseManagedTimeIT { +public class OctetLengthFunctionEnd2EndIT extends BaseHBaseManagedTimeTableReuseIT { private static final String KEY = "key"; + private static final String TABLE_NAME = generateRandomString(); @Before public void initTable() throws Exception { @@ -44,7 +45,8 @@ public class OctetLengthFunctionEnd2EndIT extends BaseHBaseManagedTimeIT { try { conn = DriverManager.getConnection(getUrl()); String ddl; - ddl = "CREATE TABLE ta (k VARCHAR NOT NULL PRIMARY KEY, b BINARY(4), vb VARBINARY)"; + ddl = "CREATE TABLE " + TABLE_NAME + + " (k VARCHAR NOT NULL PRIMARY KEY, b BINARY(4), vb VARBINARY)"; conn.createStatement().execute(ddl); conn.commit(); } finally { @@ -55,7 +57,8 @@ public class OctetLengthFunctionEnd2EndIT extends BaseHBaseManagedTimeIT { @Test public void test() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); - PreparedStatement stmt = conn.prepareStatement("UPSERT INTO ta VALUES (?, ?, ?)"); + PreparedStatement stmt = conn.prepareStatement( + "UPSERT INTO " + TABLE_NAME + " VALUES (?, ?, ?)"); stmt.setString(1, KEY); stmt.setBytes(2, new byte[] { 1, 2, 3, 4 }); stmt.setBytes(3, new byte[] { 1, 2, 3, 4 }); @@ -63,8 +66,8 @@ public class OctetLengthFunctionEnd2EndIT extends BaseHBaseManagedTimeIT { conn.commit(); ResultSet rs = conn.createStatement() - .executeQuery( - "SELECT OCTET_LENGTH(vb), OCTET_LENGTH(b) FROM ta WHERE OCTET_LENGTH(vb)=4 and OCTET_LENGTH(b)=4"); + .executeQuery("SELECT OCTET_LENGTH(vb), OCTET_LENGTH(b) FROM " + TABLE_NAME + + " WHERE OCTET_LENGTH(vb)=4 and OCTET_LENGTH(b)=4"); assertTrue(rs.next()); assertEquals(4, rs.getInt(1)); assertEquals(4, rs.getInt(2)); http://git-wip-us.apache.org/repos/asf/phoenix/blob/ea3b8eaf/phoenix-core/src/it/java/org/apache/phoenix/end2end/PowerFunctionEnd2EndIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/PowerFunctionEnd2EndIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/PowerFunctionEnd2EndIT.java index 691fb61..cb120bd 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/PowerFunctionEnd2EndIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/PowerFunctionEnd2EndIT.java @@ -27,15 +27,18 @@ import java.sql.ResultSet; import org.apache.phoenix.expression.function.PowerFunction; import org.junit.Before; +import org.junit.BeforeClass; import org.junit.Test; /** * End to end tests for {@link PowerFunction} */ -public class PowerFunctionEnd2EndIT extends BaseHBaseManagedTimeIT { +public class PowerFunctionEnd2EndIT extends BaseHBaseManagedTimeTableReuseIT { private static final String KEY = "key"; private static final double ZERO = 1e-9; + private static final String TEST_SIGNED = generateRandomString(); + private static final String TEST_UNSIGNED = generateRandomString(); private static boolean twoDoubleEquals(double a, double b) { if (Double.isNaN(a) ^ Double.isNaN(b)) return false; @@ -52,18 +55,18 @@ public class PowerFunctionEnd2EndIT extends BaseHBaseManagedTimeIT { } } - @Before - public void initTable() throws Exception { + @BeforeClass + public static void initTable() throws Exception { Connection conn = null; PreparedStatement stmt = null; try { conn = DriverManager.getConnection(getUrl()); String ddl; - ddl = - "CREATE TABLE testSigned (k VARCHAR NOT NULL PRIMARY KEY, doub DOUBLE, fl FLOAT, inte INTEGER, lon BIGINT, smalli SMALLINT, tinyi TINYINT)"; + ddl = "CREATE TABLE " + TEST_SIGNED + + " (k VARCHAR NOT NULL PRIMARY KEY, doub DOUBLE, fl FLOAT, inte INTEGER, lon BIGINT, smalli SMALLINT, tinyi TINYINT)"; conn.createStatement().execute(ddl); - ddl = - "CREATE TABLE testUnsigned (k VARCHAR NOT NULL PRIMARY KEY, doub UNSIGNED_DOUBLE, fl UNSIGNED_FLOAT, inte UNSIGNED_INT, lon UNSIGNED_LONG, smalli UNSIGNED_SMALLINT, tinyi UNSIGNED_TINYINT)"; + ddl = "CREATE TABLE " + TEST_UNSIGNED + + " (k VARCHAR NOT NULL PRIMARY KEY, doub UNSIGNED_DOUBLE, fl UNSIGNED_FLOAT, inte UNSIGNED_INT, lon UNSIGNED_LONG, smalli UNSIGNED_SMALLINT, tinyi UNSIGNED_TINYINT)"; conn.createStatement().execute(ddl); conn.commit(); } finally { @@ -137,8 +140,8 @@ public class PowerFunctionEnd2EndIT extends BaseHBaseManagedTimeIT { public void test() throws Exception { Connection conn = DriverManager.getConnection(getUrl()); for (double d : new double[] { 0.0, 1.0, -1.0, 123.1234, -123.1234 }) { - testNumberSpec(conn, d, "testSigned"); - if (d >= 0) testNumberSpec(conn, d, "testUnsigned"); + testNumberSpec(conn, d, TEST_SIGNED); + if (d >= 0) testNumberSpec(conn, d, TEST_UNSIGNED); } } } http://git-wip-us.apache.org/repos/asf/phoenix/blob/ea3b8eaf/phoenix-core/src/it/java/org/apache/phoenix/end2end/PrimitiveTypeIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/PrimitiveTypeIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/PrimitiveTypeIT.java index cc92ea9..b78d144 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/PrimitiveTypeIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/PrimitiveTypeIT.java @@ -29,15 +29,23 @@ import java.util.Properties; import org.apache.phoenix.util.PropertiesUtil; import org.apache.phoenix.util.TestUtil; +import org.junit.BeforeClass; import org.junit.Test; -public class PrimitiveTypeIT extends BaseHBaseManagedTimeIT { - private static void initTableValues(Connection conn) throws Exception { - conn.createStatement().execute("create table T (l bigint not null primary key, b boolean)"); +public class PrimitiveTypeIT extends BaseHBaseManagedTimeTableReuseIT { + + private static final String TABLE_NAME = generateRandomString(); + private static final Properties PROPS = PropertiesUtil.deepCopy(TestUtil.TEST_PROPERTIES); + private static Connection conn; + + @BeforeClass + public static void initTableValues() throws Exception { + conn = DriverManager.getConnection(getUrl(), PROPS); + conn.createStatement().execute( + "create table " + TABLE_NAME + " (l bigint not null primary key, b boolean)"); PreparedStatement stmt = conn.prepareStatement( - "upsert into " + - "T VALUES(?)"); + "upsert into " + TABLE_NAME + " VALUES(?)"); stmt.setLong(1, 2); stmt.execute(); conn.commit(); @@ -45,10 +53,7 @@ public class PrimitiveTypeIT extends BaseHBaseManagedTimeIT { @Test public void testCompareLongGTDecimal() throws Exception { - Properties props = PropertiesUtil.deepCopy(TestUtil.TEST_PROPERTIES); - Connection conn = DriverManager.getConnection(getUrl(), props); - initTableValues(conn); - String query = "SELECT l FROM T where l > 1.5"; + String query = "SELECT l FROM " + TABLE_NAME + " where l > 1.5"; try { PreparedStatement statement = conn.prepareStatement(query); ResultSet rs = statement.executeQuery(); @@ -62,10 +67,7 @@ public class PrimitiveTypeIT extends BaseHBaseManagedTimeIT { @Test public void testCompareLongGTEDecimal() throws Exception { - Properties props = PropertiesUtil.deepCopy(TestUtil.TEST_PROPERTIES); - Connection conn = DriverManager.getConnection(getUrl(), props); - initTableValues(conn); - String query = "SELECT l FROM T where l >= 1.5"; + String query = "SELECT l FROM " + TABLE_NAME + " where l >= 1.5"; try { PreparedStatement statement = conn.prepareStatement(query); ResultSet rs = statement.executeQuery(); @@ -86,10 +88,7 @@ public class PrimitiveTypeIT extends BaseHBaseManagedTimeIT { @Test public void testCompareLongLTDecimal() throws Exception { - Properties props = PropertiesUtil.deepCopy(TestUtil.TEST_PROPERTIES); - Connection conn = DriverManager.getConnection(getUrl(), props); - initTableValues(conn); - String query = "SELECT l FROM T where l < 1.5"; + String query = "SELECT l FROM " + TABLE_NAME + " where l < 1.5"; try { PreparedStatement statement = conn.prepareStatement(query); ResultSet rs = statement.executeQuery(); @@ -108,10 +107,7 @@ public class PrimitiveTypeIT extends BaseHBaseManagedTimeIT { @Test public void testCompareLongLTEDecimal() throws Exception { - Properties props = PropertiesUtil.deepCopy(TestUtil.TEST_PROPERTIES); - Connection conn = DriverManager.getConnection(getUrl(), props); - initTableValues(conn); - String query = "SELECT l FROM T where l <= 1.5"; + String query = "SELECT l FROM " + TABLE_NAME + " where l <= 1.5"; try { PreparedStatement statement = conn.prepareStatement(query); ResultSet rs = statement.executeQuery(); @@ -129,10 +125,7 @@ public class PrimitiveTypeIT extends BaseHBaseManagedTimeIT { } @Test public void testCompareLongGTDecimal2() throws Exception { - Properties props = PropertiesUtil.deepCopy(TestUtil.TEST_PROPERTIES); - Connection conn = DriverManager.getConnection(getUrl(), props); - initTableValues(conn); - String query = "SELECT l FROM T where l > 2.5"; + String query = "SELECT l FROM " + TABLE_NAME + " where l > 2.5"; try { PreparedStatement statement = conn.prepareStatement(query); ResultSet rs = statement.executeQuery(); @@ -151,10 +144,7 @@ public class PrimitiveTypeIT extends BaseHBaseManagedTimeIT { @Test public void testCompareLongGTEDecimal2() throws Exception { - Properties props = PropertiesUtil.deepCopy(TestUtil.TEST_PROPERTIES); - Connection conn = DriverManager.getConnection(getUrl(), props); - initTableValues(conn); - String query = "SELECT l FROM T where l >= 2.5"; + String query = "SELECT l FROM " + TABLE_NAME + " where l >= 2.5"; try { PreparedStatement statement = conn.prepareStatement(query); ResultSet rs = statement.executeQuery(); @@ -173,10 +163,7 @@ public class PrimitiveTypeIT extends BaseHBaseManagedTimeIT { @Test public void testCompareLongLTDecimal2() throws Exception { - Properties props = PropertiesUtil.deepCopy(TestUtil.TEST_PROPERTIES); - Connection conn = DriverManager.getConnection(getUrl(), props); - initTableValues(conn); - String query = "SELECT l FROM T where l < 2.5"; + String query = "SELECT l FROM " + TABLE_NAME + " where l < 2.5"; try { PreparedStatement statement = conn.prepareStatement(query); ResultSet rs = statement.executeQuery(); @@ -199,8 +186,7 @@ public class PrimitiveTypeIT extends BaseHBaseManagedTimeIT { public void testCompareLongLTEDecimal2() throws Exception { Properties props = PropertiesUtil.deepCopy(TestUtil.TEST_PROPERTIES); Connection conn = DriverManager.getConnection(getUrl(), props); - initTableValues(conn); - String query = "SELECT l FROM T where l <= 2.5"; + String query = "SELECT l FROM " + TABLE_NAME + " where l <= 2.5"; try { PreparedStatement statement = conn.prepareStatement(query); ResultSet rs = statement.executeQuery(); @@ -221,16 +207,13 @@ public class PrimitiveTypeIT extends BaseHBaseManagedTimeIT { @Test public void testBooleanAsObject() throws Exception { - Properties props = PropertiesUtil.deepCopy(TestUtil.TEST_PROPERTIES); - Connection conn = DriverManager.getConnection(getUrl(), props); - initTableValues(conn); - String query = "upsert into T values (2, ?)"; + String query = "upsert into " + TABLE_NAME + " values (2, ?)"; try { PreparedStatement statement = conn.prepareStatement(query); statement.setObject(1, new Boolean("false")); statement.execute(); conn.commit(); - statement = conn.prepareStatement("SELECT l,b,? FROM T"); + statement = conn.prepareStatement("SELECT l,b,? FROM " + TABLE_NAME); statement.setObject(1, new Boolean("false")); ResultSet rs = statement.executeQuery(); assertTrue(rs.next());
