sql.py 文件源码

def insert_message(self, trans, message):
        values = message_values(message)
        if self.message_cache.get(message.id) == values:
            self.logger.debug(f"Message lookup for {message.id} is already up-to-date")
            return

        self.logger.debug(f"Inserting message {message.id}")
        ins = p_insert(self.tb_messages) \
                .values(values) \
                .on_conflict_do_nothing(index_elements=['message_id'])
        trans.execute(ins)
        self.message_cache[message.id] = values

        self.upsert_user(trans, message.author)
        self.insert_mentions(trans, message)

    # Mentions