module Apartment::Database

def self.jdbc_mysql_adapter(config)
  Adapters::JDBCMysqlAdapter.new config
end

def self.jdbc_postgresql_adapter(config)
  Apartment.use_schemas ?
      Adapters::JDBCPostgresqlSchemaAdapter.new(config) :
      Adapters::JDBCPostgresqlAdapter.new(config)
end

def self.mysql2_adapter(config)
  Apartment.use_schemas ?
    Adapters::Mysql2SchemaAdapter.new(config) :
    Adapters::Mysql2Adapter.new(config)
end

def self.postgis_adapter(config)
  Apartment.use_schemas ?
    Adapters::PostgresqlSchemaAdapter.new(config) :
    Adapters::PostgresqlAdapter.new(config)
end

def self.postgresql_adapter(config)
  Apartment.use_schemas ?
    Adapters::PostgresqlSchemaAdapter.new(config) :
    Adapters::PostgresqlAdapter.new(config)
end

def self.sqlite3_adapter(config)
  Adapters::Sqlite3Adapter.new(config)
end

def adapter
  Thread.current[:apartment_adapter] ||= begin
    adapter_method = "#{config[:adapter]}_adapter"
    if defined?(JRUBY_VERSION)
      if config[:adapter] =~ /mysql/
        adapter_method = 'jdbc_mysql_adapter'
      elsif config[:adapter] =~ /postgresql/
        adapter_method = 'jdbc_postgresql_adapter'
      end
    end
    begin
      require "apartment/adapters/#{adapter_method}"
    rescue LoadError
      raise "The adapter `#{adapter_method}` is not yet supported"
    end
    unless respond_to?(adapter_method)
      raise AdapterNotFound, "database configuration specifies nonexistent #{config[:adapter]} adapter"
    end
    send(adapter_method, config)
  end
end

def config
  @config ||= Rails.configuration.database_configuration[Rails.env].symbolize_keys
end

def init
  process_excluded_models
end

def reload!(config = nil)
  Thread.current[:apartment_adapter] = nil
  @config = config
end