176 |
|
|
177 |
if not self.__cachedSources.has_key(connection_name): |
if not self.__cachedSources.has_key(connection_name): |
178 |
self.__cachedSources[connection_name] = \ |
self.__cachedSources[connection_name] = \ |
179 |
self.GetTemporaryConnection(connection_name).getSchemaList() |
self.GetTemporaryConnection(connection_name).find() |
180 |
|
|
181 |
list = [] |
list = [] |
182 |
for schema in self.__cachedSources[connection_name]: |
for schema in self.__cachedSources[connection_name]: |
187 |
|
|
188 |
def GetSourceSchema(self, connection_name, source_name): |
def GetSourceSchema(self, connection_name, source_name): |
189 |
return self.GetTemporaryConnection(connection_name)\ |
return self.GetTemporaryConnection(connection_name)\ |
190 |
.getSchemaByName(source_name) |
.findone(name=source_name) |
191 |
|
|
192 |
|
|
193 |
def GetAvailableFields(self, connection_name, source_name): |
def GetAvailableFields(self, connection_name, source_name): |
194 |
list = [] |
list = [] |
195 |
source = self.GetSourceSchema(connection_name, source_name) |
source = self.GetSourceSchema(connection_name, source_name) |
196 |
if source != None: |
if source != None: |
197 |
for schema in source.getChildSchema(source): |
for schema in source.fields(): |
198 |
list.append((schema.name, hasattr(schema,'description') \ |
list.append((schema.name, hasattr(schema,'description') \ |
199 |
and schema.description or schema.name)) |
and schema.description or schema.name)) |
200 |
|
|