Method: Dataflow::Adapters::MongoDbAdapter.client

Defined in:
lib/dataflow/adapters/mongo_db_adapter.rb

.client(settings, db_name: nil) ⇒ Object 



10
11
12
13
14
15
16
17
 
# File 'lib/dataflow/adapters/mongo_db_adapter.rb', line 10

def client(settings, db_name: nil)
  @clients ||= {}

  settings.adapter_type = 'mongodb'
  connection_uri = settings.connection_uri_or_default
  db_name ||= settings.db_name
  @clients["#{connection_uri}.#{db_name}"] ||= Mongo::Client.new([connection_uri], database: db_name)
end