def _soql_for_mapping(self, mapping):
    sf_object = mapping['sf_object']
    fields = []
    if (not mapping['oid_as_pk']):
        fields.append('Id')
    fields += [field['sf'] for field in self._fields_for_mapping(mapping)]
    soql = 'SELECT {fields} FROM {sf_object}'.format(**{'fields': ', '.join(fields), 'sf_object': sf_object})
    if ('record_type' in mapping):
        soql += " WHERE RecordType.DeveloperName = '{}'".format(mapping['record_type'])
    return soql
def _soql_for_mapping(self, mapping):
    sf_object = mapping['sf_object']
    fields = []
    if (not mapping['oid_as_pk']):
        fields.append('Id')
    fields += [field['sf'] for field in self._fields_for_mapping(mapping)]
    soql = 'SELECT {fields} FROM {sf_object}'.format(**{'fields': ', '.join(fields), 'sf_object': sf_object})
    if ('record_type' in mapping):
        soql += " WHERE RecordType.DeveloperName = '{}'".format(mapping['record_type'])
    return soql