pandaserver/taskbuffer/JediCacheSpec.py

0001 """
0002 cache specification for JEDI
0003
0004 """
0005
0006
0007 class JediCacheSpec(object):
0008     # attributes
0009     attributes = (
0010         "main_key",
0011         "sub_key",
0012         "data",
0013         "last_update",
0014     )
0015
0016     # constructor
0017     def __init__(self):
0018         # install attributes
0019         for attr in self.attributes:
0020             object.__setattr__(self, attr, None)
0021
0022     # return map of values
0023     def valuesMap(self):
0024         ret = {}
0025         for attr in self.attributes:
0026             val = getattr(self, attr)
0027             ret[f":{attr}"] = val
0028         return ret
0029
0030     # pack tuple into JediCacheSpec
0031     def pack(self, values):
0032         for i, attr in enumerate(self.attributes):
0033             val = values[i]
0034             object.__setattr__(self, attr, val)
0035
0036     # return column names for INSERT
0037     @classmethod
0038     def columnNames(cls, prefix=None):
0039         ret = ""
0040         if prefix is None:
0041             ret = ",".join(cls.attributes)
0042         else:
0043             ret = ",".join([f"{prefix}.{attr}" for attr in cls.attributes])
0044         return ret
0045
0046     # return expression of bind variables for INSERT
0047     @classmethod
0048     def bindValuesExpression(cls):
0049         values_str = ",".join([f":{attr}" for attr in cls.attributes])
0050         ret = f"VALUES({values_str})"
0051         return ret
0052
0053     # return an expression of bind variables for UPDATE
0054     @classmethod
0055     def bindUpdateChangesExpression(cls):
0056         ret = ",".join(["{0}=:{0}".format(attr) for attr in cls.attributes])
0057         return ret