Ver código fonte

fix pck

Signed-off-by: AE86 <836391306@qq.com>
AE86 1 ano atrás
pai
commit
0ba325157d

+ 5 - 6
dbsyncer-parser/src/main/java/org/dbsyncer/parser/consumer/AbstractConsumer.java

@@ -3,17 +3,16 @@
  */
 package org.dbsyncer.parser.consumer;
 
-import org.dbsyncer.sdk.enums.ChangedEventTypeEnum;
-import org.dbsyncer.sdk.listener.ChangedEvent;
-import org.dbsyncer.sdk.listener.event.DDLChangedEvent;
-import org.dbsyncer.sdk.listener.Watcher;
-import org.dbsyncer.parser.ProfileComponent;
-import org.dbsyncer.parser.flush.impl.BufferActuatorRouter;
 import org.dbsyncer.parser.LogService;
 import org.dbsyncer.parser.LogType;
+import org.dbsyncer.parser.ProfileComponent;
+import org.dbsyncer.parser.flush.impl.BufferActuatorRouter;
 import org.dbsyncer.parser.model.Mapping;
 import org.dbsyncer.parser.model.Meta;
 import org.dbsyncer.parser.model.TableGroup;
+import org.dbsyncer.sdk.listener.ChangedEvent;
+import org.dbsyncer.sdk.listener.Watcher;
+import org.dbsyncer.sdk.listener.event.DDLChangedEvent;
 import org.dbsyncer.sdk.listener.event.SqlChangedEvent;
 
 import java.util.List;

+ 6 - 2
dbsyncer-storage/src/main/test/LuceneFactoryTest.java

@@ -1,3 +1,7 @@
+/**
+ * DBSyncer Copyright 2020-2023 All Rights Reserved.
+ */
+
 import org.apache.lucene.analysis.Analyzer;
 import org.apache.lucene.analysis.TokenStream;
 import org.apache.lucene.analysis.cn.smart.SmartChineseAnalyzer;
@@ -36,8 +40,8 @@ import org.apache.lucene.util.BytesRef;
 import org.dbsyncer.common.model.Paging;
 import org.dbsyncer.common.util.CollectionUtils;
 import org.dbsyncer.common.util.RandomUtil;
+import org.dbsyncer.sdk.constant.ConfigConstant;
 import org.dbsyncer.sdk.constant.ConnectorConstant;
-import org.dbsyncer.storage.constant.ConfigConstant;
 import org.dbsyncer.storage.enums.StorageDataStatusEnum;
 import org.dbsyncer.storage.impl.SnowflakeIdWorker;
 import org.dbsyncer.storage.lucene.Option;
@@ -131,7 +135,7 @@ public class LuceneFactoryTest {
         } catch (InterruptedException e) {
             logger.error(e.getMessage());
         } catch (IOException e) {
-            e.printStackTrace();
+            logger.error(e.getMessage());
         }
 
         TimeUnit.SECONDS.sleep(3);

+ 1 - 1
dbsyncer-web/src/main/resources/application.properties

@@ -49,7 +49,7 @@ dbsyncer.parser.table.group.buffer-period-millisecond=300
 
 #storage
 # 数据存储类型:disk(默认)/mysql(推荐生产环境使用)
-# false: 保存磁盘/data/config(驱动配置)|data(按驱动分别存储增量数据)|log(系统日志)}
+# disk-磁盘:/data/config(驱动配置)|data(按驱动分别存储增量数据)|log(系统日志)
 dbsyncer.storage.type=disk
 dbsyncer.storage.mysql.url=jdbc:mysql://127.0.0.1:3306/dbsyncer?rewriteBatchedStatements=true&seUnicode=true&characterEncoding=UTF8&serverTimezone=Asia/Shanghai&useSSL=false&verifyServerCertificate=false&autoReconnect=true
 dbsyncer.storage.mysql.username=root