From: jlaine <jlaine@e071eeec-0327-468d-9b6a-08194a12b294>
Date: Mon, 11 Apr 2011 08:02:58 +0000 (+0000)
Subject: move backend definition
X-Git-Url: https://git.stderr.nl/gitweb?a=commitdiff_plain;h=0cadc34057b757d759d4640bcd9107dc02b96520;p=matthijs%2Fupstream%2Fdjango-ldapdb.git

move backend definition


git-svn-id: https://svn.bolloretelecom.eu/opensource/django-ldapdb/trunk@1014 e071eeec-0327-468d-9b6a-08194a12b294
---

diff --git a/ldapdb/backends/ldap/base.py b/ldapdb/backends/ldap/base.py
new file mode 100644
index 0000000..1b21647
--- /dev/null
+++ b/ldapdb/backends/ldap/base.py
@@ -0,0 +1,93 @@
+# -*- coding: utf-8 -*-
+# 
+# django-ldapdb
+# Copyright (c) 2009-2010, Bolloré telecom
+# All rights reserved.
+# 
+# See AUTHORS file for a full list of contributors.
+# 
+# Redistribution and use in source and binary forms, with or without modification,
+# are permitted provided that the following conditions are met:
+# 
+#     1. Redistributions of source code must retain the above copyright notice, 
+#        this list of conditions and the following disclaimer.
+#     
+#     2. Redistributions in binary form must reproduce the above copyright 
+#        notice, this list of conditions and the following disclaimer in the
+#        documentation and/or other materials provided with the distribution.
+# 
+#     3. Neither the name of Bolloré telecom nor the names of its contributors
+#        may be used to endorse or promote products derived from this software
+#        without specific prior written permission.
+# 
+# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+# ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+# DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+# ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+# (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+# LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
+# ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+# SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+#
+
+import ldap
+
+from django.db.backends import BaseDatabaseFeatures, BaseDatabaseOperations, BaseDatabaseWrapper
+
+class DatabaseCursor(object):
+    def __init__(self, ldap_connection):
+        self.connection = ldap_connection
+
+class DatabaseFeatures(BaseDatabaseFeatures):
+    def __init__(self, connection):
+        self.connection = connection
+
+class DatabaseOperations(BaseDatabaseOperations):
+    def quote_name(self, name):
+        return name
+
+class DatabaseWrapper(BaseDatabaseWrapper):
+    def __init__(self, settings_dict, alias='ldap'):
+        super(DatabaseWrapper, self).__init__(settings_dict, alias=alias)
+
+        self.charset = "utf-8"
+        self.features = DatabaseFeatures(self)
+        self.ops = DatabaseOperations()
+
+    def close(self):
+        pass
+
+    def _cursor(self):
+        if self.connection is None:
+            self.connection = ldap.initialize(self.settings_dict['NAME'])
+            self.connection.simple_bind_s(
+                self.settings_dict['USER'],
+                self.settings_dict['PASSWORD'])
+        return DatabaseCursor(self.connection)
+
+    def add_s(self, dn, modlist):
+        cursor = self._cursor()
+        return cursor.connection.add_s(dn.encode(self.charset), modlist)
+
+    def delete_s(self, dn):
+        cursor = self._cursor()
+        return cursor.connection.delete_s(dn.encode(self.charset))
+
+    def modify_s(self, dn, modlist):
+        cursor = self._cursor()
+        return cursor.connection.modify_s(dn.encode(self.charset), modlist)
+
+    def rename_s(self, dn, newrdn):
+        cursor = self._cursor()
+        return cursor.connection.rename_s(dn.encode(self.charset), newrdn.encode(self.charset))
+
+    def search_s(self, base, scope, filterstr, attrlist):
+        cursor = self._cursor()
+        results = cursor.connection.search_s(base, scope, filterstr.encode(self.charset), attrlist)
+        output = []
+        for dn, attrs in results:
+            output.append((dn.decode(self.charset), attrs))
+        return output
+