2

私は次の自己参照 (ツリー) ノードを持っており、計算されたプロパティuuid_pathとでフィルター処理/並べ替えを行いたいと考えていname_pathます。

class Node (db.Model):
    id = db.Column (db.Integer, db.Sequence ('node_id_seq'), primary_key=True)

    ###########################################################################

    root_id = db.Column (db.Integer, db.ForeignKey (id, ondelete='CASCADE'),
        index=True)

    nodes = db.relationship ('Node',
        cascade='all, delete-orphan', lazy='dynamic',
        primaryjoin='Node.id==Node.root_id',
        backref=db.backref ('root', remote_side=id))

    ###########################################################################

    _uuid = db.Column (db.String (36), nullable=False, index=True, unique=True,
        name = 'uuid')
    _name = db.Column (db.Unicode (256), nullable=False, index=True,
        name = 'name')

    ###########################################################################

    @hybrid_property
    def uuid (self):
        return self._uuid

    @hybrid_property
    def name (self):
        return self._name
    @name.setter
    def name (self, value):
        self._name = value

    ###########################################################################

    def __init__ (self, name, root, mime=None, uuid=None):

        self.root = root
        self._uuid = uuid if uuid else str (uuid_random ())
        self._name = unicode (name) if name is not None else None

    def __repr__ (self):

        return u'<Node@%x: %s>' % (self.id if self.id else 0, self._name)

    ###########################################################################

    @hybrid_property
    def uuid_path (self):
        node, path = self, []
        while node:

            path.insert (0, node.uuid)
            node = node.root

        return os.path.sep.join (path)

    @hybrid_property
    def name_path (self):
        node, path = self, []
        while node:

            path.insert (0, node.name)
            node = node.root

        return os.path.sep.join (path)

    ###########################################################################

Nodeインスタンスを取得して egsubnodeを実行すると、 egsubnode.name_pathが正しく取得されroot/subnodeます。Node.name_pathしかし、 （フィルタリング/ソートのために）使用しようとすると、SQLAlchemyは文句を言います：

Neither 'InstrumentedAttribute' object nor 'Comparator' object associated with Node.root has an attribute 'name'.

次のようなものを紹介する必要があると確信しています。

class Node (db.Model):

    @hybrid_property
    def name_path (self):
        node, path = self, []
        while node:

            path.insert (0, node.name)
            node = node.root

        return os.path.sep.join (path)

    @name_path.expression
    def name_path (cls):
        ## Recursive SQL expression??

@name_path.expressionしかし、 （または@uuid_path.expression）の正しい定義を得るのに苦労しています。ルート ノードから問題のノードまでのパスを提供するように SQL に指示する必要があります。

SQLAlchemy にパス値を繰り返し計算するように指示したため、これが必要な理由がわかりません。ご協力いただきありがとうございます。

4

2 に答える 2

0

完全を期すために、zzzeek のhttps://gist.github.com/4625858からのフィードバックを含めました。

from sqlalchemy.sql.expression import ColumnElement ## !!
from sqlalchemy.ext.hybrid import hybrid_property
from sqlalchemy.ext.compiler import compiles
from sqlalchemy import inspect

class UuidPathColumn (ColumnElement):
    def __init__(self, entity):
        insp = inspect (entity)
        self.entity = insp.selectable

@compiles (UuidPathColumn)
def compile_uuid_path_column (element, compiler, **kwargs):
    return "%s.uuid_path" % compiler.process (element.entity, ashint=True)

class NamePathColumn (ColumnElement):
    def __init__(self, entity):
        insp = inspect (entity)
        self.entity = insp.selectable

@compiles (NamePathColumn)
def compile_name_path_column (element, compiler, **kwargs):
    return "%s.name_path" % compiler.process (element.entity, ashint=True)

ColumnElementこれを機能させるには、 を使用する( を使用しないColumnClause)ことが重要です。関連するコードはnode.py、name_path、およびuuid_pathにあります。これは SQLAlchemy 0.8 と PostgreSQL 9.2 で実装されています。

于 2013-01-24T19:02:30.183 に答える
0

PostgreSQL と SQLAlchemy を微調整した後、解決策があると思います: (1) まず、クエリを SQL の関数として記述し、(2) 2 番目に正しい SQLAlchemy グルーを提供します。

SQL 部分はWITH RECURSIVECTEを使用します。

CREATE OR REPLACE FUNCTION name_path(node)
  RETURNS text AS
$BODY$

WITH RECURSIVE graph (id, root_id, id_path, name_path) AS (
    SELECT n.id, n.root_id, ARRAY[n.id], ARRAY[n.name]
    FROM node n
UNION
    SELECT n.id, n.root_id, id_path||ARRAY[n.id], name_path||ARRAY[n.name]
    FROM node n, graph g
    WHERE n.root_id = g.id)

SELECT array_to_string (g.name_path, '/','.*')
FROM graph g
WHERE (g.id_path[1] = $1.base_id OR g.root_id IS NULL)
AND (g.id = $1.id)

$BODY$
  LANGUAGE sql STABLE
  COST 100;
ALTER FUNCTION name_path(node)
  OWNER TO webed;

SQLAlchemy 側は次のようになります。

class NamePathColumn (ColumnClause):
    pass

@compiles (NamePathColumn)
def compile_name_path_column (element, compiler, **kwargs):
    return 'node.name_path' ## something missing?

と

class Node (db.Model):

    def get_path (self, field):

        @cache.version (key=[self.uuid, 'path', field])
        def cached_path (self, field):

            if self.root:
                return self.root.get_path (field) + [getattr (self, field)]
            else:
                return [getattr (self, field)]

        if field == 'uuid':
            return cached_path (self, field)
        else:
            return cached_path.uncached (self, field)

    @hybrid_property
    def name_path (self):
        return os.path.sep.join (self.get_path (field='name'))

    @name_path.expression
    def name_path (cls):
        return NamePathColumn (cls)

私が純粋な Python 側にいる場合は、DB へのアクセスを避けますが、アクセスNode.name_pathした方がおそらく高速になるでしょう。私がまだ確信が持てない唯一のことは、どのパラメーターcompile_name_path_columnも考慮していないということです。element, compiler, **kwargs

SAとPGで約1.5日間いじってから、これを調理したばかりなので、まだ改善の余地がある可能性が非常に高い. このアプローチに関するコメントをいただければ幸いです。ありがとう。

于 2013-01-24T15:54:48.527 に答える