diff options
author | Arthur de Jong <arthur@arthurdejong.org> | 2012-01-29 16:13:25 +0100 |
---|---|---|
committer | Arthur de Jong <arthur@arthurdejong.org> | 2012-01-29 16:13:25 +0100 |
commit | 4c31632a1cf1a89fc685931986653581b2623f02 (patch) | |
tree | cdb2f5ad651760eaa89c5ed10e05e2787c21cde1 /pynslcd/alias.py | |
parent | 0ddbc4563992e3e27a8e2fd1a343a855af6af151 (diff) |
implement a naive offline cache
git-svn-id: http://arthurdejong.org/svn/nss-pam-ldapd/nss-pam-ldapd@1615 ef36b2f9-881f-0410-afb5-c4e39611909c
Diffstat (limited to 'pynslcd/alias.py')
-rw-r--r-- | pynslcd/alias.py | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/pynslcd/alias.py b/pynslcd/alias.py index cdae9da..25d55b3 100644 --- a/pynslcd/alias.py +++ b/pynslcd/alias.py @@ -18,6 +18,7 @@ # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA # 02110-1301 USA +import cache import common import constants @@ -33,6 +34,23 @@ class Search(common.Search): required = ('cn', 'rfc822MailMember') +class Cache(cache.Cache): + + retrieve_sql = ''' + SELECT `alias_cache`.`cn` AS `cn`, + `alias_1_cache`.`rfc822MailMember` AS `rfc822MailMember` + FROM `alias_cache` + LEFT JOIN `alias_1_cache` + ON `alias_1_cache`.`alias` = `alias_cache`.`cn` + ''' + + def retrieve(self, parameters): + query = cache.Query(self.retrieve_sql, parameters) + # return results, returning the members as a list + for row in cache.RowGrouper(query.execute(self.con), ('cn', ), ('rfc822MailMember', )): + yield row['cn'], row['rfc822MailMember'] + + class AliasRequest(common.Request): def write(self, name, members): |