class ActiveRecord::ConnectionAdapters::SchemaReflection

def data_source_exists?(connection, name) 

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