add update jd attr

update_jd_attr.py

@@ -124,8 +124,8 @@ def update_jd_attr_by_class(conf: dict):
                 if len(db_result) == 0:
                     insert_sql = "insert into lie_shop_attr (class_id, attr_id, attr_name, unit, enum_value, input_type, is_required, status, platform, create_time) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s)"
                     # 谨慎起见 先不插入 防止破坏数据库原数据
-                    # cursor.execute(query=insert_sql, args=(class_id, attr_id, attr_name, unit, enum_value, input_type, is_required, status, platform, create_time, ))
-                    # db.commit()
+                    cursor.execute(query=insert_sql, args=(class_id, attr_id, attr_name, unit, enum_value, input_type, is_required, status, platform, create_time, ))
+                    db.commit()
                     print(insert_sql % (class_id, attr_id, attr_name, unit, enum_value, input_type, is_required, status, platform, create_time))
                     # 把sql语句输出到一个文件中
                 else:
@@ -211,8 +211,8 @@ def update_ext_attr_by_class_ids(conf: dict):
             if len(db_result) == 0:
                 # 不存在时
                 insert_sql = "insert into lie_shop_attr (class_id, attr_id, attr_name, unit, enum_value, input_type, is_required, status, platform, create_time) values (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s)"
-                # cursor.execute(query=insert_sql, args=(class_id, attr_id, attr_name, unit, enum_value, input_type, is_required, status, platform, create_time,))
-                # db.commit()
+                cursor.execute(query=insert_sql, args=(class_id, attr_id, attr_name, unit, enum_value, input_type, is_required, status, platform, create_time,))
+                db.commit()
                 print(insert_sql % (class_id, attr_id, attr_name, unit, enum_value, input_type, is_required, status, platform, create_time))
             else:
                 update_sql = ""