sql.py 文件源码

def insert_detail_item(cls, item):
        sql = "INSERT INTO `py_review_detail`(`asin`, `review_id`, `reviewer`, `review_url`, `star`, `date`, `title`, `content`) " \
              "VALUES ('%s', '%s', %s, '%s', '%s', '%s', %s, %s)" % \
              (item['asin'], item['review_id'], cls.conn.escape(item['reviewer']), item['review_url'], item['star'],
               item['date'], cls.conn.escape(item['title']), cls.conn.escape(item['content']))
        try:
            if cls.check_exist_detail(item['asin'], item['review_id']) is not True:
                print('save review detail--[asin]:', item['asin'], '[reviewID]:', item['review_id'])
                cls.cursor.execute(sql)
                cls.conn.commit()
        except pymysql.MySQLError as e:
            print(e)
            cls.conn.rollback()
        pass