improvement: make all spark sql keyword uppercase

apache · Mar 5, 2024 · f2e0d8d · f2e0d8d
1 parent 3b700b4
commit f2e0d8d
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/integration-test/src/test/java/com/datastrato/gravitino/integration/test/spark/SparkIT.java b/integration-test/src/test/java/com/datastrato/gravitino/integration/test/spark/SparkIT.java
@@ -21,7 +21,7 @@ public class SparkIT extends SparkEnvIT {
 
   @BeforeEach
   void init() {
-    sql("use " + hiveCatalogName);
+    sql("USE " + hiveCatalogName);
   }
 
   @Test
@@ -33,7 +33,7 @@ void testLoadCatalogs() {
   @Test
   void testCreateAndLoadSchema() {
     String testDatabaseName = "t_create1";
-    sql("create database " + testDatabaseName);
+    sql("CREATE DATABASE " + testDatabaseName);
     Map<String, String> databaseMeta = getDatabaseMetadata(testDatabaseName);
     Assertions.assertFalse(databaseMeta.containsKey("Comment"));
     Assertions.assertTrue(databaseMeta.containsKey("Location"));
@@ -63,11 +63,11 @@ void testDropSchema() {
     Set<String> databases = getDatabases();
     Assertions.assertFalse(databases.contains(testDatabaseName));
 
-    sql("create database " + testDatabaseName);
+    sql("CREATE DATABASE " + testDatabaseName);
     databases = getDatabases();
     Assertions.assertTrue(databases.contains(testDatabaseName));
 
-    sql("drop database " + testDatabaseName);
+    sql("DROP DATABASE " + testDatabaseName);
     databases = getDatabases();
     Assertions.assertFalse(databases.contains(testDatabaseName));