49
49
current_version = db_version()
50
50
repo_path = _find_migrate_repo()
51
51
if version is None or version > current_version:
52
return versioning_api.upgrade(
53
CONF.sql.connection, repo_path, version)
52
return versioning_api.upgrade(CONF.sql.connection, repo_path, version)
55
54
return versioning_api.downgrade(
56
CONF.sql.connection, repo_path, version)
55
CONF.sql.connection, repo_path, version)
60
59
repo_path = _find_migrate_repo()
62
return versioning_api.db_version(
63
CONF.sql.connection, repo_path)
61
return versioning_api.db_version(CONF.sql.connection, repo_path)
64
62
except versioning_exceptions.DatabaseNotControlledError:
65
63
return db_version_control(0)
68
66
def db_version_control(version=None):
69
67
repo_path = _find_migrate_repo()
70
versioning_api.version_control(
71
CONF.sql.connection, repo_path, version)
68
versioning_api.version_control(CONF.sql.connection, repo_path, version)