--- /dev/null
+#!/usr/bin/env python
+# coding=utf8
+
+"""
+Add column to store compression type of indices
+
+@contact: Debian FTP Master <ftpmaster@debian.org>
+@copyright: 2012, Ansgar Burchardt <ansgar@debian.org>
+@license: GNU General Public License version 2 or later
+"""
+
+# 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
+
+################################################################################
+
+import psycopg2
+from daklib.dak_exceptions import DBUpdateError
+from daklib.config import Config
+
+################################################################################
+def do_update(self):
+ """
+ Add column to store compression type of indices
+ """
+ print __doc__
+ try:
+ c = self.db.cursor()
+
+ c.execute("""
+ ALTER TABLE suite
+ ADD COLUMN indices_compression TEXT[] DEFAULT ARRAY['gzip', 'bzip2'],
+ ADD COLUMN i18n_compression TEXT[] DEFAULT ARRAY['bzip2']
+ """)
+
+ c.execute("""
+ ALTER TABLE suite
+ ALTER COLUMN indices_compression DROP DEFAULT,
+ ALTER COLUMN i18n_compression DROP DEFAULT
+ """)
+
+ c.execute("UPDATE config SET value = '101' WHERE name = 'db_revision'")
+ self.db.commit()
+
+ except psycopg2.ProgrammingError as msg:
+ self.db.rollback()
+ raise DBUpdateError('Unable to apply sick update 101, rollback issued. Error message : %s' % (str(msg)))
overridesuite_id = suite.get_overridesuite().suite_id
- writer = SourcesFileWriter(archive=suite.archive.path, suite=suite.suite_name, component=component.component_name)
+ writer_args = {
+ 'archive': suite.archive.path,
+ 'suite': suite.suite_name,
+ 'component': component.component_name
+ }
+ if suite.indices_compression is not None:
+ writer_args['compression'] = suite.indices_compression
+ writer = SourcesFileWriter(**writer_args)
output = writer.open()
# run query and write Sources
if include_long_description:
metadata_skip.append("Description-md5")
- writer = PackagesFileWriter(archive=suite.archive.path, suite=suite.suite_name,
- component=component.component_name,
- architecture=architecture.arch_string, debtype=type_name)
+ writer_args = {
+ 'archive': suite.archive.path,
+ 'suite': suite.suite_name,
+ 'component': component.component_name,
+ 'architecture': architecture.arch_string,
+ 'debtype': type_name
+ }
+ if suite.indices_compression is not None:
+ writer_args['compression'] = suite.indices_compression
+ writer = PackagesFileWriter(**writer_args)
output = writer.open()
r = session.execute(_packages_query, {"archive_id": suite.archive.archive_id,
suite = session.query(Suite).get(suite_id)
component = session.query(Component).get(component_id)
- writer = TranslationFileWriter(archive=suite.archive.path, suite=suite.suite_name, component=component.component_name, language="en")
+ writer_args = {
+ 'archive': suite.archive.path,
+ 'suite': suite.suite_name,
+ 'component': component.component_name,
+ 'language': 'en',
+ }
+ if suite.i18n_compression is not None:
+ writer_args['compression'] = suite.i18n_compression
+ writer = TranslationFileWriter(**writer_args)
output = writer.open()
r = session.execute(_translations_query, {"suite": suite_id, "component": component_id})
self.uncompressed = 'none' in compression
self.gzip = 'gzip' in compression
self.bzip2 = 'bzip2' in compression
+ self.xz = 'xz' in compression
self.path = template % keywords
def open(self):
if self.bzip2:
check_call('bzip2 -9 <%s.new >%s.bz2.new' % (self.path, self.path), shell = True)
self.rename('%s.bz2' % self.path)
+ if self.xz:
+ check_call('xz -c <{0}.new >{0}.xz.new'.format(self.path), shell=True)
+ self.rename('{0}.xz'.format(self.path))
if self.uncompressed:
self.rename(self.path)
else: