+++ /dev/null
-#!/usr/bin/python
-###############################################################################
-# #
-# Pakfire - The IPFire package management system #
-# Copyright (C) 2011 Pakfire development team #
-# #
-# 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 3 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, see <http://www.gnu.org/licenses/>. #
-# #
-###############################################################################
-
-import os
-import random
-import shutil
-import sqlite3
-import time
-
-import logging
-log = logging.getLogger("pakfire")
-
-import pakfire.packages as packages
-
-from pakfire.constants import *
-from pakfire.errors import *
-from pakfire.i18n import _
-
-class Database(object):
- def __init__(self, pakfire, filename):
- self.pakfire = pakfire
- self.filename = filename
-
- self._db = None
-
- def __del__(self):
- if self._db:
- self._db.close()
- self._db = None
-
- @property
- def db(self):
- if self._db is None:
- self.open()
-
- return self._db
-
- def create(self):
- pass
-
- def migrate(self):
- pass
-
- def open(self):
- if self._db is None:
- log.debug("Open database %s" % self.filename)
-
- dirname = os.path.dirname(self.filename)
- if not os.path.exists(dirname):
- os.makedirs(dirname)
-
- database_exists = os.path.exists(self.filename)
-
- # Make a connection to the database.
- self._db = sqlite3.connect(self.filename)
- self._db.row_factory = sqlite3.Row
-
- # In the case, the database was not existant, it is
- # filled with content. In case it has been there
- # we call the migrate method to update it if neccessary.
- if database_exists:
- self.migrate()
- else:
- self.create()
-
- def close(self):
- if self._db:
- self._db.close()
- self._db = None
-
- def commit(self):
- if self._db:
- self._db.commit()
-
- def cursor(self):
- self.open()
- return self._db.cursor()
-
- def executescript(self, *args, **kwargs):
- self.open()
- return self._db.executescript(*args, **kwargs)
-
-
-class DatabaseLocal(Database):
- def __init__(self, pakfire, repo):
- self.repo = repo
-
- # Generate filename for package database
- filename = os.path.join(pakfire.path, PACKAGES_DB)
-
- # Cache format number.
- self.__format = None
-
- Database.__init__(self, pakfire, filename)
-
- def initialize(self):
- # Open the database.
- self.open()
-
- # Check if we actually can open the database.
- if not self.format in DATABASE_FORMATS_SUPPORTED:
- raise DatabaseFormatError(_("The format of the database is not supported by this version of pakfire."))
-
- def __len__(self):
- count = 0
-
- c = self.cursor()
- c.execute("SELECT COUNT(*) AS count FROM packages")
- for row in c:
- count = row["count"]
- c.close()
-
- return count
-
- @property
- def format(self):
- if self.__format is None:
- c = self.cursor()
-
- c.execute("SELECT val FROM settings WHERE key = 'version' LIMIT 1")
- for row in c:
- try:
- self.__format = int(row["val"])
- break
- except ValueError:
- pass
-
- c.close()
-
- return self.__format
-
- def create(self):
- c = self.cursor()
- c.executescript("""
- CREATE TABLE settings(
- key TEXT,
- val TEXT
- );
- INSERT INTO settings(key, val) VALUES('version', '%s');
-
- CREATE TABLE files(
- id INTEGER PRIMARY KEY,
- name TEXT,
- pkg INTEGER,
- size INTEGER,
- type INTEGER,
- config INTEGER,
- datafile INTEGER,
- mode INTEGER,
- user TEXT,
- `group` TEXT,
- hash1 TEXT,
- mtime INTEGER,
- capabilities TEXT
- );
- CREATE INDEX files_pkg_index ON files(pkg);
-
- CREATE TABLE packages(
- id INTEGER PRIMARY KEY,
- name TEXT,
- epoch INTEGER,
- version TEXT,
- release TEXT,
- arch TEXT,
- groups TEXT,
- filename TEXT,
- size INTEGER,
- inst_size INTEGER,
- hash1 TEXT,
- license TEXT,
- summary TEXT,
- description TEXT,
- uuid TEXT,
- vendor TEXT,
- build_id TEXT,
- build_host TEXT,
- build_date TEXT,
- build_time INTEGER,
- installed INT,
- reason TEXT,
- repository TEXT
- );
- CREATE INDEX packages_name_index ON packages(name);
-
- CREATE TABLE scriptlets(
- id INTEGER PRIMARY KEY,
- pkg INTEGER,
- action TEXT,
- scriptlet TEXT
- );
- CREATE INDEX scriptlets_pkg_index ON scriptlets(pkg);
-
- CREATE TABLE dependencies(
- pkg INTEGER,
- type TEXT,
- dependency TEXT
- );
- CREATE INDEX dependencies_pkg_index ON dependencies(pkg);
- """ % DATABASE_FORMAT)
- # XXX add some indexes here
- self.commit()
- c.close()
-
- def migrate(self):
- # If we have already the latest version, there is nothing to do.
- if self.format == DATABASE_FORMAT:
- return
-
- # Check if database version is supported.
- if self.format > DATABASE_FORMAT:
- raise DatabaseError(_("Cannot use database with version greater than %s.") % DATABASE_FORMAT)
-
- log.info(_("Migrating database from format %(old)s to %(new)s.") % \
- { "old" : self.format, "new" : DATABASE_FORMAT })
-
- # Get a database cursor.
- c = self.cursor()
-
- # 1) The vendor column was added.
- if self.format < 1:
- c.execute("ALTER TABLE packages ADD COLUMN vendor TEXT AFTER uuid")
-
- if self.format < 2:
- c.execute("ALTER TABLE files ADD COLUMN `config` INTEGER")
- c.execute("ALTER TABLE files ADD COLUMN `mode` INTEGER")
- c.execute("ALTER TABLE files ADD COLUMN `user` TEXT")
- c.execute("ALTER TABLE files ADD COLUMN `group` TEXT")
- c.execute("ALTER TABLE files ADD COLUMN `mtime` INTEGER")
-
- if self.format < 3:
- c.execute("ALTER TABLE files ADD COLUMN `capabilities` TEXT")
-
- if self.format < 4:
- c.execute("ALTER TABLE packages ADD COLUMN recommends TEXT AFTER obsoletes")
- c.execute("ALTER TABLE packages ADD COLUMN suggests TEXT AFTER recommends")
-
- if self.format < 5:
- c.execute("ALTER TABLE files ADD COLUMN datafile INTEGER AFTER config")
-
- if self.format < 6:
- c.execute("ALTER TABLE packages ADD COLUMN inst_size INTEGER AFTER size")
-
- if self.format < 7:
- c.executescript("""
- CREATE TABLE dependencies(pkg INTEGER, type TEXT, dependency TEXT);
- CREATE INDEX dependencies_pkg_index ON dependencies(pkg);
- """)
-
- c.execute("SELECT id, provides, requires, conflicts, obsoletes, recommends, suggests FROM packages")
- pkgs = c.fetchall()
-
- for pkg in pkgs:
- (pkg_id, provides, requires, conflicts, obsoletes, recommends, suggests) = pkg
-
- dependencies = (
- ("provides", provides),
- ("requires", requires),
- ("conflicts", conflicts),
- ("obsoletes", obsoletes),
- ("recommends", recommends),
- ("suggests", suggests),
- )
-
- for type, deps in dependencies:
- c.executemany("INSERT INTO dependencies(pkg, type, dependency) VALUES(?, ?, ?)",
- ((pkg_id, type, d) for d in deps.splitlines()))
-
- c.executescript("""
- CREATE TABLE packages_(
- id INTEGER PRIMARY KEY,
- name TEXT,
- epoch INTEGER,
- version TEXT,
- release TEXT,
- arch TEXT,
- groups TEXT,
- filename TEXT,
- size INTEGER,
- inst_size INTEGER,
- hash1 TEXT,
- license TEXT,
- summary TEXT,
- description TEXT,
- uuid TEXT,
- vendor TEXT,
- build_id TEXT,
- build_host TEXT,
- build_date TEXT,
- build_time INTEGER,
- installed INT,
- reason TEXT,
- repository TEXT
- );
-
- INSERT INTO packages_ SELECT id, name, epoch, version, release, arch, groups, filename,
- size, inst_size, hash1, license, summary, description, uuid, vendor, build_id,
- build_host, build_date, build_time, installed, reason, repository FROM packages;
-
- DROP TABLE packages;
- ALTER TABLE packages_ RENAME TO packages;
-
- DROP TABLE triggers;
-
- CREATE INDEX files_pkg_index ON files(pkg);
- CREATE INDEX scriptlets_pkg_index ON scriptlets(pkg);
- CREATE INDEX packages_name_index ON packages(name);
- """)
-
- # In the end, we can easily update the version of the database.
- c.execute("UPDATE settings SET val = ? WHERE key = 'version'", (DATABASE_FORMAT,))
- self.__format = DATABASE_FORMAT
-
- self.commit()
- c.close()
-
- def add_package(self, pkg, reason=None):
- log.debug("Adding package to database: %s" % pkg.friendly_name)
-
- c = self.cursor()
-
- try:
- c.execute("""
- INSERT INTO packages(
- name,
- epoch,
- version,
- release,
- arch,
- groups,
- filename,
- size,
- inst_size,
- hash1,
- license,
- summary,
- description,
- uuid,
- vendor,
- build_id,
- build_host,
- build_date,
- build_time,
- installed,
- repository,
- reason
- ) VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)""",
- (
- pkg.name,
- pkg.epoch,
- pkg.version,
- pkg.release,
- pkg.arch,
- " ".join(pkg.groups),
- pkg.filename,
- pkg.size,
- pkg.inst_size,
- pkg.hash1,
- pkg.license,
- pkg.summary,
- pkg.description,
- pkg.uuid,
- pkg.vendor or "",
- pkg.build_id,
- pkg.build_host,
- pkg.build_date,
- pkg.build_time,
- time.time(),
- pkg.repo.name,
- reason or "",
- )
- )
-
- pkg_id = c.lastrowid
-
- # Add all dependencies.
- dependencies = (
- ("provides", pkg.provides),
- ("requires", pkg.requires),
- ("conflicts", pkg.conflicts),
- ("obsoletes", pkg.obsoletes),
- ("recommends", pkg.recommends),
- ("suggests", pkg.suggests),
- )
- for type, deps in dependencies:
- c.executemany("INSERT INTO dependencies(pkg, type, dependency) VALUES(?, ?, ?)", ((pkg_id, type, d) for d in deps))
-
- c.executemany("INSERT INTO files(`name`, `pkg`, `size`, `config`, `datafile`, `type`, `hash1`, `mode`, `user`, `group`, `mtime`, `capabilities`)"
- " VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)",
- ((f.name, pkg_id, f.size, f.is_config(), f.is_datafile(), f.type, f.hash1, f.mode, f.user, f.group, f.mtime, f.capabilities or "") for f in pkg.filelist))
-
- # Add scriptlets
- for scriptlet_action in SCRIPTS:
- scriptlet = pkg.get_scriptlet(scriptlet_action)
-
- # If there is no scriptlet, just skip to the next one.
- if not scriptlet:
- continue
-
- c.execute("INSERT INTO scriptlets(pkg, action, scriptlet) VALUES(?, ?, ?)",
- (pkg_id, scriptlet_action, scriptlet))
-
- except:
- raise
-
- else:
- self.commit()
-
- c.close()
-
- def rem_package(self, pkg):
- assert isinstance(pkg, packages.DatabasePackage), pkg
-
- log.debug("Removing package from database: %s" % pkg.friendly_name)
-
- # First, delete all files from the database and then delete the pkg itself.
- c = self.cursor()
- c.execute("DELETE FROM files WHERE pkg = ?", (pkg.id,))
- c.execute("DELETE FROM scriptlets WHERE pkg = ?", (pkg.id,))
- c.execute("DELETE FROM packages WHERE id = ?", (pkg.id,))
- c.close()
-
- self.commit()
-
- def get_package_by_id(self, id):
- c = self.cursor()
- c.execute("SELECT * FROM packages WHERE id = ?", (id,))
-
- try:
- for row in c:
- return packages.DatabasePackage(self.pakfire, self.repo, self, row)
-
- finally:
- c.close()
-
- def get_package_by_uuid(self, uuid):
- c = self.cursor()
- c.execute("SELECT * FROM packages WHERE uuid = ?", (uuid,))
-
- try:
- for row in c:
- return packages.DatabasePackage(self.pakfire, self.repo, self, row)
-
- finally:
- c.close()
-
- @property
- def packages(self):
- c = self.db.execute("SELECT * FROM packages ORDER BY name")
-
- for row in c.fetchall():
- yield packages.DatabasePackage(self.pakfire, self.repo, self, row)
-
- c.close()
-
- def get_filelist(self):
- c = self.db.execute("SELECT name FROM files")
-
- return [r["name"] for r in c.fetchall()]
-
- def get_package_from_solv(self, solv_pkg):
- assert solv_pkg.uuid
-
- c = self.cursor()
- c.execute("SELECT * FROM packages WHERE uuid = ? LIMIT 1", (solv_pkg.uuid,))
-
- try:
- for row in c:
- return packages.DatabasePackage(self.pakfire, self.repo, self, row)
-
- finally:
- c.close()
+++ /dev/null
-#!/usr/bin/python
-###############################################################################
-# #
-# Pakfire - The IPFire package management system #
-# Copyright (C) 2011 Pakfire development team #
-# #
-# 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 3 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, see <http://www.gnu.org/licenses/>. #
-# #
-###############################################################################
-
-import os
-
-from . import base
-from . import database
-
-import pakfire.packages as packages
-import pakfire.util as util
-
-from pakfire.constants import *
-from pakfire.i18n import _
-
-class RepositorySystem(base.RepositoryFactory):
- def __init__(self, pakfire):
- base.RepositoryFactory.__init__(self, pakfire, "@system", "Local repository")
-
- # Open database connection.
- self.db = database.DatabaseLocal(self.pakfire, self)
-
- @property
- def cache_file(self):
- return os.path.join(self.pakfire.path, PACKAGES_SOLV)
-
- @property
- def priority(self):
- """
- The local repository has always a high priority.
- """
- return 10
-
- def open(self):
- # Initialize database.
- self.db.initialize()
-
- # Create a progressbar.
- pb = util.make_progress(_("Loading installed packages"), len(self.db))
-
- i = 0
- for pkg in self.db.packages:
- if pb:
- i += 1
- pb.update(i)
-
- print("Loading %s" % pkg)
- #self.index.add_package(pkg)
-
- if pb:
- pb.finish()
-
- # Mark repo as open.
- self.opened = True
-
- def close(self):
- # Commit all data that is currently pending for writing.
- self.db.commit()
-
- # Close database.
- self.db.close()
-
- # Mark repo as closed.
- self.opened = False
-
- def commit(self):
- # Commit the database to disk.
- self.db.commit()
-
- def add_package(self, pkg):
- # Add package to the database.
- self.db.add_package(pkg)
-
- def rem_package(self, pkg):
- # Remove package from the database.
- self.db.rem_package(pkg)
-
- def get_package_by_uuid(self, uuid):
- return self.db.get_package_by_uuid(uuid)
-
- @property
- def filelist(self):
- return self.db.get_filelist()
projects / pakfire.git / commitdiff
