5 keep contents of binary packages in tables so we can generate contents.gz files from dak
7 @contact: Debian FTP Master <ftpmaster@debian.org>
8 @copyright: 2009 Mike O'Connor <stew@debian.org>
9 @license: GNU General Public License version 2 or later
12 # This program is free software; you can redistribute it and/or modify
13 # it under the terms of the GNU General Public License as published by
14 # the Free Software Foundation; either version 2 of the License, or
15 # (at your option) any later version.
17 # This program is distributed in the hope that it will be useful,
18 # but WITHOUT ANY WARRANTY; without even the implied warranty of
19 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
20 # GNU General Public License for more details.
22 # You should have received a copy of the GNU General Public License
23 # along with this program; if not, write to the Free Software
24 # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
26 ################################################################################
29 ################################################################################
33 from daklib.dak_exceptions import DBUpdateError
34 from daklib.config import Config
36 ################################################################################
40 return a list of suites to operate on
42 if Config().has_key( "%s::%s" %(options_prefix,"Suite")):
43 suites = utils.split_args(Config()[ "%s::%s" %(options_prefix,"Suite")])
45 suites = Config().SubTree("Suite").List()
49 def arches(cursor, suite):
51 return a list of archs to operate on
54 cursor.execute("""SELECT s.architecture, a.arch_string
55 FROM suite_architectures s
56 JOIN architecture a ON (s.architecture=a.id)
57 WHERE suite = :suite""", {'suite' : suite })
64 if r[1] != "source" and r[1] != "all":
65 arch_list.append((r[0], r[1]))
71 Adding contents table as first step to maybe, finally getting rid
80 c.execute("""CREATE TABLE pending_bin_contents (
82 package text NOT NULL,
83 version debversion NOT NULL,
85 filename text NOT NULL,
87 PRIMARY KEY(id))""" );
89 c.execute("""CREATE TABLE deb_contents (
97 c.execute("""CREATE TABLE udeb_contents (
105 c.execute("""ALTER TABLE ONLY deb_contents
106 ADD CONSTRAINT deb_contents_arch_fkey
107 FOREIGN KEY (arch) REFERENCES architecture(id)
108 ON DELETE CASCADE;""")
110 c.execute("""ALTER TABLE ONLY udeb_contents
111 ADD CONSTRAINT udeb_contents_arch_fkey
112 FOREIGN KEY (arch) REFERENCES architecture(id)
113 ON DELETE CASCADE;""")
115 c.execute("""ALTER TABLE ONLY deb_contents
116 ADD CONSTRAINT deb_contents_pkey
117 PRIMARY KEY (filename,package,arch,suite);""")
119 c.execute("""ALTER TABLE ONLY udeb_contents
120 ADD CONSTRAINT udeb_contents_pkey
121 PRIMARY KEY (filename,package,arch,suite);""")
123 c.execute("""ALTER TABLE ONLY deb_contents
124 ADD CONSTRAINT deb_contents_suite_fkey
125 FOREIGN KEY (suite) REFERENCES suite(id)
126 ON DELETE CASCADE;""")
128 c.execute("""ALTER TABLE ONLY udeb_contents
129 ADD CONSTRAINT udeb_contents_suite_fkey
130 FOREIGN KEY (suite) REFERENCES suite(id)
131 ON DELETE CASCADE;""")
133 c.execute("""ALTER TABLE ONLY deb_contents
134 ADD CONSTRAINT deb_contents_binary_fkey
135 FOREIGN KEY (binary_id) REFERENCES binaries(id)
136 ON DELETE CASCADE;""")
138 c.execute("""ALTER TABLE ONLY udeb_contents
139 ADD CONSTRAINT udeb_contents_binary_fkey
140 FOREIGN KEY (binary_id) REFERENCES binaries(id)
141 ON DELETE CASCADE;""")
143 c.execute("""CREATE INDEX ind_deb_contents_binary ON deb_contents(binary_id);""" )
147 for suite in [i.lower() for i in suites]:
148 suite_id = DBConn().get_suite_id(suite)
149 arch_list = arches(c, suite_id)
150 arch_list = arches(c, suite_id)
152 for (arch_id,arch_str) in arch_list:
153 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) )
155 for section, sname in [("debian-installer","main"),
156 ("non-free/debian-installer", "nonfree")]:
157 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) )
160 c.execute( """CREATE OR REPLACE FUNCTION update_contents_for_bin_a() RETURNS trigger AS $$
162 if event == "DELETE" or event == "UPDATE":
164 plpy.execute(plpy.prepare("DELETE FROM deb_contents WHERE binary_id=$1 and suite=$2",
166 [TD["old"]["bin"], TD["old"]["suite"]])
168 if event == "INSERT" or event == "UPDATE":
170 content_data = plpy.execute(plpy.prepare(
171 \"\"\"SELECT s.section, b.package, b.architecture, ot.type
173 JOIN override_type ot on o.type=ot.id
174 JOIN binaries b on b.package=o.package
175 JOIN files f on b.file=f.id
176 JOIN location l on l.id=f.location
177 JOIN section s on s.id=o.section
182 [TD["new"]["bin"], TD["new"]["suite"]])[0]
184 tablename="%s_contents" % content_data['type']
186 plpy.execute(plpy.prepare(\"\"\"DELETE FROM %s
187 WHERE package=$1 and arch=$2 and suite=$3\"\"\" % tablename,
188 ['text','int','int']),
189 [content_data['package'],
190 content_data['architecture'],
193 filenames = plpy.execute(plpy.prepare(
194 "SELECT bc.file FROM bin_contents bc where bc.binary_id=$1",
198 for filename in filenames:
199 plpy.execute(plpy.prepare(
201 (filename,section,package,binary_id,arch,suite)
202 VALUES($1,$2,$3,$4,$5,$6)\"\"\" % tablename,
203 ["text","text","text","int","int","int"]),
205 content_data["section"],
206 content_data["package"],
208 content_data["architecture"],
209 TD["new"]["suite"]] )
210 $$ LANGUAGE plpythonu VOLATILE SECURITY DEFINER;
214 c.execute( """CREATE OR REPLACE FUNCTION update_contents_for_override() RETURNS trigger AS $$
216 if event == "UPDATE":
218 otype = plpy.execute(plpy.prepare("SELECT type from override_type where id=$1",["int"]),[TD["new"]["type"]] )[0];
219 if otype["type"].endswith("deb"):
220 section = plpy.execute(plpy.prepare("SELECT section from section where id=$1",["int"]),[TD["new"]["section"]] )[0];
222 table_name = "%s_contents" % otype["type"]
223 plpy.execute(plpy.prepare("UPDATE %s set section=$1 where package=$2 and suite=$3" % table_name,
224 ["text","text","int"]),
226 TD["new"]["package"],
229 $$ LANGUAGE plpythonu VOLATILE SECURITY DEFINER;
232 c.execute("""CREATE OR REPLACE FUNCTION update_contents_for_override()
233 RETURNS trigger AS $$
235 if event == "UPDATE" or event == "INSERT":
237 r = plpy.execute(plpy.prepare( \"\"\"SELECT 1 from suite_architectures sa
238 JOIN binaries b ON b.architecture = sa.architecture
239 WHERE b.id = $1 and sa.suite = $2\"\"\",
241 [row["bin"], row["suite"]])
243 plpy.error("Illegal architecture for this suite")
245 $$ LANGUAGE plpythonu VOLATILE;""")
247 c.execute( """CREATE TRIGGER illegal_suite_arch_bin_associations_trigger
248 BEFORE INSERT OR UPDATE ON bin_associations
249 FOR EACH ROW EXECUTE PROCEDURE update_contents_for_override();""")
251 c.execute( """CREATE TRIGGER bin_associations_contents_trigger
252 AFTER INSERT OR UPDATE OR DELETE ON bin_associations
253 FOR EACH ROW EXECUTE PROCEDURE update_contents_for_bin_a();""")
254 c.execute("""CREATE TRIGGER override_contents_trigger
255 AFTER UPDATE ON override
256 FOR EACH ROW EXECUTE PROCEDURE update_contents_for_override();""")
259 c.execute( "CREATE INDEX ind_deb_contents_name ON deb_contents(package);");
260 c.execute( "CREATE INDEX ind_udeb_contents_name ON udeb_contents(package);");
262 c.execute("UPDATE config SET value = '28' WHERE name = 'db_revision'")
266 except psycopg2.ProgrammingError, msg:
268 raise DBUpdateError, "Unable to apply process-new update 28, rollback issued. Error message : %s" % (str(msg))