postgresクエリの問題の説明、サンプルデータ、および一意の値のフィルタリングを参照してください。SQLをクエリセットに変換したい。近くにいるような気がしますが、完全ではありません。
SELECT Column_A, Column_B, Column_C, 0 as RN
FROM TABLE
WHERE COLUMN_C is null and Column_B in (UserA, UserB, UserC)
UNION ALL
SELECT Column_A, Column_B, Column_C, RN
FROM (
SELECT A.*, ROW_NUMBER() over (partition by A.column_C Order by case A.column_B when 'UserA' then 0 else 1 end, U.Time_Created) rn
FROM Table A
INNER JOIN user U
on U.Column_B = A.Column_B
WHERE A.Column_C is not null and ColumnB in (userA, userB, UserC)) B
WHERE RN = 1
これは私がこれまでに持っているものです:
qs1 = Table.objects.filter(Column_C__isnull=True).annotate(rn=Value(0))
qs2 = Table.objects.annotate(rn=Window(
expression=RowNumber(),
partition_by=[Column_C],
order_by=[Case(When(Column_B=UserA, then=0), default=1), 'Table_for_Column_B__time_created']
)).filter(Column_C__isnull=False, rn=1)
return qs2.union(qs1)
これは機能しません。
django.db.utils.NotSupportedError: Window is disallowed in the filter clause.
次に、行番号= 1の行のみが必要なため、サブクエリで中間結果を抽出して、外部クエリでフィルタリングできるようにします。
qs1 = Table.objects.filter(Column_C__isnull=True).annotate(rn=Value(0))
qs2 = Table.objects.annotate(rn=Window(
expression=RowNumber(),
partition_by=[Column_C],
order_by=[Case(When(Column_B=UserA, then=0), default=1), 'Table_for_Column_B__time_created']
)).filter(pk=OuterRef('pk'))
qs3 = Table.objects.annotate(rn=Subquery(qs2.values('rn'))).filter(Column_C__isnull=False, rn=1)
return qs3.union(q1)
今回も例外はありませんが、うまくいきません。テーブルの各行には、row_number=1の注釈が付けられています。元の例では、クエリセットは5行にフィルタリングするのではなく、7行すべてを返します。
ウィンドウ式なしでSubQueryを使用してこれを実行できるはずです
最初に、Column_B=UserA
一致でソートされたサブクエリのクエリセットを作成し、次にtime_created
from django.db.models import Case, When, Q, Subquery, OuterRef
tables_ordered = Table.objects.filter(
Column_C=OuterRef('Column_C')
).annotate(
user_match=Case(When(Column_B=UserA, then=0), default=1)
).order_by('user_match', 'time_created')
次に、このサブクエリは、ウィンドウ関数から最初の行を選択するのと同様に、Column_C
から一致する最初のPKを返します。OuterRef
first_pk_for_each_column_c = Subquery(tables_ordered.values('pk')[:1])
次に、2つのQオブジェクトでORを作成し、NULLの場合、またはサブクエリの最初のオブジェクトと一致する場合は行を選択しますColumn_C
pk
pk
Table.objects.filter(
Q(Column_C__isnull=True) | Q(pk=first_pk_for_each_column_c)
)
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句