Sha256: f4d4b61e79f27af0149e0bee79fb02aa4dc98805f1f0ef1f29f69db99834b963
Contents?: true
Size: 1.85 KB
Versions: 22
Compression:
Stored size: 1.85 KB
Contents
ActiveRecord::Schema.define do
create_table "event_records", :force => true do |t|
t.string "aggregate_id", :null => false
t.integer "sequence_number", :null => false
t.datetime "created_at", :null => false
t.string "event_type", :null => false
t.text "event_json", :null => false
t.integer "command_record_id", :null => false
t.integer "stream_record_id", :null => false
end
execute %Q{
CREATE UNIQUE INDEX unique_event_per_aggregate ON event_records (
aggregate_id,
sequence_number,
(CASE event_type WHEN 'Sequent::Core::SnapshotEvent' THEN 0 ELSE 1 END)
)
}
execute %Q{
CREATE INDEX snapshot_events ON event_records (aggregate_id, sequence_number DESC) WHERE event_type = 'Sequent::Core::SnapshotEvent'
}
add_index "event_records", ["command_record_id"], :name => "index_event_records_on_command_record_id"
add_index "event_records", ["event_type"], :name => "index_event_records_on_event_type"
add_index "event_records", ["created_at"], :name => "index_event_records_on_created_at"
create_table "command_records", :force => true do |t|
t.string "user_id"
t.string "aggregate_id"
t.string "command_type", :null => false
t.text "command_json", :null => false
t.datetime "created_at", :null => false
end
create_table "stream_records", :force => true do |t|
t.datetime "created_at", :null => false
t.string "aggregate_type", :null => false
t.string "aggregate_id", :null => false
t.integer "snapshot_threshold"
end
add_index "stream_records", ["aggregate_id"], :name => "index_stream_records_on_aggregate_id", :unique => true
execute %q{
ALTER TABLE event_records ADD CONSTRAINT command_fkey FOREIGN KEY (command_record_id) REFERENCES command_records (id)
}
execute %q{
ALTER TABLE event_records ADD CONSTRAINT stream_fkey FOREIGN KEY (stream_record_id) REFERENCES stream_records (id)
}
end
Version data entries
22 entries across 18 versions & 2 rubygems