from types import StringTypes import time import re import datetime from PLC.Faults import * from PLC.Parameter import Parameter, Mixed from PLC.Filter import Filter from PLC.Debug import profile from PLC.Timestamp import Timestamp from PLC.Storage.AlchemyObject import AlchemyObj class SlicePerson(AlchemyObj): """ Representation of a row in the slice_person table. To use, optionally instantiate with a dict of values. Update as you would a dict. Commit to the database with sync().To use, instantiate with a dict of values. """ tablename = 'slice_person' fields = { 'slice_id': Parameter(int, "Slice identifier", primary_key=True), 'person_id': Parameter(int, "Person identifier", indexed=True), } tags = {} def sync(self, commit = True, validate=True): """ Add the record """ AlchemyObj.sync(self, commit, validate) AlchemyObj.insert(self, dict(self)) def delete(self, commit = True): """ Delete existing slice. """ AlchemyObj.delete(self, dict(self)) class SlicePersons(list): """ Representation of row(s) from the slices table in the database. """ def __init__(self, api, filter = None, columns = None): # the view that we're selecting upon: start with view_slices if not filter: slice_persons = SlicePerson().select() elif isinstance(filter, dict): slice_persons = SlicePerson().select(filter=filter) else: raise PLCInvalidArgument, "Wrong slice_person filter %r"%filter for slice_person in slice_persons: self.append(slice_person)