0018-downgrade.sql

begin
  -- lock this table before reading from it, to prevent loss of concurrent
  -- updates when the table is dropped.
  lock table indexed_tasks;

  raise log 'TIMING start indexed_tasks_entities create table';
  create table indexed_tasks_entities(
    partition_key text, row_key text,
    value jsonb not null,
    version integer not null,
    etag uuid default public.gen_random_uuid());

  raise log 'TIMING start indexed_tasks_entities add primary key';
  alter table indexed_tasks_entities add primary key (partition_key, row_key);

  raise log 'TIMING start indexed_tasks_entities insert into';
  insert into indexed_tasks_entities
  select
    sha512(namespace) as partition_key,
    encode_string_key(name) as row_key,
    entity_buf_encode(
        jsonb_build_object(
          'PartitionKey', sha512(namespace),
          'RowKey', encode_string_key(name),
          'namespace', namespace,
          'name', name,
          'rank', rank,
          'taskId', task_id,
          'expires', expires),
        'data', data::text) as value,
    1 as version,
    etag
  from indexed_tasks;

  raise log 'TIMING start indexed_tasks_entities set permissions';
  revoke select, insert, update, delete on indexed_tasks from $db_user_prefix$_index;
  drop table indexed_tasks;
  grant select, insert, update, delete on indexed_tasks_entities to $db_user_prefix$_index;


  -- lock this table before reading from it, to prevent loss of concurrent
  -- updates when the table is dropped.
  lock table index_namespaces;

  raise log 'TIMING start namespaces_entities create table';
  create table namespaces_entities(
    partition_key text, row_key text,
    value jsonb not null,
    version integer not null,
    etag uuid default public.gen_random_uuid());

  raise log 'TIMING start namespaces_entities add primary key';
  alter table namespaces_entities add primary key (partition_key, row_key);

  raise log 'TIMING start namespaces_entities insert into';
  insert into namespaces_entities
  select
    sha512(parent) as partition_key,
    encode_string_key(name) as row_key,
    jsonb_build_object(
      'PartitionKey', sha512(parent),
      'RowKey', encode_string_key(name),
      'parent', parent,
      'name', name,
      'expires', expires),
    1 as version,
    etag
  from index_namespaces;

  raise log 'TIMING start namespaces_entities set permissions';
  revoke select, insert, update, delete on index_namespaces from $db_user_prefix$_index;
  drop table index_namespaces;
  grant select, insert, update, delete on namespaces_entities to $db_user_prefix$_index;
end