Updates so that dbupdate command works

- Various fixes to dbupdate itself
 - Switching db/sql/migrations.py to use a dict instead of a list
 - Registering the function
This commit is contained in:
Christopher Allan Webber
2012-02-18 23:19:09 -06:00
parent 4d8be4fe0d
commit 3ea1cf36fc
9 changed files with 124 additions and 10 deletions

View File

@@ -53,6 +53,10 @@ SUBCOMMAND_MAP = {
'setup': 'mediagoblin.gmg_commands.import_export:import_export_parse_setup',
'func': 'mediagoblin.gmg_commands.import_export:env_import',
'help': 'Exports the data for this MediaGoblin instance'},
'dbupdate': {
'setup': 'mediagoblin.gmg_commands.dbupdate:dbupdate_parse_setup',
'func': 'mediagoblin.gmg_commands.dbupdate:dbupdate',
'help': 'Set up or update the SQL database'},
}

View File

@@ -1,5 +1,5 @@
# GNU MediaGoblin -- federated, autonomous media hosting
# Copyright (C) 2011 MediaGoblin contributors. See AUTHORS.
# Copyright (C) 2011, 2012 MediaGoblin contributors. See AUTHORS.
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
@@ -14,6 +14,8 @@
# You should have received a copy of the GNU Affero General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
from sqlalchemy.orm import sessionmaker
from mediagoblin.db.sql.open import setup_connection_and_db_from_config
from mediagoblin.db.sql.util import (
MigrationManager, assure_migrations_table_setup)
@@ -21,15 +23,19 @@ from mediagoblin.init import setup_global_and_app_config
from mediagoblin.tools.common import import_component
def dbupdate_parse_setup(subparser):
pass
class DatabaseData(object):
def __init__(self, name, models, migrations):
self.name = name
self.models = models
self.migrations = migrations
def make_migration_manager(self, db):
def make_migration_manager(self, session):
return MigrationManager(
self.name, self.models, self.migrations, db)
self.name, self.models, self.migrations, session)
def gather_database_data(media_types):
@@ -74,11 +80,10 @@ def dbupdate(args):
# Set up the database
connection, db = setup_connection_and_db_from_config(app_config)
# If migrations table not made, make it!
assure_migrations_table_setup(db)
Session = sessionmaker(bind=db.engine)
# Setup media managers for all dbdata, run init/migrate and print info
# For each component, create/migrate tables
for dbdata in dbdatas:
migration_manager = dbdata.make_migration_manager(db)
migration_manager = dbdata.make_migration_manager(Session())
migration_manager.init_or_migrate()