refactor: add sql logs

Author: tianlu-root

config/logback.xml

@@ -1,6 +1,7 @@
 <configuration scan="true" scanPeriod="60 seconds" debug="false">
 
     <property name="LOG_HOME" value="./logs"/>
+    <property name ="SQL_LEVEL" value="DEBUG"/>
 
     <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
         <encoder>
@@ -22,13 +23,27 @@
         </encoder>
     </appender>
 
+    <appender name="sql" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <FileNamePattern>${LOG_HOME}/%d{yyyy-MM-dd}-sql.log</FileNamePattern>
+            <MaxHistory>30</MaxHistory>
+        </rollingPolicy>
+        <encoder>
+            <charset>UTF-8</charset>
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} : %msg%n</pattern>
+        </encoder>
+    </appender>
+
     <root level="INFO">
         <appender-ref ref="console"/>
         <appender-ref ref="root" />
     </root>
 
-    <logger name="access" additivity="false" level="INFO">
-        <appender-ref ref="error_db_appender"/>
+    <logger name="datart.data.provider.jdbc.adapters" level="${SQL_LEVEL}">
+        <appender-ref ref="sql"/>
+    </logger>
+    <logger name="datart.data.provider.local.LocalDB" level="${SQL_LEVEL}">
+        <appender-ref ref="sql"/>
     </logger>
 
 </configuration>

data-providers/src/main/java/datart/data/provider/local/LocalDB.java

@@ -43,16 +43,12 @@
 import java.util.concurrent.ConcurrentHashMap;
 
 @Slf4j
-public class
-LocalDB {
+public class LocalDB {
 
     private static final String MEM_URL = "jdbc:h2:mem:/";
 
     private static final String H2_PARAM = ";LOG=0;DATABASE_TO_UPPER=false;MODE=MySQL;CASE_INSENSITIVE_IDENTIFIERS=TRUE;CACHE_SIZE=65536;LOCK_MODE=0;UNDO_LOG=0";
 
-    private static String fileUrl;
-
-    private static final String TABLE_CREATE_SQL_TEMPLATE = "CREATE TABLE `%s` ( %s )";
 
     public static final SqlDialect SQL_DIALECT = new H2Dialect();
 
@@ -283,6 +279,8 @@ private static Dataframe execute(Connection connection, QueryScript queryScript,
 
         String sql = render.render(true, false, false);
 
+        log.debug(sql);
+
         ResultSet resultSet = connection.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY).executeQuery(sql);
         PageInfo pageInfo = executeParam.getPageInfo();
         resultSet.last();
@@ -312,7 +310,7 @@ private static String getDatabaseUrl(String database) {
         } else {
             database = toDatabase(database);
         }
-        return fileUrl = String.format("jdbc:h2:file:%s/%s" + H2_PARAM, getDbFileBasePath(), database);
+        return String.format("jdbc:h2:file:%s/%s" + H2_PARAM, getDbFileBasePath(), database);
     }
 
     private static String getDbFileBasePath() {

server/src/main/java/datart/server/service/impl/DataProviderServiceImpl.java

@@ -432,7 +432,6 @@ private Map<String, Column> parseSchema(String model) {
                 }
             } else {
                 // 兼容1.0.0-beta.1以前的版本
-                jsonObject = jsonObject.getJSONObject("columns");
                 for (String key : jsonObject.keySet()) {
                     ValueType type = ValueType.valueOf(jsonObject.getJSONObject(key).getString("type"));
                     schema.put(key, new Column(key, type));