diff --git a/feapder/commands/create/create_table.py b/feapder/commands/create/create_table.py index 2358da7f..15162782 100644 --- a/feapder/commands/create/create_table.py +++ b/feapder/commands/create/create_table.py @@ -141,8 +141,9 @@ def create(self, table_name): unique=unique, ) print(sql) - - if self._db.execute(sql): + result=self._db.execute(sql) + # 建立表成功。受影响的行数为 0,因此返回0 + if result==0: print("\n%s 创建成功" % table_name) print("注意手动检查下字段类型,确保无误!!!") else: diff --git a/feapder/pipelines/mysql_pipeline.py b/feapder/pipelines/mysql_pipeline.py index 8899761b..3ffb3fc1 100644 --- a/feapder/pipelines/mysql_pipeline.py +++ b/feapder/pipelines/mysql_pipeline.py @@ -45,6 +45,8 @@ def save_items(self, table, items: List[Dict]) -> bool: log.info( "共导出 %s 条数据 到 %s, 重复 %s 条" % (datas_size, table, datas_size - add_count) ) + else: + log.debug("没有插入数据,可能全部重复") return add_count != None