DI MARC Bib Create

(PTF - Create 2)

DI MARC Bib Update

(PTF - Updates Success - 2)

insert into "marc_records_lb" ("id", "content") values (cast($1 as uuid), cast($2 as jsonb)) on conflict ("id") do update set "content" = cast($3 as jsonb)

WITH cte AS (SELECT id,
                    name,
                    name_type_id,
                    authority_id,
                    last_updated_date
             FROM fs09000000_mod_search.contributor
             WHERE last_updated_date > $1
             ORDER BY last_updated_date
             )
SELECT c.id,
       c.name,
       c.name_type_id,
       c.authority_id,
       c.last_updated_date,
       json_agg(
               CASE
                                WHEN sub.instance_count IS NULL THEN NULL
                                ELSE json_build_object(
                       'count', sub.instance_count,
                       'typeId', sub.type_ids,
                       'shared', sub.shared,
                       'tenantId', sub.tenant_id
               )
               END
       ) AS instances
FROM cte c
         LEFT JOIN
     (SELECT cte.id,
             ins.tenant_id,
             ins.shared,
             array_agg(DISTINCT ins.type_id) FILTER (WHERE ins.type_id <> '') AS type_ids,
             count(DISTINCT ins.instance_id)                                  AS instance_count
      FROM fs09000000_mod_search.instance_contributor ins
               INNER JOIN cte
                          ON ins.contributor_id = cte.id
      GROUP BY cte.id,
               ins.tenant_id,
               ins.shared) sub ON c.id = sub.id
GROUP BY c.id,
         c.name,
         c.name_type_id,
         c.authority_id,
         c.last_updated_date
      ORDER BY last_updated_date ASC