2

我有一个 ZODB 安装，我必须在其中组织几百万种不同类型的对象。我有一个通用容器类Table，它包含 BTrees 来按属性或这些属性的组合索引对象。数据一致性非常重要，因此我想强制执行，当我写入索引覆盖的任何属性时，索引会自动更新。所以一个简单的obj.a = x应该足以计算所有新的依赖索引条目，检查是否有任何冲突，最后写入索引和值。

一般来说，我很乐意为此使用库，所以我查看了repoze.catalog和IndexedCatalog，但对此并不满意。IndexedCatalog 似乎已经死了很长一段时间，并且没有为对象的更改提供那种一致性。据我所知， repoze.catalog 似乎更常用和更活跃，但也没有提供这种一致性。如果我在这里错过了什么，我很想听听它，并且更喜欢重用而不是重新发明。

所以，除了试图为问题找到一个库之外，我如何看待它，我必须拦截对具有描述符的数据对象属性的写访问，并让Table类执行更改索引的魔法。为此，描述符实例必须知道Table它们必须与哪些实例通信。当前的实现是这样的：

class DatabaseElement(Persistent):
    name = Property(constant_parameters)
    ...

class Property(object):
    ...
    def __set__(self, obj, name, val):
        val = self.check_value(val)
        setattr(obj, '_' + name, val)

生成这些DatabaseElement类时，尚未创建数据库和其中的对象。因此，正如在这个不错的答案中提到的，我可能必须创建一些单例查找机制来查找Table对象，而不是将它们Property作为实例化参数。有没有更优雅的方式？保留描述符本身？欢迎任何建议和最佳实践示例！

4

1 回答 1

0

所以我终于弄清楚了自己。解决方案分为三个部分。不需要丑陋的单身人士。Table提供检查冲突的逻辑，能够在没有丑陋的变通方法的情况下DatabaseElement查找负责人的能力，并注意在写入任何索引值之前更新索引。这里有一些片段，主要线索是. 我也没有在任何地方看到记录。不错的附加功能：它不仅可以验证对单个值的写入，我还可以一次性检查多个索引值的变化。TablePropertyDatabaseElement

class Table(PersistentMapping):
    ....
    def update_indices(self, inst, updated_values_dict):
        changed_indices_keys = self._check_collision(inst, updated_values_dict)
        original_keys = [inst.key(index) for index, tmp_key in changed_indices_keys]
        for (index, tmp_key), key in zip(changed_indices_keys, original_keys):
            self[index][tmp_key] = inst
            try:
                del self[index][key]
            except KeyError:
                pass


class DatabaseElement(Persistent):
    ....
    @property
    def _table(self):
        return self._p_jar and self._p_jar.root()[self.__class__.__name__]

    def _update_indices(self, update_dict, verify=True):
        if verify:
            update_dict = dict((key, getattr(type(self), key).verify(val)) 
                                for key, val in update_dict.items()
                                if key in self._key_properties)
        if not update_dict:
            return
        table = self._table
        table and table.update_indices(self, update_dict)


class Property(object):
    ....
    def __set__(self, obj, val):
        validated_val = self.validator(obj, self.name, val)
        if self.indexed:
            obj._update_indices({self.name: val}, verify=False)
        setattr(obj, self.hidden_name, validated_val)
于 2012-10-01T08:44:37.740 回答