Lines 44-50
class ObjectNotFound(BaseException):
|
Link Here
|
---|
|
44 |
def remove_ucs_rejected(ucs_dn): |
44 |
def remove_ucs_rejected(ucs_dn): |
45 |
cache_db = sqlite3.connect('/etc/univention/connector/s4internal.sqlite') |
45 |
cache_db = sqlite3.connect('/etc/univention/connector/s4internal.sqlite') |
46 |
c = cache_db.cursor() |
46 |
c = cache_db.cursor() |
47 |
c.execute("SELECT key FROM 'UCS rejected' WHERE value='%s'" % ucs_dn) |
47 |
c.execute("SELECT key FROM 'UCS rejected' WHERE value=?" % [unicode(ucs_dn)]) |
48 |
filenames = c.fetchall() |
48 |
filenames = c.fetchall() |
49 |
if not filenames: |
49 |
if not filenames: |
50 |
raise ObjectNotFound |
50 |
raise ObjectNotFound |
Lines 52-58
def remove_ucs_rejected(ucs_dn):
|
Link Here
|
---|
|
52 |
if filename: |
52 |
if filename: |
53 |
if os.path.exists(filename[0]): |
53 |
if os.path.exists(filename[0]): |
54 |
os.remove(filename[0]) |
54 |
os.remove(filename[0]) |
55 |
c.execute("DELETE FROM 'UCS rejected' WHERE value='%s'" % ucs_dn) |
55 |
c.execute("DELETE FROM 'UCS rejected' WHERE value=?" % [unicode(ucs_dn)]) |
56 |
cache_db.commit() |
56 |
cache_db.commit() |
57 |
cache_db.close() |
57 |
cache_db.close() |
58 |
|
58 |
|