रूबी 3 पर रूबी में कई डेटाबेस के साथ काम करना

सभी को नमस्कार। मैं रेल्स डेवलपर पर एक शुरुआती (अपेक्षाकृत) रूबी हूं। मैं वर्तमान में एक एप्लिकेशन विकसित कर रहा हूं जो कई डेटाबेस का उपयोग करता है। इंटरनेट पर इस मुद्दे पर उतनी जानकारी नहीं है, जितनी हम चाहेंगे, इसलिए मैंने सब कुछ एक साथ रखने और इसे व्यापकता के साथ साझा करने का फैसला किया।
मैं दोहराता हूं, मैं खुद को रेल के लिए एक नवागंतुक मानता हूं, इसलिए यह सही कैसे करना है पर एक लेख नहीं है। यह सिर्फ नोटों का संग्रह है कि मैंने क्या और कैसे किया।

मेरे पास एक विशिष्ट कार्य है, लेकिन बहुत अधिक कोड नहीं है और इसे अपनी आवश्यकताओं के लिए रीमेक करना मुश्किल नहीं होगा।

कार्य

कुछ सामान बेचने वाली कंपनियों के लिए एक निश्चित एमडीजी बनाना आवश्यक है। कंपनियां एक साथ कई ब्रांडों के साथ काम करती हैं, और प्रत्येक ब्रांड को एक अलग डेटाबेस के साथ अपने स्वयं के सीआरएम की आवश्यकता होती है। मेरे कार्यान्वयन में, कंपनी उप-डोमेन द्वारा निर्धारित की गई है, और URL से ब्रांड, उदाहरण के लिए, URL company1.myapp.dev/brand1/ हमें बताता है कि हम company1 और brand1 ब्रांड के साथ काम कर रहे हैं।

यह सब मॉडल से शुरू होता है

इस मामले में, 2 मॉडलों को अलग करना तर्कसंगत था: कंपनी और ब्रांड।

कंपनी

• db_user: string - DBMS से कनेक्ट करने के लिए उपयोगकर्ता नाम
• db_password: string - पासवर्ड
• db_host: string - DBMS सर्वर का पता
• db_port: पूर्णांक - DBMS सर्वर पोर्ट
• उपडोमेन: स्ट्रिंग - कंपनी के लिए उपडोमेन नाम
• उपनाम: स्ट्रिंग - वैकल्पिक पता (उदाहरण के लिए, एक कंपनी DTM को अपनी साइट crm.company1.dev से बांधना चाहती है)
• सक्रिय: बूलियन - DTM तक पहुंच को जल्दी से अक्षम करने के लिए
• नाम: स्ट्रिंग - कंपनी का नाम

ब्रांड

• नाम: स्ट्रिंग - ब्रांड नाम
• db_name: स्ट्रिंग - डेटाबेस का नाम
• company_id: पूर्णांक - कंपनी से लिंक

नोट: सबसे अधिक बार डेटाबेस को केवल डोमेन द्वारा स्विच करने की आवश्यकता होती है, इसलिए ब्रांड मॉडल को हटाया जा सकता है और db_name फ़ील्ड को कंपनी मॉडल में स्थानांतरित किया जा सकता है। यदि आप स्थानीय सर्वर पर केवल DBMS का उपयोग करने की योजना बनाते हैं, तो आप db_user, db_host, आदि को पूरी तरह से हटा सकते हैं। मैं किसी दिन क्लाउड सेवाओं पर स्विच करने की योजना बना रहा हूं, और यह काम में आ सकती है।

इन मॉडलों के लिए तालिकाओं को प्रत्येक डेटाबेस में होना चाहिए, जिसके साथ अनुप्रयोग काम करेगा, लेकिन डेटा केवल एक में ही संग्रहीत किया जाएगा (उत्पादन या विकास, आपके RIDS_ENV पर निर्भर करता है)। केवल एक विशिष्ट डेटाबेस में डेटा की खोज करने के लिए एप्लिकेशन के लिए, प्रतिष्ठान_संक्रमण विधि का उपयोग करें।

