X-Git-Url: https://git.stderr.nl/gitweb?p=matthijs%2Fupstream%2Fdjango-ldapdb.git;a=blobdiff_plain;f=ldapdb%2Fmodels%2Fquery.py;h=1fddeeeb1aea3b8bb0ece0f4a7b079fa8d802b84;hp=f90c9b169d6bf276714d5da5393832074c914bbc;hb=641160553d6db632259d325be2b22ee7c3059f3c;hpb=baba34a193fe7d304d86003b19f36ed638c7ec80 diff --git a/ldapdb/models/query.py b/ldapdb/models/query.py index f90c9b1..1fddeee 100644 --- a/ldapdb/models/query.py +++ b/ldapdb/models/query.py @@ -94,7 +94,7 @@ class Compiler(object): try: vals = self.connection.search_s( self.query.model.base_dn, - ldap.SCOPE_SUBTREE, + self.query.model.search_scope, filterstr=self.query._ldap_filter(), attrlist=attrlist, ) @@ -190,10 +190,11 @@ class WhereNode(BaseWhereNode): else: clause = '(|%s)' % ''.join(equal_bits) - if self.negated: - bits.append('(!%s)' % clause) - else: - bits.append(clause) + bits.append(clause) + + if not len(bits): + return '', [] + if len(bits) == 1: sql_string = bits[0] elif self.connector == AND: @@ -202,6 +203,10 @@ class WhereNode(BaseWhereNode): sql_string = '(|%s)' % ''.join(bits) else: raise Exception("Unhandled WHERE connector: %s" % self.connector) + + if self.negated: + sql_string = ('(!%s)' % sql_string) + return sql_string, [] class Query(BaseQuery): @@ -219,7 +224,7 @@ class Query(BaseQuery): try: vals = ldapdb.connection.search_s( self.model.base_dn, - ldap.SCOPE_SUBTREE, + self.model.search_scope, filterstr=self._ldap_filter(), attrlist=[], ) @@ -238,6 +243,9 @@ class Query(BaseQuery): def get_compiler(self, using=None, connection=None): return Compiler(self, ldapdb.connection, using) + def has_results(self, using): + return self.get_count() != 0 + def results_iter(self): "For django 1.1 compatibility" return self.get_compiler().results_iter() @@ -260,7 +268,7 @@ class QuerySet(BaseQuerySet): try: vals = ldapdb.connection.search_s( self.model.base_dn, - ldap.SCOPE_SUBTREE, + self.model.search_scope, filterstr=self.query._ldap_filter(), attrlist=[], )