X-Git-Url: https://git.decadent.org.uk/gitweb/?a=blobdiff_plain;f=dak%2Fdakdb%2Fupdate28.py;h=1455ee3110284d3cdd4d48effd237f1d0a1fc2d0;hb=e2c4fd7f21c3b33cd7192bded5d6373e0ee90374;hp=f1c8b2fa3a9f2bcb5c960baf4cebeb0fea8c17fe;hpb=a4d0d5dc90348e09db42dafb4e4e6bd15ec1d202;p=dak.git diff --git a/dak/dakdb/update28.py b/dak/dakdb/update28.py index f1c8b2fa..1455ee31 100755 --- a/dak/dakdb/update28.py +++ b/dak/dakdb/update28.py @@ -32,6 +32,7 @@ import psycopg2 import time from daklib.dak_exceptions import DBUpdateError from daklib.config import Config +import string ################################################################################ @@ -50,7 +51,7 @@ def arches(cursor, suite): cursor.execute("""SELECT s.architecture, a.arch_string FROM suite_architectures s JOIN architecture a ON (s.architecture=a.id) - WHERE suite = :suite""", {'suite' : suite }) + WHERE suite = '%s'""" % suite) while True: r = cursor.fetchone() @@ -143,17 +144,19 @@ def do_update(self): for suite in [i.lower() for i in suites]: c.execute("SELECT id FROM suite WHERE suite_name ='%s'" % suite ) - suiterow = c.fetchall() - suite_id=suiterow[0] + suiterow = c.fetchone() + suite_id = suiterow[0] arch_list = arches(c, suite_id) arch_list = arches(c, suite_id) + suitestr=string.replace(suite,'-','_'); for (arch_id,arch_str) in arch_list: - c.execute( "CREATE INDEX ind_deb_contents_%s_%s ON deb_contents (arch,suite) WHERE (arch=2 OR arch=%d) AND suite=$d"%(arch_str,suite,arch_id,suite_id) ) + arch_str = string.replace(arch_str,"-", "_") + c.execute( "CREATE INDEX ind_deb_contents_%s_%s ON deb_contents (arch,suite) WHERE (arch=2 OR arch=%s) AND suite='%s'"%(arch_str,suitestr,arch_id,suite_id) ) for section, sname in [("debian-installer","main"), ("non-free/debian-installer", "nonfree")]: - c.execute( "CREATE INDEX ind_udeb_contents_%s_%s ON udeb_contents (section,suite) WHERE section=%s AND suite=$d"%(sname,suite,section,suite_id) ) + c.execute( "CREATE INDEX ind_udeb_contents_%s_%s ON udeb_contents (section,suite) WHERE section='%s' AND suite='%s'"%(sname,suitestr,section,suite_id) ) c.execute( """CREATE OR REPLACE FUNCTION update_contents_for_bin_a() RETURNS trigger AS $$ @@ -262,7 +265,7 @@ $$ LANGUAGE plpythonu VOLATILE;""") self.db.commit() - except psycopg2.ProgrammingError, msg: + except psycopg2.ProgrammingError as msg: self.db.rollback() - raise DBUpdateError, "Unable to apply process-new update 28, rollback issued. Error message : %s" % (str(msg)) + raise DBUpdateError("Unable to apply process-new update 28, rollback issued. Error message : %s" % (str(msg)))