discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

fix-string-agg

Browse Source
This commit is contained in:
Untone 2024-08-08 16:20:45 +03:00
parent 71015c2ca3
commit 21d9b75a09
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
resolvers/reader.py
View File

@ -47,15 +47,15 @@ def query_shouts():
func.concat("slug:", Author.slug), func.concat("slug:", Author.slug),
func.concat("pic:", Author.pic), func.concat("pic:", Author.pic),
), ),
", ", " | "
).label("authors"), ).label("authors"), # Используем символ | как разделитель
) )
.join(Author, ShoutAuthor.author == Author.id) .join(Author, ShoutAuthor.author == Author.id)
.group_by(ShoutAuthor.shout) .group_by(ShoutAuthor.shout)
.subquery() .subquery()
) )
# Подзапрос для уникальных тем, объединенных в строку # Подзапрос для уникальных тем, объединенных в строку (без поля body)
topics_subquery = ( topics_subquery = (
select( select(
ShoutTopic.shout.label("shout_id"), ShoutTopic.shout.label("shout_id"),
@ -67,8 +67,8 @@ def query_shouts():
func.concat("slug:", Topic.slug), func.concat("slug:", Topic.slug),
func.concat("is_main:", ShoutTopic.main), func.concat("is_main:", ShoutTopic.main),
), ),
", ", " | "
).label("topics"), ).label("topics"), # Используем символ | как разделитель
) )
.join(Topic, ShoutTopic.topic == Topic.id) .join(Topic, ShoutTopic.topic == Topic.id)
.group_by(ShoutTopic.shout) .group_by(ShoutTopic.shout)
@ -105,7 +105,6 @@ def query_shouts():
return q, aliased_reaction return q, aliased_reaction
def parse_aggregated_string(aggregated_str): def parse_aggregated_string(aggregated_str):
""" """
Преобразует строку, полученную из string_agg, обратно в список словарей. Преобразует строку, полученную из string_agg, обратно в список словарей.
@ -117,10 +116,11 @@ def parse_aggregated_string(aggregated_str):
return [] return []
items = [] items = []
for item_str in aggregated_str.split(", "): # Изменяем разделитель на символ |, соответствующий используемому в агрегации
for item_str in aggregated_str.split(" | "):
item_data = {} item_data = {}
for field in item_str.split(";"): for field in item_str.split(";"):
if ":" in field: if ':' in field:
key, value = field.split(":", 1) key, value = field.split(":", 1)
item_data[key] = value item_data[key] = value
else: else: