database.py 文件源码

def upsert_seed_list(self, torrent_info):
        tid, name, tracker = torrent_info

        while True:
            if name in self.cache_torrent_name:
                raw_sql = "UPDATE `seed_list` SET `{cow}` = {id:d} WHERE `title`='{name}'"
                break
            else:
                exist = "SELECT COUNT(*) FROM `seed_list` WHERE `title`='{}'".format(pymysql.escape_string(name))
                if self.exec(sql=exist)[0] == 0:
                    raw_sql = "INSERT INTO `seed_list` (`title`,`{cow}`) VALUES ('{name}',{id:d})"
                    break
                else:
                    self.cache_torrent_list()

        sql = raw_sql.format(cow=tracker, name=pymysql.escape_string(name), id=tid)
        return self.exec(sql=sql)