Skip to content

Commit e431217

Browse files
authored
Merge pull request #301 from qe-present/master
修改建表成功后判断逻辑以及插入数据全部重复的特殊情况提示
2 parents 478e1bd + 7b79f3f commit e431217

2 files changed

Lines changed: 5 additions & 2 deletions

File tree

feapder/commands/create/create_table.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -141,8 +141,9 @@ def create(self, table_name):
141141
unique=unique,
142142
)
143143
print(sql)
144-
145-
if self._db.execute(sql):
144+
result=self._db.execute(sql)
145+
# 建立表成功。受影响的行数为 0,因此返回0
146+
if result==0:
146147
print("\n%s 创建成功" % table_name)
147148
print("注意手动检查下字段类型,确保无误!!!")
148149
else:

feapder/pipelines/mysql_pipeline.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,8 @@ def save_items(self, table, items: List[Dict]) -> bool:
4545
log.info(
4646
"共导出 %s 条数据 到 %s, 重复 %s 条" % (datas_size, table, datas_size - add_count)
4747
)
48+
else:
49+
log.debug("没有插入数据,可能全部重复")
4850

4951
return add_count != None
5052

0 commit comments

Comments
 (0)