X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=PLC%2FEventObjects.py;h=6dc45731713deb1674e17920208391209ed9f736;hb=1b1b5a911bb005644baabb87ecba60602228a070;hp=25df867046f1de505f7bb732938887c4420b6f32;hpb=4604006f235246d8480da96e488c0c7fd6a09c91;p=plcapi.git diff --git a/PLC/EventObjects.py b/PLC/EventObjects.py index 25df867..6dc4573 100644 --- a/PLC/EventObjects.py +++ b/PLC/EventObjects.py @@ -4,8 +4,6 @@ # Tony Mack # Copyright (C) 2006 The Trustees of Princeton University # -# $Id: EventObjects.py 348 2007-05-10 14:13:51Z thierry $ -# from PLC.Faults import * from PLC.Parameter import Parameter @@ -15,9 +13,9 @@ from PLC.Table import Row, Table class EventObject(Row): """ - Representation of a row in the event_object table. + Representation of a row in the event_object table. """ - + table_name = 'event_object' primary_key = 'event_id' fields = { @@ -25,39 +23,34 @@ class EventObject(Row): 'person_id': Parameter(int, "Identifier of person responsible for event, if any"), 'node_id': Parameter(int, "Identifier of node responsible for event, if any"), 'fault_code': Parameter(int, "Event fault code"), - 'call_name': Parameter(str, "Call responsible for this event"), - 'call': Parameter(str, "Call responsible for this event, including paramters"), - 'message': Parameter(str, "High level description of this event"), + 'call_name': Parameter(str, "Call responsible for this event"), + 'call': Parameter(str, "Call responsible for this event, including paramters"), + 'message': Parameter(str, "High level description of this event"), 'runtime': Parameter(float, "Runtime of event"), 'time': Parameter(int, "Date and time that the event took place, in seconds since UNIX epoch", ro = True), 'object_id': Parameter(int, "ID of objects affected by this event"), - 'object_type': Parameter(str, "What type of object is this event affecting") - } + 'object_type': Parameter(str, "What type of object is this event affecting") + } class EventObjects(Table): """ - Representation of row(s) from the event_object table in the database. + Representation of row(s) from the event_object table in the database. """ def __init__(self, api, event_filter = None, columns = None): Table.__init__(self, api, EventObject, columns) - - sql = "SELECT %s FROM view_event_objects WHERE True" % \ + + sql = "SELECT %s FROM view_event_objects WHERE True" % \ ", ".join(self.columns) - - if event_filter is not None: - if isinstance(event_filter, (list, tuple, set)): + + if event_filter is not None: + if isinstance(event_filter, (list, tuple, set, int)): event_filter = Filter(EventObject.fields, {'event_id': event_filter}) sql += " AND (%s) %s" % event_filter.sql(api, "OR") elif isinstance(event_filter, dict): event_filter = Filter(EventObject.fields, event_filter) sql += " AND (%s) %s" % event_filter.sql(api, "AND") - elif isinstance (event_filter, int): - event_filter = Filter(EventObject.fields, {'event_id':[event_filter]}) - sql += " AND (%s) %s" % event_filter.sql(api, "AND") else: - raise PLCInvalidArgument, "Wrong event object filter %r"%event_filter -# with new filtering, caller needs to set this explicitly -# sql += " ORDER BY %s" % EventObject.primary_key - - self.selectall(sql) + raise PLCInvalidArgument("Wrong event object filter %r"%event_filter) + + self.selectall(sql)