--- /dev/null
+#!/usr/bin/env python
+
+# Fix testing
+# Copyright (C) 2000, 2001 James Troup <james@nocrew.org>
+# $Id: hack.6,v 1.1 2001-06-05 22:31:33 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
+# the Free Software Foundation; either version 2 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+################################################################################
+
+# 'Too afraid to touch; too afraid you'll like too much'
+
+################################################################################
+
+import pg, sys, os, string
+import utils, db_access
+import apt_inst, apt_pkg;
+
+################################################################################
+
+Cnf = None;
+projectB = None;
+
+################################################################################
+
+def main ():
+ global Cnf, projectB, db_files, waste, excluded;
+
+ apt_pkg.init();
+
+ Cnf = apt_pkg.newConfiguration();
+ apt_pkg.ReadConfigFileISC(Cnf,utils.which_conf_file());
+
+ Arguments = [('d',"debug","Christina::Options::Debug", "IntVal"),
+ ('h',"help","Christina::Options::Help"),
+ ('v',"version","Christina::Options::Version")];
+
+ apt_pkg.ParseCommandLine(Cnf,Arguments,sys.argv);
+ projectB = pg.connect(Cnf["DB::Name"], Cnf["DB::Host"], int(Cnf["DB::Port"]));
+ christina = pg.connect('christina', Cnf["DB::Host"], int(Cnf["DB::Port"]));
+ db_access.init(Cnf, projectB);
+
+ total = 0; found = 0;
+ morgue = Cnf["Dir::Morgue"] + '/' + Cnf["Rhona::MorgueSubDir"];
+
+ xxx = utils.open_file ("xxx", 'r');
+ for line in xxx.readlines():
+ (package, version, arch) = string.split(line);
+ eversion = utils.re_no_epoch.sub('', version);
+ total = total + 1;
+ if arch != "source":
+ #filename = "%s/%s_%s_%s.deb" % (morgue, package, eversion, arch);
+ filename = "%s/%s_%s.deb" % (morgue, package, eversion);
+ else:
+ continue
+ if os.access(filename, os.R_OK) == 0:
+ continue;
+
+ control = apt_pkg.ParseSection(apt_inst.debExtractControl(utils.open_file(filename,"r")));
+ deb_arch = control.Find("Architecture");
+ if arch != deb_arch:
+ continue;
+
+ arch_id = db_access.get_architecture_id (arch);
+ q = christina.query("SELECT f.*, l.path, b.* FROM binaries b, files f, location l WHERE b.package = '%s' AND b.architecture = %s AND b.version = '%s' AND b.file = f.id AND l.id = f.location" % (package, arch_id, version));
+ ql = q.getresult();
+ if len(ql) != 1:
+ print "YOU LOSE: "+package+"~"+version+"~"+arch+"~"+repr(ql)
+ continue;
+ ql = ql[0];
+
+ x = projectB.query("SELECT * FROM source WHERE id = %s" % (ql[11]));
+ xl = x.getresult();
+ if len(xl) != 1:
+ old_filename = filename;
+ z = christina.query("SELECT f.*, l.path, s.*, df.* FROM source s, files f, location l, dsc_files df WHERE s.id = %s AND df.source = s.id AND df.file = f.id AND l.id = f.location" % (ql[11]));
+ zl = z.getresult();
+ if len(zl) < 1:
+ print old_filename
+ print repr(ql);
+ print "SELECT f.*, l.path, s.*, df.* FROM source s, files f, location l, dsc_files df WHERE s.id = %s AND df.source = s.id AND df.file = f.id AND l.id = f.location" % (ql[11]);
+ print " ==> "+repr(zl);
+ #sys.exit(3);
+ else:
+ projectB.query("BEGIN WORK");
+ gack = [];
+ for i in zl:
+ new_filename = i[6] + i[1];
+ filename = morgue + '/' + os.path.basename(new_filename);
+ if os.access(filename, os.R_OK):
+ print filename + " -> " + new_filename;
+ if os.path.exists(new_filename):
+ sys.exit(3);
+ #utils.move(filename, new_filename);
+ print "INSERT INTO files (id, filename, size, md5sum, location) VALUES (%s, '%s', %s, '%s', %s)" % (i[:5]);
+ #projectB.query("INSERT INTO files (id, filename, size, md5sum, location) VALUES (%s, '%s', %s, '%s', %s)" % (i[:5]));
+ gack.append("INSERT INTO dsc_files (id, source, file) VALUES (%s, %s, %s)" % (i[12:]));
+ if new_filename[-4:] == ".dsc":
+ print "INSERT INTO source (id, source, version, maintainer, file) VALUES (%s, '%s', '%s', %s, %s)" % (i[7:12]);
+ #projectB.query("INSERT INTO source (id, source, version, maintainer, file) VALUES (%s, '%s', '%s', %s, %s)" % (i[7:12]));
+ for i in gack:
+ print i;
+ #projectB.query(i);
+ projectB.query("COMMIT WORK");
+ filename = old_filename;
+
+ projectB.query("BEGIN WORK");
+ new_filename = ql[6] + ql[1];
+ print filename + " -> " + new_filename;
+ if os.path.exists(new_filename):
+ sys.exit(3);
+ utils.move(filename, new_filename);
+ print "INSERT INTO files (id, filename, size, md5sum, location) VALUES (%s, '%s', %s, '%s', %s)" % (ql[:5]);
+ projectB.query("INSERT INTO files (id, filename, size, md5sum, location) VALUES (%s, '%s', %s, '%s', %s)" % (ql[:5]));
+ if ql[11] == 0:
+ print "INSERT INTO binaries (id, package, version, maintainer, architecture, file, type) VALUES (%s, '%s', '%s', %s, %s, %s, '%s')" % (ql[7], ql[8], ql[9], ql[10], ql[12], ql[13], ql[14]);
+ projectB.query("INSERT INTO binaries (id, package, version, maintainer, architecture, file, type) VALUES (%s, '%s', '%s', %s, %s, %s, '%s')" % (ql[7], ql[8], ql[9], ql[10], ql[12], ql[13], ql[14]));
+ else:
+ print "INSERT INTO binaries (id, package, version, maintainer, source, architecture, file, type) VALUES (%s, '%s', '%s', %s, %s, %s, %s, '%s')" % (ql[7:]);
+ projectB.query("INSERT INTO binaries (id, package, version, maintainer, source, architecture, file, type) VALUES (%s, '%s', '%s', %s, %s, %s, %s, '%s')" % (ql[7:]));
+ print "INSERT INTO bin_associations (suite, bin) VALUES (%s, %s)" % (4, ql[7]);
+ projectB.query("INSERT INTO bin_associations (suite, bin) VALUES (%s, %s)" % (4, ql[7]));
+
+ projectB.query("COMMIT WORK");
+
+#######################################################################################
+
+if __name__ == '__main__':
+ main()
+
+#######################################################################################
+
+# xxx = utils.open_file ("xxx", 'r');
+# for line in xxx.readlines():
+# (package, version, arch) = string.split(line);
+# eversion = utils.re_no_epoch.sub('', version);
+# total = total + 1;
+# if arch == "source":
+# filename = "%s/%s_%s.dsc" % (morgue, package, eversion);
+# else:
+# continue
+# if os.access(filename, os.R_OK) == 0:
+# continue;
+
+# arch_id = db_access.get_architecture_id (arch);
+# q = christina.query("SELECT f.*, l.path, s.*, df.* FROM source s, files f, location l, dsc_files df WHERE s.source = '%s' AND s.version = '%s' AND df.source = s.id AND df.file = f.id AND l.id = f.location" % (package, version));
+# ql = q.getresult();
+# if len(ql) < 1:
+# print "YOU LOSE: "+package+"~"+version+"~"+arch+"~"+repr(ql)
+# continue;
+# projectB.query("BEGIN WORK");
+# gack = [];
+# for i in ql:
+# new_filename = i[6] + i[1];
+# filename = morgue + '/' + os.path.basename(new_filename);
+# if os.access(filename, os.R_OK) == 0:
+# continue;
+# print filename + " -> " + new_filename;
+# if os.path.exists(new_filename):
+# sys.exit(3);
+# utils.move(filename, new_filename);
+# print "INSERT INTO files (id, filename, size, md5sum, location) VALUES (%s, '%s', %s, '%s', %s)" % (i[:5]);
+# projectB.query("INSERT INTO files (id, filename, size, md5sum, location) VALUES (%s, '%s', %s, '%s', %s)" % (i[:5]));
+# gack.append("INSERT INTO dsc_files (id, source, file) VALUES (%s, %s, %s)" % (i[12:]));
+# if new_filename[-4:] == ".dsc":
+# print "INSERT INTO source (id, source, version, maintainer, file) VALUES (%s, '%s', '%s', %s, %s)" % (i[7:12]);
+# projectB.query("INSERT INTO source (id, source, version, maintainer, file) VALUES (%s, '%s', '%s', %s, %s)" % (i[7:12]));
+# print "INSERT INTO src_associations (suite, source) VALUES (%s, %s)" % (4, i[7]);
+# projectB.query("INSERT INTO src_associations (suite, source) VALUES (%s, %s)" % (4, i[7]));
+# #print repr(i)
+# for i in gack:
+# print i;
+# projectB.query(i);
+# projectB.query("COMMIT WORK");
+
+#######################################################################################
+
+#######################################################################################
+
+# bad = {};
+# xxx = utils.open_file ("xxx", 'r');
+# for line in xxx.readlines():
+# (package, version, arch) = string.split(line);
+# version = utils.re_no_epoch.sub('', version);
+# total = total + 1;
+# if arch != "source":
+# filename = "%s/%s_%s_%s.deb" % (morgue, package, version, arch);
+# else:
+# filename = "%s/%s_%s.dsc" % (morgue, package, version);
+# if os.access(filename, os.R_OK):
+# found = found + 1;
+# else:
+# if arch != "source":
+# filename = "%s/%s_%s.deb" % (morgue, package, version);
+# if os.access(filename, os.R_OK):
+# control = apt_pkg.ParseSection(apt_inst.debExtractControl(utils.open_file(filename,"r")));
+# deb_arch = control.Find("Architecture");
+# if arch == deb_arch:
+# found = found + 1;
+# continue;
+# if arch != "source":
+# xf = 0;
+# arch_id = db_access.get_architecture_id (arch);
+# q = projectB.query("SELECT version FROM binaries b, bin_associations ba WHERE b.package = '%s' AND b.architecture = %s AND ba.bin = b.id AND ba.suite = 5" % (package, arch_id));
+# ql = q.getresult();
+# if len(ql) != 1:
+# q = projectB.query("SELECT version FROM binaries b, bin_associations ba WHERE b.package = '%s' AND b.architecture = %s AND ba.bin = b.id AND ba.suite = 2" % (package, arch_id));
+# ql = q.getresult();
+# if len(ql) != 1:
+# #print "YOU LOSE: "+package+"~"+version+"~"+arch+"~"+repr(ql)
+# continue;
+
+# unstable_version = ql[0][0];
+# print package+" "+unstable_version+" "+arch;
+# found = found + 1;
+# else:
+# q = projectB.query("SELECT version FROM source s, src_associations sa WHERE s.source = '%s' AND sa.source = s.id AND sa.suite = 5" % (package));
+# ql = q.getresult();
+# if len(ql) != 1:
+# q = projectB.query("SELECT version FROM source s, src_associations sa WHERE s.source = '%s' AND sa.source = s.id AND sa.suite = 2" % (package));
+# ql = q.getresult();
+# if len(ql) != 1:
+# #print "YOU LOSE: "+package+"~"+version+"~"+arch+"~"+repr(ql)
+# continue;
+
+# unstable_version = ql[0][0];
+# print package+" "+unstable_version+" "+arch;
+# found = found + 1;
+
+# #print "Good: %d / %d (%.2f%%)" % (found, total, (float(found)/total*100));
+# #not_found = total - found;
+# #print "Bad: %d / %d (%.2f%%)" % (not_found, total, (float(not_found)/total*100));
+
+#######################################################################################
+
+# Pretty print bad stuff code
+
+# key = package+'~'+version;
+# if not bad.has_key(key):
+# bad[key] = [];
+# bad[key].append(arch);
+
+# keys = bad.keys();
+# keys.sort();
+# for i in keys:
+# print i+": "+repr(bad[i]);
+
+
+
+# Check if is in DB code
+
+# arch_id = db_access.get_architecture_id (arch);
+# q = projectB.query("SELECT id FROM binaries WHERE package = '%s' AND version = '%s' AND architecture = %s" % (package, version, arch_id));
+# ql = q.getresult();
+# if ql != []:
+# found = found + 1;
+
+# q = projectB.query("SELECT id FROM source WHERE source = '%s' AND version = '%s'" % (package, version));
+# ql = q.getresult();
+# if ql != []:
+# found = found + 1;
projects / dak.git / commitdiff