update version to 0.0.7

Author: dingxin-tech

pom.xml

@@ -28,7 +28,7 @@
     </parent>
     <groupId>com.aliyun.odps</groupId>
     <artifactId>maxcompute-emulator</artifactId>
-    <version>0.0.6-tpch</version>
+    <version>0.0.7</version>
     <name>maxcompute-emulator</name>
     <description>mock version to access MaxCompute</description>
     <properties>

src/main/java/com/aliyun/odps/utils/SqlRunner.java

@@ -99,6 +99,7 @@ public static String handleAddColumn(String mcSql) throws SQLException {
         // split on whitespace to get column name
         String[] columnDefinitions = columnsPart.split("\\s*,\\s*");
         String tableName = noDatabasePrefix.replaceAll("ALTER TABLE (\\S+) ADD COLUMNS.*", "$1");
+        tableName = unwrapTable(tableName);
 
         String[] alterTableStatements = new String[columnDefinitions.length];
 
@@ -134,6 +135,7 @@ public static String handleDropColumn(String mcSql) throws SQLException {
         String noDatabasePrefix = mcSql.replaceAll("ALTER TABLE \\S+\\.", "ALTER TABLE ");
 
         String tableName = noDatabasePrefix.replaceAll("ALTER TABLE (\\S+) DROP COLUMNS.*", "$1");
+        tableName = unwrapTable(tableName);
         String[] columnsToDrop =
                 noDatabasePrefix.replaceAll("ALTER TABLE \\S+ DROP COLUMNS ", "").split(",");
 
@@ -180,6 +182,7 @@ public static String handleRenameColumn(String mcSql) throws SQLException {
         String noDatabasePrefix = mcSql.replaceAll("ALTER TABLE \\S+\\.", "ALTER TABLE ");
 
         String tableName = noDatabasePrefix.replaceAll("ALTER TABLE (\\S+) CHANGE COLUMN.*", "$1");
+        tableName = unwrapTable(tableName);
         String[] columnToRename =
                 noDatabasePrefix.replaceAll("ALTER TABLE \\S+ CHANGE COLUMN ", "").replace("\\s+", "").split(" ");
         String oldName;
@@ -211,6 +214,7 @@ public static String handleRenameColumn(String mcSql) throws SQLException {
     }
 
     public static SqlLiteSchema getSchema(String tableName) throws SQLException {
+        tableName = unwrapTable(tableName);
         try (Statement stmt = CommonUtils.getConnection().createStatement()) {
             ResultSet rs = stmt.executeQuery(
                     "SELECT schema FROM schemas WHERE table_name = '" + tableName.toUpperCase() + "';");
@@ -229,6 +233,7 @@ public static SqlLiteSchema getSchema(String tableName) throws SQLException {
     }
 
     static void updateSchema(String tableName, SqlLiteSchema schema) throws SQLException {
+        tableName = unwrapTable(tableName);
         try (Statement stmt = CommonUtils.getConnection().createStatement()) {
             stmt.executeUpdate(
                     "UPDATE schemas SET schema = '" + schema.toJson() + "' WHERE table_name = '" + tableName +
@@ -275,4 +280,13 @@ private static String processResultSet(ResultSet resultSet) throws SQLException,
 
         return writer.toString();
     }
+
+    private static String unwrapTable(String tableName) {
+        tableName = tableName.trim();
+        if (tableName.startsWith("`") && tableName.endsWith("`")) {
+            return tableName.substring(1, tableName.length() - 1);
+        } else {
+            return tableName;
+        }
+    }
 }

src/main/resources/banner.txt

@@ -4,5 +4,5 @@
  | |\/| |  / _` | \ \/ / | |       / _ \  | '_ ` _ \  | '_ \  | | | | | __|  / _ \   |  __|   | '_ ` _ \  | | | | | |  / _` | | __|  / _ \  | '__|
  | |  | | | (_| |  >  <  | |____  | (_) | | | | | | | | |_) | | |_| | | |_  |  __/   | |____  | | | | | | | |_| | | | | (_| | | |_  | (_) | | |
  |_|  |_|  \__,_| /_/\_\  \_____|  \___/  |_| |_| |_| | .__/   \__,_|  \__|  \___|   |______| |_| |_| |_|  \__,_| |_|  \__,_|  \__|  \___/  |_|
-                                                      | |                                                                                         v0.0.4
+                                                      | |                                                                                         v0.0.7
                                                       |_|