Packages

eventstore

1.4.7
1.4.8 1.4.7 1.4.6 1.4.4 1.4.3 1.4.2 1.4.1 1.4.0 1.3.2 1.3.1 1.3.0 1.2.3 1.2.2 1.2.1 1.2.0 1.1.0 1.0.3 1.0.2 1.0.1 1.0.0 1.0.0-rc.0 0.17.0 0.16.2 0.16.1 0.16.0 0.15.1 0.15.0 0.14.0 0.14.0-rc.0 0.13.2 0.13.1 0.13.0 0.12.1 0.12.0 0.11.0 0.11.0-rc.0 0.10.1 0.10.0 0.9.0 0.8.1 0.8.0 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.2 0.5.1 0.5.0 0.4.3 0.4.2 0.4.1 0.4.0 0.3.0 0.2.1 0.2.0 0.1.0 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

Event store using PostgreSQL for persistence.

HexDocs

Current section

Files

Jump to
Readme
65 Versions
5 Dependencies
8 Dependants
Files
Activity
eventstore priv event_store migrations v0.14.0.sql
Raw

priv/event_store/migrations/v0.14.0.sql 

DO $$

BEGIN



  -- seed `$all` stream using event counter as its stream version

  INSERT INTO streams (stream_id, stream_uuid, stream_version)

  SELECT 0, '$all', event_number

  FROM event_counter;



  -- create `stream_events` table

  CREATE TABLE stream_events

  (

    event_id uuid NOT NULL REFERENCES events (event_id),

    stream_id bigint NOT NULL REFERENCES streams (stream_id),

    stream_version bigint NOT NULL,

    original_stream_id bigint REFERENCES streams (stream_id),

    original_stream_version bigint,

    PRIMARY KEY(event_id, stream_id)

  );



  CREATE UNIQUE INDEX ix_stream_events ON stream_events (stream_id, stream_version);

  CREATE RULE no_update_stream_events AS ON UPDATE TO stream_events DO INSTEAD NOTHING;

  CREATE RULE no_delete_stream_events AS ON DELETE TO stream_events DO INSTEAD NOTHING;



  -- seed stream events

  INSERT INTO stream_events (event_id, stream_id, stream_version, original_stream_id, original_stream_version)

  SELECT event_id, stream_id, stream_version, stream_id, stream_version

  FROM events;



  -- seed `$all` stream events

  INSERT INTO stream_events (event_id, stream_id, stream_version, original_stream_id, original_stream_version)

  SELECT event_id, 0, event_number, stream_id, stream_version

  FROM events;



  DROP INDEX ix_events_event_number;

  DROP INDEX ix_events_stream_id;

  DROP INDEX ix_events_stream_id_stream_version;



  ALTER TABLE events

    DROP COLUMN event_number,

    DROP COLUMN stream_id,

    DROP COLUMN stream_version;



  -- subscriptions now use single `last_seen` pointer

  ALTER TABLE subscriptions ADD COLUMN last_seen bigint;



  UPDATE subscriptions

  SET last_seen = COALESCE(last_seen_event_number, last_seen_stream_version);



  ALTER TABLE subscriptions

    DROP COLUMN last_seen_event_number,

    DROP COLUMN last_seen_stream_version;



  -- event pub/sub notification function

  CREATE OR REPLACE FUNCTION notify_events()

    RETURNS trigger AS $function$

  DECLARE

    payload text;

  BEGIN

      payload := NEW.stream_uuid || ',' || NEW.stream_id || ',' || (OLD.stream_version + 1) || ',' || NEW.stream_version;



      -- Notify events to listeners

      PERFORM pg_notify('events', payload);



      RETURN NULL;

  END;

  $function$ LANGUAGE plpgsql;



  -- event pub/sub table trigger

  CREATE TRIGGER event_notification

  AFTER UPDATE ON streams

  FOR EACH ROW EXECUTE PROCEDURE notify_events();



  -- stream version of `$all` stream events are used instead of event counter

  DROP TABLE event_counter;



  -- record schema migration

  INSERT INTO schema_migrations (major_version, minor_version, patch_version) VALUES (0, 14, 0);



END;

$$ LANGUAGE plpgsql;