/models/company.rb

class Company < ActiveRecord::Base establish_connection "production" has_many :brands, dependent: :destroy validates :subdomain, :db_user, :db_host, :db_port, :name, presence: true end 

/models/brand.rb

 class Brand < ActiveRecord::Base establish_connection "production" belongs_to :company validates :name, :db_name, presence: true end 

एक कोड लिखना

routes.rb

चूंकि हमें हमेशा यह जानने की जरूरत है कि हम किस ब्रांड के साथ काम कर रहे हैं, इसलिए हमें हर चीज को दायरे में लपेटने की जरूरत है।

 MyApp::Application.routes.draw do scope ':brand' do resource :sessions, only: [:new, :create, :destroy] #  .. match '/' => redirect("/%{brand}/orders"), as: 'brand_root' end root :to => "main#index" end 

application.rb

 class ApplicationController < ActionController::Base protect_from_forgery before_filter :override_db before_filter :authenticate_user! def not_found raise ActionController::RoutingError.new('Not Found') end #    scope,     #     ,    #      # Ex:  orders_path(brand: @current_brand.name)    orders_path def url_options if @current_brand.present? { :brand => @current_brand.name }.merge(super) else super end end private #     def override_db @current_company = Company.where("(subdomain = ? or alias = ?) AND active = ?", request.env['HTTP_HOST'][/^[\w\-]+/], request.env['HTTP_HOST'], true).first not_found unless @current_company.present? && @current_company.brands.present? if params[:brand].present? @current_brand = @current_company.brands.find_by_name params[:brand] if @current_brand.present? ActiveRecord::Base.clear_cache! ActiveRecord::Base.establish_connection( :adapter => "postgresql", :host => @current_company.db_host, :username => @current_company.db_user, :password => @current_company.db_password, :database => @current_company.db_name ) redefine_uploaders_store_dir else redirect_to root_url end end end #    CarrierWave def redefine_uploaders_store_dir CarrierWave::Uploader::Base.descendants.each do |d| d.class_eval <<-RUBY, __FILE__, __LINE__+1 def store_dir "uploads/#{@current_company.subdomain}/\#{model.class.to_s.underscore}/\#{mounted_as}/\#{model.id}" end RUBY end end end 

एक नए डेटाबेस से कनेक्ट करने से पहले, आपको निश्चित रूप से ActiveRecord कैश (ActiveRecord :: Base.clear_cache! या ActiveRecord :: Base.connection_pool.clear_reloadable_connections!) साफ़ करना होगा।
Redefine_uploaders_store_dir विधि उन निर्देशिकाओं को ओवरराइड करती है जिसमें कैरियरवे फाइलें संचित करेंगे। आप यह हैक नहीं कर सकते, संघर्ष की संभावना बहुत कम है (फ़ाइल नाम और मॉडल आईडी को मेल खाना चाहिए), लेकिन यह मौजूद है, इसलिए मैंने इसे सुरक्षित खेलने का फैसला किया।

एक और तिपहिया जिसके बिना कुछ भी नहीं चलेगा

विन्यास / वातावरण / production.rb में आपको क्लास कैशिंग को अक्षम करना होगा।

 config.cache_classes = false 

हां, प्रदर्शन में गिरावट आ रही है, लेकिन मैं नहीं जानता कि इस समस्या को कैसे हल किया जाए।

अधिवेशन

