Method put

mindmeld/query_cache.py:167–200

Adds a ProcessedQuery to the cache Args: key(str): A key generated by QueryCache.get_key() for this example processed_query(ProcessedQuery): The ProcessedQuery generated for this example Returns: integer: The unique id of the query in the

(self, key, processed_query)

        return row[0] if row else None

    def put(self, key, processed_query):
        """
        Adds a ProcessedQuery to the cache

        Args:
            key(str): A key generated by QueryCache.get_key() for this example
            processed_query(ProcessedQuery): The ProcessedQuery generated for this example
        Returns:
            integer: The unique id of the query in the cache.
        """
        data = json.dumps(processed_query.to_cache())

        def commit_to_db(connection):
            cursor = connection.cursor()
            cursor.execute("""
            INSERT OR IGNORE into queries values (?, ?, ?, ?, ?);
            """, (key,
                  data,
                  processed_query.query.text,
                  processed_query.domain,
                  processed_query.intent,
                  ))
            connection.commit()

        if self.memory_connection:
            commit_to_db(self.memory_connection)
            rowid = self.key_to_row_id(key)
            self.batch_writes.append(str(rowid))
            if len(self.batch_writes) == self.batch_write_size:
                self.flush_to_disk()
        else:
            commit_to_db(self.disk_connection)

        return self.key_to_row_id(key)

    @lru_cache(maxsize=1)
    def get(self, row_id):