from types import StringTypes import time import re import datetime from PLC.Faults import * from PLC.Parameter import Parameter, Mixed from PLC.Debug import profile from PLC.Timestamp import Timestamp from PLC.Storage.AlchemyObject import AlchemyObj class SiteAddress(AlchemyObj): """ Representation of a row in the site_address 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 = 'site_address' fields = { 'site_id': Parameter(int, "Slice identifier", primary_key=True), 'address_id': Parameter(int, "Address 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 SiteAddresses(list): """ Representation of row(s) from the site address 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: site_addresses = SiteAddress().select() elif isinstance(filter, dict): site_addresses = SiteAddress().select(filter=filter) else: raise PLCInvalidArgument, "Wrong site_address filter %r"%filter for site_address in site_address: site_address = SiteAddress(self.api, object=site_address) self.append(site_address)