class Sequent::Migrations::SequentSchema

Constants

FAIL_IF_EXISTS

Public Class Methods

create_sequent_schema_if_not_exists(env:, fail_if_exists: true) click to toggle source

Creates the sequent schema if it does not exist yet

@param env [String] The environment used to setup database connection @param fail_if_exists [Boolean] When true fails if the schema exists, otherwise just return.

# File lib/sequent/migrations/sequent_schema.rb, line 14
def create_sequent_schema_if_not_exists(env:, fail_if_exists: true)
  fail ArgumentError, 'env is required' if env.blank?

  db_config = Sequent::Support::Database.read_config(env)

  Sequent::Support::Database.establish_connection(db_config)

  event_store_schema = Sequent.configuration.event_store_schema_name
  schema_exists = Sequent::Support::Database.schema_exists?(event_store_schema)

  FAIL_IF_EXISTS.call(event_store_schema) if schema_exists && fail_if_exists
  return if schema_exists

  sequent_schema = File.join(Sequent.configuration.database_schema_directory, "#{event_store_schema}.rb")
  unless File.exist?(sequent_schema)
    fail "File '#{sequent_schema}' does not exist. Check your Sequent configuration."
  end

  Sequent::Support::Database.create_schema(event_store_schema)
  Sequent::Support::Database.with_schema_search_path(event_store_schema, db_config, env) do
    load(sequent_schema)
  end
end