(*) full support for database caching, including SliceAttributes
[plcapi.git] / PLC / SliceAttributes.py
1 from PLC.Faults import *
2 from PLC.Parameter import Parameter
3 from PLC.Filter import Filter
4 from PLC.Table import Row, Table
5 from PLC.SliceAttributeTypes import SliceAttributeType, SliceAttributeTypes
6
7 class SliceAttribute(Row):
8     """
9     Representation of a row in the slice_attribute table. To use,
10     instantiate with a dict of values.
11     """
12
13     table_name = 'slice_attribute'
14     primary_key = 'slice_attribute_id'
15     fields = {
16         'slice_attribute_id': Parameter(int, "Slice attribute identifier"),
17         'slice_id': Parameter(int, "Slice identifier"),
18         'node_id': Parameter(int, "Node identifier, if a sliver attribute"),
19         'attribute_type_id': SliceAttributeType.fields['attribute_type_id'],
20         'name': SliceAttributeType.fields['name'],
21         'description': SliceAttributeType.fields['description'],
22         'min_role_id': SliceAttributeType.fields['min_role_id'],
23         # XXX Arbitrary max, make configurable
24         'value': Parameter(str, "Slice attribute value", max = 254),
25         'peer_id': Parameter(int, "Peer at which this node is managed", nullok = True),
26         }
27
28 class SliceAttributes(Table):
29     """
30     Representation of row(s) from the slice_attribute table in the
31     database.
32     """
33
34     def __init__(self, api, slice_attribute_filter = None, columns = None):
35         Table.__init__(self, api, SliceAttribute, columns)
36
37         sql = "SELECT %s FROM view_slice_attributes WHERE True" % \
38               ", ".join(self.columns)
39
40         if slice_attribute_filter is not None:
41             if isinstance(slice_attribute_filter, (list, tuple, set)):
42                 slice_attribute_filter = Filter(SliceAttribute.fields, {'slice_attribute_id': slice_attribute_filter})
43             elif isinstance(slice_attribute_filter, dict):
44                 slice_attribute_filter = Filter(SliceAttribute.fields, slice_attribute_filter)
45             sql += " AND (%s)" % slice_attribute_filter.sql(api)
46
47         self.selectall(sql)