Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 3 additions & 2 deletions feapder/commands/create/create_table.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down
2 changes: 2 additions & 0 deletions feapder/pipelines/mysql_pipeline.py
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down