Sha256: 4fb010440ff5bc6cf2feb8ce8611de395459e9723bf1672fc5ca6067bd3961a3
Contents?: true
Size: 1.93 KB
Versions: 1
Compression:
Stored size: 1.93 KB
Contents
# frozen_string_literal: true require 'forwardable' module Apartment # The main entry point to Apartment functions # module Tenant extend self extend Forwardable def_delegators :adapter, :create, :drop, :switch, :switch!, :current, :each, :reset, :init, :set_callback, :seed, :current_tenant, :default_tenant, :environmentify attr_writer :config def init_once return if @already_initialized # To avoid infinite loops in work init is doing, # we need to set @already_initialized to true # before init is called @already_initialized = true init end def reinitialize @already_initialized = false end # Fetch the proper multi-tenant adapter based on Rails config # # @return {subclass of Apartment::AbstractAdapter} # 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 # Reset config and adapter so they are regenerated # def reload!(config = nil) Thread.current[:apartment_adapter] = nil reinitialize @config = config end private # Fetch the rails database configuration # def config @config ||= Apartment.connection_config end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
ros-apartment-2.7.2 | lib/apartment/tenant.rb |