मेरे मामले में, एक सत्र बहुत सारे डेटा को संग्रहीत कर सकता है, इसलिए मुझे इसे डेटाबेस में संग्रहीत करने की आवश्यकता है, कुकीज़ में नहीं। इसके अलावा, मुख्य पृष्ठ पर मेरे पास विभिन्न ब्रांडों के लिए प्राधिकरण फ़ॉर्म हैं और मैं उस उपयोगकर्ता को दिखाना चाहता हूं जिसमें वे पहले से ही अधिकृत हैं और एक बटन के क्लिक के साथ प्रवेश कर सकते हैं, और जिसके लिए आपको अभी भी एक पासवर्ड दर्ज करने की आवश्यकता है। इसलिए, आपको सत्रों को एक डेटाबेस में संग्रहीत करने की आवश्यकता है, और कई पर नहीं फैलाना चाहिए।
पहले हम सत्रों को संग्रहीत करने के लिए ActiveRecord का उपयोग करने के लिए रेल बताते हैं:

 rails g session_migration rake db:migrate 

config / initializers / session_store.rb

 MyApp::Application.config.session_store :active_record_store 

और फिर हम उन्हें स्टोर करने के लिए एक विशिष्ट डेटाबेस का उपयोग करने के लिए कहते हैं:

config / environment.rb

 # Load the rails application require File.expand_path('../application', __FILE__) # Initialize the rails application MyApp::Application.initialize! ActiveRecord::SessionStore::Session.establish_connection "production" 

ध्यान दें: बस के मामले में, मैं एक आरक्षण करूँगा कि "उत्पादन" यहाँ और मॉडल में डेटाबेस का नाम नहीं है, लेकिन config / database.yml में अनुभाग नाम है।

प्रवास

माइग्रेशन के लिए, आप निम्न समाधान का उपयोग कर सकते हैं:

lib / कार्य / मल्टीमगेट.ट्रैक

 namespace :db do desc "Migrations for all databases" task :multimigrate => :environment do Company.all.each do |company| company.brands.each do |brand| puts "Run migration for #{company.name} (#{brand.name})" sh "cd #{Rails.root.to_s} && bundle exec rake db:migrate RAILS_ENV=#{brand.db_name}" end end end end 

सब कुछ काम करने के लिए, सभी डेटाबेस database.yml में सूचीबद्ध होने चाहिए। खुद के लिए, मैं एक नियम के साथ आया था कि database.yml में विभाजन (पर्यावरण) को डेटाबेस की तरह कहा जाएगा।
अब जब मैं व्यवस्थापक पैनल में एक नई कंपनी जोड़ता हूं, तो कंट्रोलर database.yml में एक नया खंड जोड़ता है, लेकिन आप इस मॉडल को भी निर्देश दे सकते हैं (मुझे नहीं पता कि यह कैसे कोषेर होगा, लेकिन यह सुविधाजनक है)। कुछ इस तरह:

 class Brand < ActiveRecord::Base establish_connection "production" belongs_to :company after_save :sync_to_yml validates :name, :db_name, presence: true private def sync_to_yml db_config = YAML.load_file(Rails.root.to_s + '/config/database.yml') db_config[self.db_name] = { 'adapter' => 'postgresql', 'encoding' => 'unicode', 'database' => self.db_name, 'pool' => 5, 'username' => self.company.db_user, 'password' => self.company.db_password.present? ? self.company.db_password : nil } if self.company.db_host != 'localhost' db_config[self.db_name].merge( { 'host' => self.company.db_host, 'port' => self.company.db_port } ) end File.open( Rails.root.to_s + '/config/database.yml', 'w' ) do |out| YAML.dump( db_config, out ) end end end 

चेतावनी! कोड का परीक्षण नहीं किया गया। बस सुझाव दिया कि यह कैसे करना है। इसके अलावा, आपको अभी भी after_destroy पर कॉलबैक जोड़ना होगा।

यह सब प्रतीत होता है, कई डेटाबेस के साथ काम करने के लिए मौजूदा रेल एप्लिकेशन को फिर से लिखना बहुत सरल है। मैं उन स्रोतों को साझा करना पसंद करूंगा जिन्होंने मुझे निर्णय में मदद की, लेकिन उनमें से बहुत सारे थे और उन्हें (एक शब्द में, आलस्य) खोजना मुश्किल होगा। लेकिन मैं पोस्ट के लिए तस्वीर को एक स्रोत दे सकता हूं।