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 SliceNode(AlchemyObj): """ Representation of a row in the slice_node 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), 'node_id': Parameter(int, "Node 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 SliceNodes(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_nodes = SliceNode().select() elif isinstance(filter, dict): slices_nodes = SliceNode().select(filter=filter) else: raise PLCInvalidArgument, "Wrong slice_node filter %r"%filter for slice_node in slice_nodes: self.append(slice_node)