# Copyright 2010 United States Government as represented by the
# Administrator of the National Aeronautics and Space Administration.
# All Rights Reserved.
#
#    Licensed under the Apache License, Version 2.0 (the "License"); you may
#    not use this file except in compliance with the License. You may obtain
#    a copy of the License at
#
#         http://www.apache.org/licenses/LICENSE-2.0
#
#    Unless required by applicable law or agreed to in writing, software
#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
#    License for the specific language governing permissions and limitations
#    under the License.


import os

from migrate import exceptions as versioning_exceptions
from migrate.versioning import api as versioning_api
from migrate.versioning.repository import Repository
import sqlalchemy

from cinder.db.sqlalchemy.api import get_engine
from cinder import exception

INIT_VERSION = 000
_REPOSITORY = None


def db_sync(version=None):
    if version is not None:
        try:
            version = int(version)
        except ValueError:
            raise exception.Error(_("version should be an integer"))

    current_version = db_version()
    repository = _find_migrate_repo()
    if version is None or version > current_version:
        return versioning_api.upgrade(get_engine(), repository, version)
    else:
        return versioning_api.downgrade(get_engine(), repository,
                                        version)


def db_version():
    repository = _find_migrate_repo()
    try:
        return versioning_api.db_version(get_engine(), repository)
    except versioning_exceptions.DatabaseNotControlledError:
        # If we aren't version controlled we may already have the database
        # in the state from before we started version control, check for that
        # and set up version_control appropriately
        meta = sqlalchemy.MetaData()
        engine = get_engine()
        meta.reflect(bind=engine)
        tables = meta.tables
        if len(tables) == 0:
            db_version_control(INIT_VERSION)
            return versioning_api.db_version(get_engine(), repository)
        else:
            raise exception.Error(_("Upgrade DB using Essex release first."))


def db_initial_version():
    return INIT_VERSION


def db_version_control(version=None):
    repository = _find_migrate_repo()
    versioning_api.version_control(get_engine(), repository, version)
    return version


def _find_migrate_repo():
    """Get the path for the migrate repository."""
    global _REPOSITORY
    path = os.path.join(os.path.abspath(os.path.dirname(__file__)),
                        'migrate_repo')
    assert os.path.exists(path)
    if _REPOSITORY is None:
        _REPOSITORY = Repository(path)
    return _REPOSITORY

@@ -1036,16 +1036,610 @@
  None%0A%0A%0A
+def _ensure_reservations_index(migrate_engine):%0A    meta = sqlalchemy.MetaData()%0A    meta.bind = migrate_engine%0A%0A    reservations = sqlalchemy.Table('reservations', meta, autoload=True)%0A    members = sorted(%5B'deleted', 'expire'%5D)%0A    for idx in reservations.indexes:%0A        if sorted(idx.columns.keys()) == members:%0A            return%0A%0A    # Based on expire_reservations query%0A    # from: cinder/db/sqlalchemy/api.py%0A    index = sqlalchemy.Index('reservations_deleted_expire_idx',%0A                             reservations.c.deleted, reservations.c.expire)%0A%0A    index.create(migrate_engine)%0A%0A%0A
 def db_s
@@ -1899,24 +1899,58 @@
 rate_repo()%0A
+    migrate_engine = get_engine()%0A
     if versi
@@ -1992,36 +1992,38 @@
 sion:%0A        re
-turn
+sult =
  versioning_api.
@@ -2026,36 +2026,38 @@
 api.upgrade(
-get
+migrate
 _engine
-()
 , repository
@@ -2079,36 +2079,38 @@
 else:%0A        re
-turn
+sult =
  versioning_api.
@@ -2119,28 +2119,30 @@
 wngrade(
-get
+migrate
 _engine
-()
 , reposi
@@ -2183,24 +2183,26 @@
             
+  
 version)%0A%0A%0Ad
@@ -2198,16 +2198,81 @@
 ersion)%0A
+    _ensure_reservations_index(migrate_engine)%0A    return result%0A
 %0A%0Adef db

Add fix for reservation index to icehouse