cco/cybertools
3
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

make indexes configurable

Browse source 
git-svn-id: svn://svn.cy55.de/Zope3/src/cybertools/trunk@2019 fd906abe-77d9-0310-91a1-e0d9ade77398
This commit is contained in:
helmutm 2007-09-09 19:45:54 +00:00
parent 809a06d3ab
commit a53b5d7304
2 changed files with 21 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
tracking/btree.py
View file

@ -57,11 +57,14 @@ class Track(Persistent):
implements(ITrack) implements(ITrack)
metadata_attributes = ('taskId', 'runId', 'userName', 'timeStamp') metadata_attributes = ('taskId', 'runId', 'userName', 'timeStamp')
index_attributes = metadata_attributes
@property @property
def metadata(self): def metadata(self):
return dict((attr, getattr(self, attr)) for attr in self.metadata_attributes) return dict((attr, getattr(self, attr)) for attr in self.metadata_attributes)
indexdata = metadata
def __init__(self, taskId, runId, userName, data={}): def __init__(self, taskId, runId, userName, data={}):
self.taskId = taskId self.taskId = taskId
self.runId = runId self.runId = runId
@ -90,7 +93,8 @@ class TrackingStorage(BTreeContainer):
trackNum = runId = 0 trackNum = runId = 0
runs = None runs = None
indexAttributes = ('taskId', 'runId', 'userName', 'timeStamp') #indexAttributes = ('taskId', 'runId', 'userName', 'timeStamp')
indexAttributes = Track.index_attributes
def __init__(self, *args, **kw): def __init__(self, *args, **kw):
super(TrackingStorage, self).__init__(*args, **kw) super(TrackingStorage, self).__init__(*args, **kw)
@ -101,6 +105,15 @@ class TrackingStorage(BTreeContainer):
self.currentRuns = OOBTree.OOBTree() self.currentRuns = OOBTree.OOBTree()
self.taskUsers = OOBTree.OOBTree() self.taskUsers = OOBTree.OOBTree()
def setupIndexes(self):
changed = False
for idx in self.indexAttributes:
if idx not in self.indexes:
self.indexes[idx] = FieldIndex()
changed = True
if changed:
self.reindexTracks()
def idFromNum(self, num): def idFromNum(self, num):
return '%07i' % (num) return '%07i' % (num)
@ -163,11 +176,13 @@ class TrackingStorage(BTreeContainer):
return trackId return trackId
def indexTrack(self, trackNum, track): def indexTrack(self, trackNum, track):
md = track.metadata ixd = track.indexdata
for attr in self.indexAttributes: for attr in self.indexAttributes:
self.indexes[attr].index_doc(trackNum, md[attr]) value = ixd[attr]
taskId = md['taskId'] if value is not None:
userName = md['userName'] self.indexes[attr].index_doc(trackNum, value)
taskId = ixd['taskId']
userName = ixd['userName']
if taskId not in self.taskUsers: if taskId not in self.taskUsers:
self.taskUsers[taskId] = OOBTree.OOTreeSet() self.taskUsers[taskId] = OOBTree.OOTreeSet()
self.taskUsers[taskId].update([userName]) self.taskUsers[taskId].update([userName])

1
tracking/interfaces.py
View file

@ -44,6 +44,7 @@ class ITrack(Interface):
data = Attribute('The data for this track, typically a mapping') data = Attribute('The data for this track, typically a mapping')
metadata = Attribute('A mapping with the track\'s metadata') metadata = Attribute('A mapping with the track\'s metadata')
indexdata = Attribute('A mapping with the data to be used for indexing')
class ITrackingStorage(Interface): class ITrackingStorage(Interface):