X-Git-Url: https://git.decadent.org.uk/gitweb/?a=blobdiff_plain;f=alyson;h=a1b75d34381f3ca66ba1c979dc86da5e1dbac9bb;hb=9540d873fa78598454af57f5f8a4875969ed0439;hp=c6c401985dacb63902e71ea79db2c61fdfed657d;hpb=4b41dc06229eed89f52f397fc7df5d665fa092cf;p=dak.git diff --git a/alyson b/alyson index c6c40198..a1b75d34 100755 --- a/alyson +++ b/alyson @@ -1,8 +1,8 @@ #!/usr/bin/env python # Sync the ISC configuartion file and the SQL database -# Copyright (C) 2000 James Troup -# $Id: alyson,v 1.2 2001-01-16 21:52:37 troup Exp $ +# Copyright (C) 2000, 2001, 2002, 2003 James Troup +# $Id: alyson,v 1.12 2003-09-07 13:52:07 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 @@ -20,8 +20,8 @@ ################################################################################ -import pg, sys, string -import utils, db_access +import pg, sys; +import utils, db_access; import apt_pkg; ################################################################################ @@ -31,58 +31,149 @@ projectB = None; ################################################################################ +def usage(exit_code=0): + print """Usage: alyson +Initalizes some tables in the projectB database based on the config file. + + -h, --help show this help and exit.""" + sys.exit(exit_code) + +################################################################################ + +def get (c, i): + if c.has_key(i): + return "'%s'" % (c[i]); + else: + return "NULL"; + def main (): global Cnf, projectB; - apt_pkg.init(); - - Cnf = apt_pkg.newConfiguration(); - apt_pkg.ReadConfigFileISC(Cnf,utils.which_conf_file()); - Arguments = [('D',"debug","Alyson::Options::Debug", "IntVal"), - ('h',"help","Alyson::Options::Help"), - ('v',"version","Alyson::Options::Version")]; - apt_pkg.ParseCommandLine(Cnf,Arguments,sys.argv); + Cnf = utils.get_conf() + Arguments = [('h',"help","Alyson::Options::Help")]; + for i in [ "help" ]: + if not Cnf.has_key("Alyson::Options::%s" % (i)): + Cnf["Alyson::Options::%s" % (i)] = ""; - projectB = pg.connect('projectb', 'localhost'); + apt_pkg.ParseCommandLine(Cnf, Arguments, sys.argv); + + Options = Cnf.SubTree("Alyson::Options") + if Options["Help"]: + usage(); + + projectB = pg.connect(Cnf["DB::Name"], Cnf["DB::Host"], int(Cnf["DB::Port"])); db_access.init(Cnf, projectB); - # Quick hack to populate section, priority and bin_type; the rest todo later + # archive + + projectB.query("BEGIN WORK"); + projectB.query("DELETE FROM archive"); + for name in Cnf.SubTree("Archive").List(): + Archive = Cnf.SubTree("Archive::%s" % (name)); + origin_server = get(Archive, "OriginServer"); + description = get(Archive, "Description"); + projectB.query("INSERT INTO archive (name, origin_server, description) VALUES ('%s', %s, %s)" % (name, origin_server, description)); + projectB.query("COMMIT WORK"); + + # architecture + + projectB.query("BEGIN WORK"); + projectB.query("DELETE FROM architecture"); + for arch in Cnf.SubTree("Architectures").List(): + description = Cnf["Architectures::%s" % (arch)]; + projectB.query("INSERT INTO architecture (arch_string, description) VALUES ('%s', '%s')" % (arch, description)); + projectB.query("COMMIT WORK"); + + # component + + projectB.query("BEGIN WORK"); + projectB.query("DELETE FROM component"); + for name in Cnf.SubTree("Component").List(): + Component = Cnf.SubTree("Component::%s" % (name)); + description = get(Component, "Description"); + if Component.get("MeetsDFSG").lower() == "true": + meets_dfsg = "true"; + else: + meets_dfsg = "false"; + projectB.query("INSERT INTO component (name, description, meets_dfsg) VALUES ('%s', %s, %s)" % (name, description, meets_dfsg)); + projectB.query("COMMIT WORK"); + + # location + + projectB.query("BEGIN WORK"); + projectB.query("DELETE FROM location"); + for location in Cnf.SubTree("Location").List(): + Location = Cnf.SubTree("Location::%s" % (location)); + archive_id = db_access.get_archive_id(Location["Archive"]); + type = Location.get("type"); + if type == "legacy-mixed": + projectB.query("INSERT INTO location (path, archive, type) VALUES ('%s', %d, '%s')" % (location, archive_id, Location["type"])); + elif type == "legacy" or type == "pool": + for component in Cnf.SubTree("Component").List(): + component_id = db_access.get_component_id(component); + projectB.query("INSERT INTO location (path, component, archive, type) VALUES ('%s', %d, %d, '%s')" % + (location, component_id, archive_id, type)); + else: + utils.fubar("E: type '%s' not recognised in location %s." % (type, location)); + projectB.query("COMMIT WORK"); + + # suite + + projectB.query("BEGIN WORK"); + projectB.query("DELETE FROM suite") + for suite in Cnf.SubTree("Suite").List(): + Suite = Cnf.SubTree("Suite::%s" %(suite)) + version = get(Suite, "Version"); + origin = get(Suite, "Origin"); + description = get(Suite, "Description"); + projectB.query("INSERT INTO suite (suite_name, version, origin, description) VALUES ('%s', %s, %s, %s)" + % (suite.lower(), version, origin, description)); + for architecture in Cnf.ValueList("Suite::%s::Architectures" % (suite)): + architecture_id = db_access.get_architecture_id (architecture); + if architecture_id < 0: + utils.fubar("architecture '%s' not found in architecture table for suite %s." % (architecture, suite)); + projectB.query("INSERT INTO suite_architectures (suite, architecture) VALUES (currval('suite_id_seq'), %d)" % (architecture_id)); + projectB.query("COMMIT WORK"); + + # override_type projectB.query("BEGIN WORK"); projectB.query("DELETE FROM override_type"); - for type in Cnf.SubTree("OverrideType").List(): + for type in Cnf.ValueList("OverrideType"): projectB.query("INSERT INTO override_type (type) VALUES ('%s')" % (type)); projectB.query("COMMIT WORK"); - + + # priority + projectB.query("BEGIN WORK"); projectB.query("DELETE FROM priority"); for priority in Cnf.SubTree("Priority").List(): projectB.query("INSERT INTO priority (priority, level) VALUES ('%s', %s)" % (priority, Cnf["Priority::%s" % (priority)])); projectB.query("COMMIT WORK"); + # section + projectB.query("BEGIN WORK"); projectB.query("DELETE FROM section"); for component in Cnf.SubTree("Component").List(): if Cnf["Natalie::ComponentPosition"] == "prefix": suffix = ""; - if component != 'main': + if component != "main": prefix = component + '/'; else: prefix = ""; else: prefix = ""; - component = string.replace(component, "non-US/", ""); - if component != 'main': + component = component.replace("non-US/", ""); + if component != "main": suffix = '/' + component; else: suffix = ""; - for section in Cnf.SubTree("Section").List(): + for section in Cnf.ValueList("Section"): projectB.query("INSERT INTO section (section) VALUES ('%s%s%s')" % (prefix, section, suffix)); projectB.query("COMMIT WORK"); - - -####################################################################################### +################################################################################ if __name__ == '__main__': main()