]> git.decadent.org.uk Git - dak.git/blob - dak/dakdb/update25.py
Add location_id to return value of str(somelocation).
[dak.git] / dak / dakdb / update25.py
1 #!/usr/bin/env python
2
3 """
4 Add views for new dominate command.
5
6 @contact: Debian FTP Master <ftpmaster@debian.org>
7 @copyright: 2009  Torsten Werner <twerner@debian.org>
8 @license: GNU General Public License version 2 or later
9 """
10
11 # This program is free software; you can redistribute it and/or modify
12 # it under the terms of the GNU General Public License as published by
13 # the Free Software Foundation; either version 2 of the License, or
14 # (at your option) any later version.
15
16 # This program is distributed in the hope that it will be useful,
17 # but WITHOUT ANY WARRANTY; without even the implied warranty of
18 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
19 # GNU General Public License for more details.
20
21 # You should have received a copy of the GNU General Public License
22 # along with this program; if not, write to the Free Software
23 # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
24
25 import psycopg2
26
27 def do_update(self):
28     print "Add views for generate_filelist to database."
29
30     try:
31         c = self.db.cursor()
32
33         print "Drop old views."
34         c.execute("DROP VIEW IF EXISTS binaries_suite_arch CASCADE")
35         c.execute("DROP VIEW IF EXISTS newest_all_associations CASCADE")
36         c.execute("DROP VIEW IF EXISTS obsolete_any_by_all_associations CASCADE")
37         c.execute("DROP VIEW IF EXISTS newest_any_associations CASCADE")
38         c.execute("DROP VIEW IF EXISTS obsolete_any_associations CASCADE")
39         c.execute("DROP VIEW IF EXISTS source_suite CASCADE")
40         c.execute("DROP VIEW IF EXISTS newest_source CASCADE")
41         c.execute("DROP VIEW IF EXISTS newest_src_association CASCADE")
42         c.execute("DROP VIEW IF EXISTS any_associations_source CASCADE")
43         c.execute("DROP VIEW IF EXISTS src_associations_src CASCADE")
44         c.execute("DROP VIEW IF EXISTS almost_obsolete_src_associations CASCADE")
45         c.execute("DROP VIEW IF EXISTS obsolete_src_associations CASCADE")
46         c.execute("DROP VIEW IF EXISTS bin_associations_binaries CASCADE")
47         c.execute("DROP VIEW IF EXISTS src_associations_bin CASCADE")
48         c.execute("DROP VIEW IF EXISTS almost_obsolete_all_associations CASCADE")
49         c.execute("DROP VIEW IF EXISTS obsolete_all_associations CASCADE")
50
51         print "Create new views."
52         c.execute("""
53 CREATE VIEW binaries_suite_arch AS
54     SELECT bin_associations.id, binaries.id AS bin, binaries.package,
55            binaries.version, binaries.source, bin_associations.suite,
56            suite.suite_name, binaries.architecture, architecture.arch_string
57         FROM binaries JOIN bin_associations ON binaries.id = bin_associations.bin
58         JOIN suite ON suite.id = bin_associations.suite
59         JOIN architecture ON binaries.architecture = architecture.id;
60             """)
61         c.execute("""
62 CREATE VIEW newest_all_associations AS
63     SELECT package, max(version) AS version, suite, architecture
64         FROM binaries_suite_arch
65         WHERE architecture = 2 GROUP BY package, suite, architecture;
66             """)
67         c.execute("""
68 CREATE VIEW obsolete_any_by_all_associations AS
69     SELECT binaries_suite_arch.id, binaries_suite_arch.package,
70            binaries_suite_arch.version, binaries_suite_arch.suite,
71            binaries_suite_arch.architecture
72         FROM binaries_suite_arch
73         JOIN newest_all_associations
74             ON (binaries_suite_arch.package = newest_all_associations.package AND
75                 binaries_suite_arch.version < newest_all_associations.version AND
76                 binaries_suite_arch.suite = newest_all_associations.suite AND
77                 binaries_suite_arch.architecture > 2);
78             """)
79         c.execute("""
80 CREATE VIEW newest_any_associations AS
81     SELECT package, max(version) AS version, suite, architecture
82         FROM binaries_suite_arch
83         WHERE architecture > 2 GROUP BY package, suite, architecture;
84             """)
85         c.execute("""
86 CREATE VIEW obsolete_any_associations AS
87     SELECT id, binaries_suite_arch.architecture, binaries_suite_arch.version,
88            binaries_suite_arch.package, binaries_suite_arch.suite
89         FROM binaries_suite_arch
90         JOIN newest_any_associations
91             ON binaries_suite_arch.architecture = newest_any_associations.architecture AND
92                binaries_suite_arch.package = newest_any_associations.package AND
93                binaries_suite_arch.suite = newest_any_associations.suite AND
94                binaries_suite_arch.version != newest_any_associations.version;
95             """)
96         c.execute("""
97 CREATE VIEW source_suite AS
98     SELECT src_associations.id, source.id AS src , source.source, source.version,
99            src_associations.suite, suite.suite_name
100         FROM source
101         JOIN src_associations ON source.id = src_associations.source
102         JOIN suite ON suite.id = src_associations.suite;
103             """)
104         c.execute("""
105 CREATE VIEW newest_source AS
106     SELECT source, max(version) AS version, suite
107         FROM source_suite
108         GROUP BY source, suite;
109             """)
110         c.execute("""
111 CREATE VIEW newest_src_association AS
112     SELECT id, src, source, version, suite
113         FROM source_suite
114         JOIN newest_source USING (source, version, suite);
115             """)
116         c.execute("""
117 CREATE VIEW any_associations_source AS
118     SELECT bin_associations.id, bin_associations.suite, binaries.id AS bin,
119            binaries.package, binaries.version AS binver, binaries.architecture,
120            source.id AS src, source.source, source.version AS srcver
121         FROM bin_associations
122         JOIN binaries ON bin_associations.bin = binaries.id AND architecture != 2
123         JOIN source ON binaries.source = source.id;
124             """)
125         c.execute("""
126 CREATE VIEW src_associations_src AS
127     SELECT src_associations.id, src_associations.suite, source.id AS src,
128            source.source, source.version
129         FROM src_associations
130         JOIN source ON src_associations.source = source.id;
131             """)
132         c.execute("""
133 CREATE VIEW almost_obsolete_src_associations AS
134     SELECT src_associations_src.id, src_associations_src.src,
135            src_associations_src.source, src_associations_src.version, suite
136         FROM src_associations_src
137         LEFT JOIN any_associations_source USING (src, suite)
138         WHERE bin IS NULL;
139             """)
140         c.execute("""
141 CREATE VIEW obsolete_src_associations AS
142     SELECT almost.id, almost.src, almost.source, almost.version, almost.suite
143         FROM almost_obsolete_src_associations as almost
144     JOIN newest_src_association AS newest
145         ON almost.source  = newest.source AND
146            almost.version < newest.version AND
147            almost.suite   = newest.suite;
148             """)
149         c.execute("""
150 CREATE VIEW bin_associations_binaries AS
151     SELECT bin_associations.id, bin_associations.bin, binaries.package,
152            binaries.version, bin_associations.suite, binaries.architecture
153         FROM bin_associations
154         JOIN binaries ON bin_associations.bin = binaries.id;
155             """)
156         c.execute("""
157 CREATE VIEW src_associations_bin AS
158     SELECT src_associations.id, src_associations.source, src_associations.suite,
159            binaries.id AS bin, binaries.architecture
160         FROM src_associations
161         JOIN source ON src_associations.source = source.id
162         JOIN binaries ON source.id = binaries.source;
163             """)
164         c.execute("""
165 CREATE VIEW almost_obsolete_all_associations AS
166     SELECT bin_associations_binaries.id AS id, bin, bin_associations_binaries.package,
167            bin_associations_binaries.version, suite
168         FROM bin_associations_binaries
169         LEFT JOIN src_associations_bin USING (bin, suite, architecture)
170         WHERE source IS NULL AND architecture = 2;
171             """)
172         c.execute("""
173 CREATE VIEW obsolete_all_associations AS
174     SELECT almost.id, almost.bin, almost.package, almost.version, almost.suite
175         FROM almost_obsolete_all_associations AS almost
176         JOIN newest_all_associations AS newest
177             ON almost.package = newest.package AND
178                almost.version < newest.version AND
179                almost.suite   = newest.suite;
180             """)
181
182         print "Committing"
183         c.execute("UPDATE config SET value = '25' WHERE name = 'db_revision'")
184         self.db.commit()
185
186     except psycopg2.InternalError, msg:
187         self.db.rollback()
188         raise DBUpdateError, "Database error, rollback issued. Error message : %s" % (str(msg))
189