X-Git-Url: https://git.donarmstrong.com/?a=blobdiff_plain;f=db_access.py;h=cb8df363c7e13ba1a05edbef05734f26cc33d172;hb=d904756049f3c53b562cd2c1f96f7e09dba21949;hp=8760d91bbd475f801281dabb8e7d29f00ebaa27b;hpb=bb8283ad6274e461fc78a00b2a52c6594c53e13d;p=dak.git diff --git a/db_access.py b/db_access.py index 8760d91b..cb8df363 100644 --- a/db_access.py +++ b/db_access.py @@ -1,6 +1,6 @@ # DB access fucntions -# Copyright (C) 2000 James Troup -# $Id: db_access.py,v 1.3 2000-12-05 04:27:48 troup Exp $ +# Copyright (C) 2000, 2001 James Troup +# $Id: db_access.py,v 1.8 2001-09-27 01:12:42 troup Exp $ # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by @@ -18,20 +18,28 @@ import pg, string -Cnf = None -projectB = None -suite_id_cache = {} -architecture_id_cache = {} -archive_id_cache = {} -component_id_cache = {} -location_id_cache = {} -maintainer_id_cache = {} -source_id_cache = {} -files_id_cache = {} +############################################################################################ + +Cnf = None; +projectB = None; +suite_id_cache = {}; +section_id_cache = {}; +priority_id_cache = {}; +override_type_id_cache = {}; +architecture_id_cache = {}; +archive_id_cache = {}; +component_id_cache = {}; +location_id_cache = {}; +maintainer_id_cache = {}; +source_id_cache = {}; +files_id_cache = {}; +maintainer_cache = {} + +############################################################################################ def init (config, sql): global Cnf, projectB - + Cnf = config; projectB = sql; @@ -46,24 +54,76 @@ def get_suite_id (suite): q = projectB.query("SELECT id FROM suite WHERE suite_name = '%s'" % (suite)) ql = q.getresult(); if ql == []: - return -1; - - suite_id = q.getresult()[0][0] + return -1; + + suite_id = ql[0][0]; suite_id_cache[suite] = suite_id return suite_id +def get_section_id (section): + global section_id_cache + + if section_id_cache.has_key(section): + return section_id_cache[section] + + q = projectB.query("SELECT id FROM section WHERE section = '%s'" % (section)) + ql = q.getresult(); + if ql == []: + return -1; + + section_id = ql[0][0]; + section_id_cache[section] = section_id + + return section_id + +def get_priority_id (priority): + global priority_id_cache + + if priority_id_cache.has_key(priority): + return priority_id_cache[priority] + + q = projectB.query("SELECT id FROM priority WHERE priority = '%s'" % (priority)) + ql = q.getresult(); + if ql == []: + return -1; + + priority_id = ql[0][0]; + priority_id_cache[priority] = priority_id + + return priority_id + +def get_override_type_id (type): + global override_type_id_cache; + + if override_type_id_cache.has_key(type): + return override_type_id_cache[type]; + + q = projectB.query("SELECT id FROM override_type WHERE type = '%s'" % (type)); + ql = q.getresult(); + if ql == []: + return -1; + + override_type_id = ql[0][0]; + override_type_id_cache[type] = override_type_id; + + return override_type_id; + def get_architecture_id (architecture): - global architecture_id_cache + global architecture_id_cache; if architecture_id_cache.has_key(architecture): - return architecture_id_cache[architecture] + return architecture_id_cache[architecture]; q = projectB.query("SELECT id FROM architecture WHERE arch_string = '%s'" % (architecture)) - architecture_id = q.getresult()[0][0] - architecture_id_cache[architecture] = architecture_id + ql = q.getresult(); + if ql == []: + return -1; + + architecture_id = ql[0][0]; + architecture_id_cache[architecture] = architecture_id; - return architecture_id + return architecture_id; def get_archive_id (archive): global archive_id_cache @@ -88,7 +148,7 @@ def get_component_id (component): if ql == []: return -1; - component_id = ql[0][0] + component_id = ql[0][0]; component_id_cache[component] = component_id return component_id @@ -156,17 +216,18 @@ def get_files_id (filename, size, md5sum, location_id): if files_id_cache.has_key(cache_key): return files_id_cache[cache_key] + size = int(size); q = projectB.query("SELECT id, size, md5sum FROM files WHERE filename = '%s' AND location = %d" % (filename, location_id)); ql = q.getresult(); if ql: if len(ql) != 1: return -1; - ql = ql[0] - orig_size = ql[1]; + ql = ql[0]; + orig_size = int(ql[1]); orig_md5sum = ql[2]; if orig_size != size or orig_md5sum != md5sum: return -2; - files_id_cache[cache_key] = ql[0] + files_id_cache[cache_key] = ql[0]; return files_id_cache[cache_key] else: return None @@ -180,7 +241,7 @@ def set_files_id (filename, size, md5sum, location_id): cache_key = "%s~%d" % (filename, location_id); #print "INSERT INTO files (filename, size, md5sum, location) VALUES ('%s', %d, '%s', %d)" % (filename, long(size), md5sum, location_id); - projectB.query("INSERT INTO files (filename, size, md5sum, location) VALUES ('%s', %d, '%s', %d)" % (filename, long(size), md5sum, location_id)); + projectB.query("INSERT INTO files (filename, size, md5sum, location) VALUES ('%s', %d, '%s', %d)" % (filename, long(size), md5sum, location_id)); q = projectB.query("SELECT id FROM files WHERE id = currval('files_id_seq')"); ql = q.getresult()[0]; files_id_cache[cache_key] = ql[0] @@ -189,3 +250,13 @@ def set_files_id (filename, size, md5sum, location_id): ########################################################################################## +def get_maintainer (maintainer_id): + global maintainer_cache; + + if not maintainer_cache.has_key(maintainer_id): + q = projectB.query("SELECT name FROM maintainer WHERE id = %s" % (maintainer_id)); + maintainer_cache[maintainer_id] = q.getresult()[0][0]; + + return maintainer_cache[maintainer_id]; + +##########################################################################################