class ActiveRecord::ConnectionAdapters::SchemaReflection

def data_source_exists?(pool, name) 

def data_source_exists?(pool, name)
  cache(pool).data_source_exists?(pool, name)
end