X-Git-Url: https://git.decadent.org.uk/gitweb/?a=blobdiff_plain;f=daklib%2Fdatabase.py;h=49c18f9e3731b34850c9463672f30e3a26911733;hb=b7e5c9a6deda1018da9023d1d01acec86e165ba4;hp=606e8f2de8ba76afbe38528ac77610684252dfe6;hpb=8131766bb2726c10767caecd845b06df4d62c896;p=dak.git diff --git a/daklib/database.py b/daklib/database.py index 606e8f2d..49c18f9e 100755 --- a/daklib/database.py +++ b/daklib/database.py @@ -486,6 +486,33 @@ def get_suite_architectures(suite): q = projectB.query(sql) return map(lambda x: x[0], q.getresult()) +def get_suite_untouchable(suite): + """ + Returns true if the C{suite} is untouchable, otherwise false. + + @type suite: string, int + @param suite: the suite name or the suite_id + + @rtype: boolean + @return: status of suite + """ + + suite_id = None + if type(suite) == str: + suite_id = get_suite_id(suite.lower()) + elif type(suite) == int: + suite_id = suite + else: + return None + + sql = """ SELECT untouchable FROM suite WHERE id='%s' """ % (suite_id) + + q = projectB.query(sql) + if q.getresult()[0][0] == "f": + return False + else: + return True + ################################################################################ def get_or_set_maintainer_id (maintainer): @@ -811,7 +838,7 @@ def get_suites(pkgname, src=False): ################################################################################ -def copy_temporary_contents(package, version, deb, reject): +def copy_temporary_contents(package, version, arch, deb, reject): """ copy the previously stored contents from the temp table to the permanant one @@ -821,8 +848,13 @@ def copy_temporary_contents(package, version, deb, reject): # first see if contents exist: + arch_id = database.get_architecture_id (architecture) + exists = projectB.query("""SELECT 1 FROM pending_content_associations - WHERE package='%s' LIMIT 1""" % package ).getresult() + WHERE package='%s' + AND version='%s' + AND architecture=%d LIMIT 1""" + % package, version, arch_id ).getresult() if not exists: # This should NOT happen. We should have added contents @@ -831,6 +863,7 @@ def copy_temporary_contents(package, version, deb, reject): subst = { "__PACKAGE__": package, "__VERSION__": version, + "__ARCH__": arch, "__TO_ADDRESS__": Cnf["Dinstall::MyAdminAddress"], "__DAK_ADDRESS__": Cnf["Dinstall::MyEmailAddress"] } @@ -843,10 +876,12 @@ def copy_temporary_contents(package, version, deb, reject): sql = """INSERT INTO content_associations(binary_pkg,filepath,filename) SELECT currval('binaries_id_seq'), filepath, filename FROM pending_content_associations WHERE package='%s' - AND version='%s'""" % (package, version) + AND version='%s' + AND architecture=%d""" % (package, version, arch_id) projectB.query(sql) projectB.query("""DELETE from pending_content_associations WHERE package='%s' - AND version='%s'""" % (package, version)) + AND version='%s' + AND architecture=%d""" % (package, version, arch_id)) return exists