grr/server/grr_response_server/databases/mysql_flows.py
def ReadFlowObject(self, client_id, flow_id, cursor=None):
    """Reads a flow object from the database."""
    query = ("SELECT " + self.FLOW_DB_FIELDS +
             "FROM flows WHERE client_id=%s AND flow_id=%s")
    cursor.execute(query, [
        mysql_utils.ClientIDToInt(client_id),
        mysql_utils.FlowIDToInt(flow_id)
    ])
    result = cursor.fetchall()
    if not result:
      raise db.UnknownFlowError(client_id, flow_id)
    row, = result
    return self._FlowObjectFromRow(row)
Reads a flow object from the database.
Reads a flow object from the database.
Reads a flow object from the database .
def ReadFlowObject(self, client_id, flow_id, cursor=None):
    query = ("SELECT " + self.FLOW_DB_FIELDS +
             "FROM flows WHERE client_id=%s AND flow_id=%s")
    cursor.execute(query, [
        mysql_utils.ClientIDToInt(client_id),
        mysql_utils.FlowIDToInt(flow_id)
    ])
    result = cursor.fetchall()
    if not result:
      raise db.UnknownFlowError(client_id, flow_id)
    row, = result
    return self._FlowObjectFromRow(row)
def ReadFlowObject ( self , client_id , flow_id , cursor = None ) : query = ( "SELECT " + self . FLOW_DB_FIELDS + "FROM flows WHERE client_id=%s AND flow_id=%s" ) cursor . execute ( query , [ mysql_utils . ClientIDToInt ( client_id ) , mysql_utils . FlowIDToInt ( flow_id ) ] ) result = cursor . fetchall ( ) if not result : raise db . UnknownFlowError ( client_id , flow_id ) row , = result return self . _FlowObjectFromRow ( row )
Reads a flow object from the database.
Reads a flow object from the database .
"""Reads a flow object from the database."""
self
client_id
flow_id
cursor