From 80ac2c30478aba65fb17f91f54df6bf5214352d3 Mon Sep 17 00:00:00 2001 From: Jihoon Son Date: Mon, 7 Sep 2015 15:21:55 +0900 Subject: [PATCH] TAJO-1819 --- .../apache/tajo/catalog/store/XMLCatalogSchemaManager.java | 4 ++-- .../tajo/catalog/store/TestXMLCatalogSchemaManager.java | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/tajo-catalog/tajo-catalog-server/src/main/java/org/apache/tajo/catalog/store/XMLCatalogSchemaManager.java b/tajo-catalog/tajo-catalog-server/src/main/java/org/apache/tajo/catalog/store/XMLCatalogSchemaManager.java index c36426e0ec..0ecd90a377 100644 --- a/tajo-catalog/tajo-catalog-server/src/main/java/org/apache/tajo/catalog/store/XMLCatalogSchemaManager.java +++ b/tajo-catalog/tajo-catalog-server/src/main/java/org/apache/tajo/catalog/store/XMLCatalogSchemaManager.java @@ -239,14 +239,14 @@ private boolean checkExistenceByQuery(PreparedStatement pstmt, BaseSchema baseSc } for (; paramIdx <= pstmt.getParameterMetaData().getParameterCount(); paramIdx++) { - pstmt.setString(paramIdx, params[paramIdx-1]); + pstmt.setString(paramIdx, params[paramIdx-1].toUpperCase()); } ResultSet rs = null; try { rs = pstmt.executeQuery(); while (rs.next()) { - if (rs.getString(1).equals(params[params.length - 1].toUpperCase())) { + if (rs.getString(1).toUpperCase().equals(params[params.length - 1].toUpperCase())) { result = true; break; } diff --git a/tajo-catalog/tajo-catalog-server/src/test/java/org/apache/tajo/catalog/store/TestXMLCatalogSchemaManager.java b/tajo-catalog/tajo-catalog-server/src/test/java/org/apache/tajo/catalog/store/TestXMLCatalogSchemaManager.java index d5b0403efd..f53beffda6 100644 --- a/tajo-catalog/tajo-catalog-server/src/test/java/org/apache/tajo/catalog/store/TestXMLCatalogSchemaManager.java +++ b/tajo-catalog/tajo-catalog-server/src/test/java/org/apache/tajo/catalog/store/TestXMLCatalogSchemaManager.java @@ -408,6 +408,7 @@ public void testCheckExistance() throws Exception { manager.createBaseSchema(conn); assertThat(manager.checkExistence(conn, DatabaseObjectType.TABLE, "TESTTABLE1"), is(true)); + assertThat(manager.checkExistence(conn, DatabaseObjectType.TABLE, "testtable2"), is(true)); assertThat(manager.checkExistence(conn, DatabaseObjectType.TABLE, "TESTTABLE3"), is(false)); assertThat(manager.checkExistence(conn, DatabaseObjectType.INDEX, "testtable1", "TESTINDEX1"), is(true)); assertThat(manager.checkExistence(conn, DatabaseObjectType.TRIGGER, "TESTTRIGGER1"), is(true));