querrel

ケレル

Querrel を使用すると、1 つのデータベースをクエリしているかのように、ActiveRecord を使用して複数のデータベースを並列 (スレッド) で簡単にクエリできます。

インストール

次の行をアプリケーションの Gemfile に追加します。

 gem 'querrel'

そして、以下を実行します。

 $ bundle

または、次のように自分でインストールします。

 $ gem install querrel

使用法

基本

最上位の名前空間を介して Querrel を直接使用することも、インスタンスを作成することによっても使用できます。

 all_brands = Querrel . query ( Brand . all , on : [ 'db1' , 'db2' , 'db3' ] )
# is the same as
all_brands = Querrel . new ( [ 'db1' , 'db2' , 'db3' ] ) . query ( Brand . all )

上記のいずれかを実行すると、指定されたすべてのデータベースからすべてのブランド オブジェクトの配列が得られます。レコードは読み取り専用としてマークされます。

高度な

query 、 ActiveRecord::Relationに渡されたブロックを生成します。これにより、結果がマージされる前に、結果に対して追加の操作を行うことができます。たとえば、 pluck を使用できます。

 all_brand_names = q . query ( Brand . all ) do | s |
  s . pluck ( :name )
end

また、事前に規定されたスコープを実行してマージする代わりに、指定されたデータベース接続でやりたいことを何でもできるようにするブロックを取得するrunメソッドもあります。

 require 'thread'
all_brands = [ ]
b_s = Mutex . new
all_products = [ ]
p_s = Mutex . new

Querrel . run ( on : dbs ) do | db |
  b_s . synchronize { all_brands += Brand . all . to_a }
  p_s . synchronize { all_products += Product . all . to_a }
end

データベース

Querrel にどのデータベースを使用するかを指示するには、次の 3 つの方法があります。

1. 環境の配列を渡します。例: Querrel.new([:customer1, :customer2])

2. データベース名の配列を渡します。例: Querrel.new(['dbs/customer1.sqlite3', 'dbs/customer2.sqlite3'], db_names: true)

3. 名前付き接続構成のハッシュを渡します。例:

    Querrel . new ( {
     one : {
       adapter : "sqlite3" ,
       database : "test/dbs/test_db_1.sqlite3"
     } ,
     two : {
       adapter : "sqlite3" ,
       database : "test/dbs/test_db_2.sqlite3"
     }
   } )

構成

デフォルトでは、Querrel は最大 20 のスレッドを使用しますが、 :threadsオプションを使用してこれを調整できます。

 q = Querrel . new ( dbs , threads : 50 ) 

貢献する

1. フォークします ( https://github.com/meritec/querrel/fork )
2. 機能ブランチを作成します ( git checkout -b my-new-feature )
3. 変更をコミットします ( git commit -am 'Add some feature' )
4. ブランチにプッシュします ( git push origin my-new-feature )
5. 新しいプルリクエストを作成する