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