使用 CQLEngine 更新 UDT 集

Question

我是 Cassandra 的新手，我正在尝试使用 CQLEngine ORM 更新包含 UDT 的集合列，但我不能，而且文档也没有说明自定义类型。

我的代码是；

class MyType(UserType):

    val = columns.Text()
    point = columns.Integer()
    key = columns.Text()

    def __init__(self, val, point, key, **values):
        super().__init__(**values)
        self.val = val
        self.point = point
        self.key = key


class MyModel(Model):

    myid = columns.UUID(primary_key=True)
    set_clm = columns.Set(columns.Integer)
    mytype = columns.Set(UserDefinedType(MyType))

    def __init__(self, set_clm, mytype, **values):
        super().__init__(**values)
        self.myid = uuid4()
        self.set_clm = set_clm
        self.mytype = mytype



s = MyModel.objects(myid="2b3adb7d-9e68-49fc-9aa0-26dbec607f9d").update(
    mytype__add=set(MyType(val="1", point=2, key="3"))
)

MyModel 最初在集合中持有 NULL，但当我尝试更新它时，出现以下错误：

cassandra.InvalidRequest: Error from server: code=2200 [Invalid query] message="Invalid set literal for mytype: value 'point' is not of type frozen<mytype>"

'point' is not of type frozen<mytype> -> 每当我重新运行代码时，这部分随机更改（下次我运行，我会得到相同的错误 'val' 列等）。

任何人都可以帮助我如何添加 UDT 集？

Answer 1

好的。我已经解决了。我正在为那些在 Google.

上找到它的人写下来

这是添加到集合的正确方法：mytype__add={MyType(val="1", point=2, key="3")}

并为 MyType 实现 __hash__ 函数，例如：

def __hash__():
    return hash(self.__repr__())

但具有更智能的 __hash__ 功能。这只是一个例子。希望对其他人有帮助。

使用 CQLEngine 更新 UDT 集

Updating UDT Set with CQLEngine

python

cassandra

cqlengine