Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/sql/40-swh-func.sql
Show First 20 Lines • Show All 687 Lines • ▼ Show 20 Lines | begin | ||||
return; | return; | ||||
end | end | ||||
$$; | $$; | ||||
-- add a new origin_visit for origin origin_id at date. | -- add a new origin_visit for origin origin_id at date. | ||||
-- | -- | ||||
-- Returns the new visit id. | -- Returns the new visit id. | ||||
create or replace function swh_origin_visit_add(origin_id bigint, date timestamptz) | create or replace function swh_origin_visit_add(origin_id bigint, date timestamptz, type text) | ||||
returns bigint | returns bigint | ||||
language sql | language sql | ||||
as $$ | as $$ | ||||
with last_known_visit as ( | with last_known_visit as ( | ||||
select coalesce(max(visit), 0) as visit | select coalesce(max(visit), 0) as visit | ||||
from origin_visit | from origin_visit | ||||
where origin = origin_id | where origin = origin_id | ||||
) | ) | ||||
insert into origin_visit (origin, date, visit, status) | insert into origin_visit (origin, date, type, visit, status) | ||||
values (origin_id, date, (select visit from last_known_visit) + 1, 'ongoing') | values (origin_id, date, type, (select visit from last_known_visit) + 1, 'ongoing') | ||||
returning visit; | returning visit; | ||||
$$; | $$; | ||||
create or replace function swh_snapshot_add(snapshot_id snapshot.id%type) | create or replace function swh_snapshot_add(snapshot_id snapshot.id%type) | ||||
returns void | returns void | ||||
language plpgsql | language plpgsql | ||||
as $$ | as $$ | ||||
declare | declare | ||||
▲ Show 20 Lines • Show All 405 Lines • Show Last 20 Lines |