Remove unrequired migrate check in test
Remove all migrate check in test for migrate version before 72, since those are now default setting. We don't need to check them anymore. Change-Id: Ie5328366ccdbcc4b869383450a060ea1f1c6f37b
This commit is contained in:
ricolin
David Peacock
parent
28ce9f3ad4
commit
7afeb79962
|
|
@ -20,20 +20,15 @@ properly both upgrading and downgrading, and that no data loss occurs
|
|||
if possible.
|
||||
"""
|
||||
|
||||
import datetime
|
||||
import fixtures
|
||||
import os
|
||||
import uuid
|
||||
|
||||
from migrate.versioning import repository
|
||||
from oslo_db.sqlalchemy import enginefacade
|
||||
from oslo_db.sqlalchemy import test_fixtures
|
||||
from oslo_db.sqlalchemy import test_migrations
|
||||
from oslo_db.sqlalchemy import utils
|
||||
from oslo_serialization import jsonutils
|
||||
from oslo_utils import timeutils
|
||||
from oslotest import base as test_base
|
||||
import six
|
||||
import sqlalchemy
|
||||
import testtools
|
||||
|
||||
|
|
@ -183,523 +178,6 @@ class HeatMigrationsCheckers(test_migrations.WalkVersionsMixin,
|
|||
|
||||
self.assertEqual(sorted(members), sorted(index_columns))
|
||||
|
||||
def _pre_upgrade_031(self, engine):
|
||||
raw_template = utils.get_table(engine, 'raw_template')
|
||||
templ = []
|
||||
for i in range(300, 303, 1):
|
||||
t = dict(id=i, template='{}', files='{}')
|
||||
engine.execute(raw_template.insert(), [t])
|
||||
templ.append(t)
|
||||
|
||||
user_creds = utils.get_table(engine, 'user_creds')
|
||||
user = [dict(id=4, username='angus', password='notthis',
|
||||
tenant='mine', auth_url='bla',
|
||||
tenant_id=str(uuid.uuid4()),
|
||||
trust_id='',
|
||||
trustor_user_id='')]
|
||||
engine.execute(user_creds.insert(), user)
|
||||
|
||||
stack = utils.get_table(engine, 'stack')
|
||||
stack_ids = [('967aaefb-152e-405d-b13a-35d4c816390c', 0),
|
||||
('9e9deba9-a303-4f29-84d3-c8165647c47e', 1),
|
||||
('9a4bd1ec-8b21-46cd-964a-f66cb1cfa2f9', 2)]
|
||||
data = [dict(id=ll_id, name='fruity',
|
||||
raw_template_id=templ[templ_id]['id'],
|
||||
user_creds_id=user[0]['id'],
|
||||
username='angus', disable_rollback=True)
|
||||
for ll_id, templ_id in stack_ids]
|
||||
|
||||
engine.execute(stack.insert(), data)
|
||||
return data
|
||||
|
||||
def _check_031(self, engine, data):
|
||||
self.assertColumnExists(engine, 'stack_lock', 'stack_id')
|
||||
self.assertColumnExists(engine, 'stack_lock', 'engine_id')
|
||||
self.assertColumnExists(engine, 'stack_lock', 'created_at')
|
||||
self.assertColumnExists(engine, 'stack_lock', 'updated_at')
|
||||
|
||||
def _check_034(self, engine, data):
|
||||
self.assertColumnExists(engine, 'raw_template', 'files')
|
||||
|
||||
def _pre_upgrade_035(self, engine):
|
||||
# The stacks id are for the 33 version migration
|
||||
event_table = utils.get_table(engine, 'event')
|
||||
data = [{
|
||||
'id': '22222222-152e-405d-b13a-35d4c816390c',
|
||||
'stack_id': '967aaefb-152e-405d-b13a-35d4c816390c',
|
||||
'resource_action': 'Test',
|
||||
'resource_status': 'TEST IN PROGRESS',
|
||||
'resource_name': 'Testing Resource',
|
||||
'physical_resource_id': '3465d1ec-8b21-46cd-9dgf-f66cttrh53f9',
|
||||
'resource_status_reason': '',
|
||||
'resource_type': '',
|
||||
'resource_properties': None,
|
||||
'created_at': timeutils.utcnow()},
|
||||
{'id': '11111111-152e-405d-b13a-35d4c816390c',
|
||||
'stack_id': '967aaefb-152e-405d-b13a-35d4c816390c',
|
||||
'resource_action': 'Test',
|
||||
'resource_status': 'TEST COMPLETE',
|
||||
'resource_name': 'Testing Resource',
|
||||
'physical_resource_id': '3465d1ec-8b21-46cd-9dgf-f66cttrh53f9',
|
||||
'resource_status_reason': '',
|
||||
'resource_type': '',
|
||||
'resource_properties': None,
|
||||
'created_at': timeutils.utcnow() +
|
||||
datetime.timedelta(days=5)}]
|
||||
engine.execute(event_table.insert(), data)
|
||||
return data
|
||||
|
||||
def _check_035(self, engine, data):
|
||||
self.assertColumnExists(engine, 'event', 'id')
|
||||
self.assertColumnExists(engine, 'event', 'uuid')
|
||||
|
||||
event_table = utils.get_table(engine, 'event')
|
||||
events_in_db = list(event_table.select().execute())
|
||||
last_id = 0
|
||||
for index, event in enumerate(data):
|
||||
last_id = index + 1
|
||||
self.assertEqual(last_id, events_in_db[index].id)
|
||||
self.assertEqual(event['id'], events_in_db[index].uuid)
|
||||
|
||||
# Check that the autoincremental id is ok
|
||||
data = [{
|
||||
'uuid': '33333333-152e-405d-b13a-35d4c816390c',
|
||||
'stack_id': '967aaefb-152e-405d-b13a-35d4c816390c',
|
||||
'resource_action': 'Test',
|
||||
'resource_status': 'TEST COMPLEATE AGAIN',
|
||||
'resource_name': 'Testing Resource',
|
||||
'physical_resource_id': '3465d1ec-8b21-46cd-9dgf-f66cttrh53f9',
|
||||
'resource_status_reason': '',
|
||||
'resource_type': '',
|
||||
'resource_properties': None,
|
||||
'created_at': timeutils.utcnow()}]
|
||||
result = engine.execute(event_table.insert(), data)
|
||||
self.assertEqual(last_id + 1, result.inserted_primary_key[0])
|
||||
|
||||
def _check_036(self, engine, data):
|
||||
self.assertColumnExists(engine, 'stack', 'stack_user_project_id')
|
||||
|
||||
def _pre_upgrade_037(self, engine):
|
||||
raw_template = utils.get_table(engine, 'raw_template')
|
||||
templ = '''{"heat_template_version": "2013-05-23",
|
||||
"parameters": {
|
||||
"key_name": {
|
||||
"Type": "string"
|
||||
}
|
||||
}
|
||||
}'''
|
||||
data = [dict(id=4, template=templ, files='{}')]
|
||||
engine.execute(raw_template.insert(), data)
|
||||
return data[0]
|
||||
|
||||
def _check_037(self, engine, data):
|
||||
raw_template = utils.get_table(engine, 'raw_template')
|
||||
templs = list(raw_template.select().
|
||||
where(raw_template.c.id == str(data['id'])).
|
||||
execute())
|
||||
template = jsonutils.loads(templs[0].template)
|
||||
data_template = jsonutils.loads(data['template'])
|
||||
self.assertNotIn('Type', template['parameters']['key_name'])
|
||||
self.assertIn('type', template['parameters']['key_name'])
|
||||
self.assertEqual(template['parameters']['key_name']['type'],
|
||||
data_template['parameters']['key_name']['Type'])
|
||||
|
||||
def _check_038(self, engine, data):
|
||||
self.assertColumnNotExists(engine, 'software_config', 'io')
|
||||
|
||||
def _check_039(self, engine, data):
|
||||
self.assertColumnIsNullable(engine, 'stack', 'user_creds_id')
|
||||
|
||||
def _check_040(self, engine, data):
|
||||
self.assertColumnNotExists(engine, 'software_deployment', 'signal_id')
|
||||
|
||||
def _pre_upgrade_041(self, engine):
|
||||
raw_template = utils.get_table(engine, 'raw_template')
|
||||
templ = '''{"heat_template_version": "2013-05-23",
|
||||
"resources": {
|
||||
"my_instance": {
|
||||
"Type": "OS::Nova::Server"
|
||||
}
|
||||
},
|
||||
"outputs": {
|
||||
"instance_ip": {
|
||||
"Value": { "get_attr": "[my_instance, networks]" }
|
||||
}
|
||||
}
|
||||
}'''
|
||||
data = [dict(id=7, template=templ, files='{}')]
|
||||
engine.execute(raw_template.insert(), data)
|
||||
return data[0]
|
||||
|
||||
def _check_041(self, engine, data):
|
||||
raw_template = utils.get_table(engine, 'raw_template')
|
||||
templs = list(raw_template.select().
|
||||
where(raw_template.c.id == str(data['id'])).
|
||||
execute())
|
||||
template = jsonutils.loads(templs[0].template)
|
||||
self.assertIn('type', template['resources']['my_instance'])
|
||||
self.assertNotIn('Type', template['resources']['my_instance'])
|
||||
self.assertIn('value', template['outputs']['instance_ip'])
|
||||
self.assertNotIn('Value', template['outputs']['instance_ip'])
|
||||
|
||||
def _pre_upgrade_043(self, engine):
|
||||
raw_template = utils.get_table(engine, 'raw_template')
|
||||
templ = '''{"HeatTemplateFormatVersion" : "2012-12-11",
|
||||
"Parameters" : {
|
||||
"foo" : { "Type" : "String", "NoEcho": "True" },
|
||||
"bar" : { "Type" : "String", "NoEcho": "True", "Default": "abc" },
|
||||
"blarg" : { "Type" : "String", "Default": "quux" }
|
||||
}
|
||||
}'''
|
||||
data = [dict(id=8, template=templ, files='{}')]
|
||||
engine.execute(raw_template.insert(), data)
|
||||
return data[0]
|
||||
|
||||
def _check_043(self, engine, data):
|
||||
raw_template = utils.get_table(engine, 'raw_template')
|
||||
templ = list(raw_template.select().
|
||||
where(raw_template.c.id == data['id']).execute())
|
||||
template = jsonutils.loads(templ[0].template)
|
||||
self.assertEqual(template['HeatTemplateFormatVersion'], '2012-12-12')
|
||||
|
||||
def _pre_upgrade_045(self, engine):
|
||||
raw_template = utils.get_table(engine, 'raw_template')
|
||||
templ = []
|
||||
for i in range(200, 203, 1):
|
||||
t = dict(id=i, template='{}', files='{}')
|
||||
engine.execute(raw_template.insert(), [t])
|
||||
templ.append(t)
|
||||
|
||||
user_creds = utils.get_table(engine, 'user_creds')
|
||||
user = [dict(id=6, username='steve', password='notthis',
|
||||
tenant='mine', auth_url='bla',
|
||||
tenant_id=str(uuid.uuid4()),
|
||||
trust_id='',
|
||||
trustor_user_id='')]
|
||||
engine.execute(user_creds.insert(), user)
|
||||
|
||||
stack = utils.get_table(engine, 'stack')
|
||||
stack_ids = [('s1', '967aaefb-152e-505d-b13a-35d4c816390c', 0),
|
||||
('s2', '9e9deba9-a303-5f29-84d3-c8165647c47e', 1),
|
||||
('s1*', '9a4bd1ec-8b21-56cd-964a-f66cb1cfa2f9', 2)]
|
||||
data = [dict(id=ll_id, name=name,
|
||||
raw_template_id=templ[templ_id]['id'],
|
||||
user_creds_id=user[0]['id'],
|
||||
username='steve', disable_rollback=True)
|
||||
for name, ll_id, templ_id in stack_ids]
|
||||
data[2]['owner_id'] = '967aaefb-152e-505d-b13a-35d4c816390c'
|
||||
|
||||
engine.execute(stack.insert(), data)
|
||||
return data
|
||||
|
||||
def _check_045(self, engine, data):
|
||||
self.assertColumnExists(engine, 'stack', 'backup')
|
||||
stack_table = utils.get_table(engine, 'stack')
|
||||
stacks_in_db = list(stack_table.select().execute())
|
||||
stack_names_in_db = [s.name for s in stacks_in_db]
|
||||
# Assert the expected stacks are still there
|
||||
for stack in data:
|
||||
self.assertIn(stack['name'], stack_names_in_db)
|
||||
# And that the backup flag is set as expected
|
||||
for stack in stacks_in_db:
|
||||
if stack.name.endswith('*'):
|
||||
self.assertTrue(stack.backup)
|
||||
else:
|
||||
self.assertFalse(stack.backup)
|
||||
|
||||
def _check_046(self, engine, data):
|
||||
self.assertColumnExists(engine, 'resource', 'properties_data')
|
||||
|
||||
def _pre_upgrade_047(self, engine):
|
||||
raw_template = utils.get_table(engine, 'raw_template')
|
||||
templ = []
|
||||
for i in range(100, 105, 1):
|
||||
t = dict(id=i, template='{}', files='{}')
|
||||
engine.execute(raw_template.insert(), [t])
|
||||
templ.append(t)
|
||||
|
||||
user_creds = utils.get_table(engine, 'user_creds')
|
||||
user = [dict(id=7, username='steve', password='notthis',
|
||||
tenant='mine', auth_url='bla',
|
||||
tenant_id=str(uuid.uuid4()),
|
||||
trust_id='',
|
||||
trustor_user_id='')]
|
||||
engine.execute(user_creds.insert(), user)
|
||||
|
||||
stack = utils.get_table(engine, 'stack')
|
||||
stack_ids = [
|
||||
('s9', '167aaefb-152e-505d-b13a-35d4c816390c', 0),
|
||||
('n1', '1e9deba9-a303-5f29-84d3-c8165647c47e', 1),
|
||||
('n2', '1e9deba9-a304-5f29-84d3-c8165647c47e', 2),
|
||||
('n3', '1e9deba9-a305-5f29-84d3-c8165647c47e', 3),
|
||||
('s9*', '1a4bd1ec-8b21-56cd-964a-f66cb1cfa2f9', 4)]
|
||||
data = [dict(id=ll_id, name=name,
|
||||
raw_template_id=templ[tmpl_id]['id'],
|
||||
user_creds_id=user[0]['id'],
|
||||
owner_id=None,
|
||||
backup=False,
|
||||
username='steve', disable_rollback=True)
|
||||
for name, ll_id, tmpl_id in stack_ids]
|
||||
# Make a nested tree s1->s2->s3->s4 with a s1 backup
|
||||
data[1]['owner_id'] = '167aaefb-152e-505d-b13a-35d4c816390c'
|
||||
data[2]['owner_id'] = '1e9deba9-a303-5f29-84d3-c8165647c47e'
|
||||
data[3]['owner_id'] = '1e9deba9-a304-5f29-84d3-c8165647c47e'
|
||||
data[4]['owner_id'] = '167aaefb-152e-505d-b13a-35d4c816390c'
|
||||
data[4]['backup'] = True
|
||||
engine.execute(stack.insert(), data)
|
||||
return data
|
||||
|
||||
def _check_047(self, engine, data):
|
||||
self.assertColumnExists(engine, 'stack', 'nested_depth')
|
||||
stack_table = utils.get_table(engine, 'stack')
|
||||
stacks_in_db = list(stack_table.select().execute())
|
||||
stack_ids_in_db = [s.id for s in stacks_in_db]
|
||||
|
||||
# Assert the expected stacks are still there
|
||||
for stack in data:
|
||||
self.assertIn(stack['id'], stack_ids_in_db)
|
||||
|
||||
# And that the depth is set as expected
|
||||
def n_depth(sid):
|
||||
s = [s for s in stacks_in_db if s.id == sid][0]
|
||||
return s.nested_depth
|
||||
|
||||
self.assertEqual(0, n_depth('167aaefb-152e-505d-b13a-35d4c816390c'))
|
||||
self.assertEqual(1, n_depth('1e9deba9-a303-5f29-84d3-c8165647c47e'))
|
||||
self.assertEqual(2, n_depth('1e9deba9-a304-5f29-84d3-c8165647c47e'))
|
||||
self.assertEqual(3, n_depth('1e9deba9-a305-5f29-84d3-c8165647c47e'))
|
||||
self.assertEqual(0, n_depth('1a4bd1ec-8b21-56cd-964a-f66cb1cfa2f9'))
|
||||
|
||||
def _check_049(self, engine, data):
|
||||
self.assertColumnExists(engine, 'user_creds', 'region_name')
|
||||
|
||||
def _check_051(self, engine, data):
|
||||
column_list = [('id', False),
|
||||
('host', False),
|
||||
('topic', False),
|
||||
('binary', False),
|
||||
('hostname', False),
|
||||
('engine_id', False),
|
||||
('report_interval', False),
|
||||
('updated_at', True),
|
||||
('created_at', True),
|
||||
('deleted_at', True)]
|
||||
for column in column_list:
|
||||
self.assertColumnExists(engine, 'service', column[0])
|
||||
if not column[1]:
|
||||
self.assertColumnIsNotNullable(engine, 'service', column[0])
|
||||
else:
|
||||
self.assertColumnIsNullable(engine, 'service', column[0])
|
||||
|
||||
def _check_052(self, engine, data):
|
||||
self.assertColumnExists(engine, 'stack', 'convergence')
|
||||
|
||||
def _check_055(self, engine, data):
|
||||
self.assertColumnExists(engine, 'stack', 'prev_raw_template_id')
|
||||
self.assertColumnExists(engine, 'stack', 'current_traversal')
|
||||
self.assertColumnExists(engine, 'stack', 'current_deps')
|
||||
|
||||
def _pre_upgrade_056(self, engine):
|
||||
raw_template = utils.get_table(engine, 'raw_template')
|
||||
templ = []
|
||||
for i in range(900, 903, 1):
|
||||
t = dict(id=i, template='{}', files='{}')
|
||||
engine.execute(raw_template.insert(), [t])
|
||||
templ.append(t)
|
||||
|
||||
user_creds = utils.get_table(engine, 'user_creds')
|
||||
user = [dict(id=uid, username='test_user', password='password',
|
||||
tenant='test_project', auth_url='bla',
|
||||
tenant_id=str(uuid.uuid4()),
|
||||
trust_id='',
|
||||
trustor_user_id='') for uid in range(900, 903)]
|
||||
engine.execute(user_creds.insert(), user)
|
||||
|
||||
stack = utils.get_table(engine, 'stack')
|
||||
stack_ids = [('967aaefa-152e-405d-b13a-35d4c816390c', 0),
|
||||
('9e9debab-a303-4f29-84d3-c8165647c47e', 1),
|
||||
('9a4bd1e9-8b21-46cd-964a-f66cb1cfa2f9', 2)]
|
||||
data = [dict(id=ll_id, name=ll_id,
|
||||
raw_template_id=templ[templ_id]['id'],
|
||||
user_creds_id=user[templ_id]['id'],
|
||||
username='test_user',
|
||||
disable_rollback=True,
|
||||
parameters='test_params',
|
||||
created_at=timeutils.utcnow(),
|
||||
deleted_at=None)
|
||||
for ll_id, templ_id in stack_ids]
|
||||
data[-1]['deleted_at'] = timeutils.utcnow()
|
||||
|
||||
engine.execute(stack.insert(), data)
|
||||
return data
|
||||
|
||||
def _check_056(self, engine, data):
|
||||
self.assertColumnNotExists(engine, 'stack', 'parameters')
|
||||
|
||||
self.assertColumnExists(engine, 'raw_template', 'environment')
|
||||
self.assertColumnExists(engine, 'raw_template', 'predecessor')
|
||||
|
||||
# Get the parameters in stack table
|
||||
stack_parameters = {}
|
||||
for stack in data:
|
||||
templ_id = stack['raw_template_id']
|
||||
stack_parameters[templ_id] = (stack['parameters'],
|
||||
stack.get('deleted_at'))
|
||||
|
||||
# validate whether its moved to raw_template
|
||||
raw_template_table = utils.get_table(engine, 'raw_template')
|
||||
raw_templates = raw_template_table.select().execute()
|
||||
|
||||
for raw_template in raw_templates:
|
||||
if raw_template.id in stack_parameters:
|
||||
stack_param, deleted_at = stack_parameters[raw_template.id]
|
||||
tmpl_env = raw_template.environment
|
||||
if engine.name == 'sqlite' and deleted_at is None:
|
||||
stack_param = '"%s"' % stack_param
|
||||
if deleted_at is None:
|
||||
self.assertEqual(stack_param,
|
||||
tmpl_env,
|
||||
'parameters migration from stack to '
|
||||
'raw_template failed')
|
||||
else:
|
||||
self.assertIsNone(tmpl_env,
|
||||
'parameters migration did not skip '
|
||||
'deleted stack')
|
||||
|
||||
def _pre_upgrade_057(self, engine):
|
||||
# template
|
||||
raw_template = utils.get_table(engine, 'raw_template')
|
||||
templ = [dict(id=11, template='{}', files='{}')]
|
||||
engine.execute(raw_template.insert(), templ)
|
||||
|
||||
# credentials
|
||||
user_creds = utils.get_table(engine, 'user_creds')
|
||||
user = [dict(id=11, username='steve', password='notthis',
|
||||
tenant='mine', auth_url='bla',
|
||||
tenant_id=str(uuid.uuid4()),
|
||||
trust_id='',
|
||||
trustor_user_id='')]
|
||||
engine.execute(user_creds.insert(), user)
|
||||
|
||||
# stack
|
||||
stack = utils.get_table(engine, 'stack')
|
||||
stack_data = [dict(id='867aaefb-152e-505d-b13a-35d4c816390c',
|
||||
name='s1',
|
||||
raw_template_id=templ[0]['id'],
|
||||
user_creds_id=user[0]['id'],
|
||||
username='steve', disable_rollback=True)]
|
||||
engine.execute(stack.insert(), stack_data)
|
||||
|
||||
# resource
|
||||
resource = utils.get_table(engine, 'resource')
|
||||
res_data = [dict(id='167aaefb-152e-505d-b13a-35d4c816390c',
|
||||
name='res-4',
|
||||
stack_id=stack_data[0]['id'],
|
||||
user_creds_id=user[0]['id']),
|
||||
dict(id='177aaefb-152e-505d-b13a-35d4c816390c',
|
||||
name='res-5',
|
||||
stack_id=stack_data[0]['id'],
|
||||
user_creds_id=user[0]['id'])]
|
||||
engine.execute(resource.insert(), res_data)
|
||||
|
||||
# resource_data
|
||||
resource_data = utils.get_table(engine, 'resource_data')
|
||||
rd_data = [dict(key='fruit',
|
||||
value='blueberries',
|
||||
reduct=False,
|
||||
resource_id=res_data[0]['id']),
|
||||
dict(key='fruit',
|
||||
value='apples',
|
||||
reduct=False,
|
||||
resource_id=res_data[1]['id'])]
|
||||
engine.execute(resource_data.insert(), rd_data)
|
||||
|
||||
return {'resource': res_data, 'resource_data': rd_data}
|
||||
|
||||
def _check_057(self, engine, data):
|
||||
def uuid_in_res_data(res_uuid):
|
||||
for rd in data['resource']:
|
||||
if rd['id'] == res_uuid:
|
||||
return True
|
||||
return False
|
||||
|
||||
def rd_matches_old_data(key, value, res_uuid):
|
||||
for rd in data['resource_data']:
|
||||
if (rd['resource_id'] == res_uuid and rd['key'] == key
|
||||
and rd['value'] == value):
|
||||
return True
|
||||
return False
|
||||
|
||||
self.assertColumnIsNotNullable(engine, 'resource', 'id')
|
||||
res_table = utils.get_table(engine, 'resource')
|
||||
res_in_db = list(res_table.select().execute())
|
||||
# confirm the resource.id is an int and the uuid field has been
|
||||
# copied from the old id.
|
||||
for r in res_in_db:
|
||||
self.assertIsInstance(r.id, six.integer_types)
|
||||
self.assertTrue(uuid_in_res_data(r.uuid))
|
||||
|
||||
# confirm that the new resource_id points to the correct resource.
|
||||
rd_table = utils.get_table(engine, 'resource_data')
|
||||
rd_in_db = list(rd_table.select().execute())
|
||||
for rd in rd_in_db:
|
||||
for r in res_in_db:
|
||||
if rd.resource_id == r.id:
|
||||
self.assertTrue(rd_matches_old_data(rd.key, rd.value,
|
||||
r.uuid))
|
||||
|
||||
def _check_058(self, engine, data):
|
||||
self.assertColumnExists(engine, 'resource', 'engine_id')
|
||||
self.assertColumnExists(engine, 'resource', 'atomic_key')
|
||||
|
||||
def _check_059(self, engine, data):
|
||||
column_list = [('entity_id', False),
|
||||
('traversal_id', False),
|
||||
('is_update', False),
|
||||
('atomic_key', False),
|
||||
('stack_id', False),
|
||||
('input_data', True),
|
||||
('updated_at', True),
|
||||
('created_at', True)]
|
||||
for column in column_list:
|
||||
self.assertColumnExists(engine, 'sync_point', column[0])
|
||||
if not column[1]:
|
||||
self.assertColumnIsNotNullable(engine, 'sync_point',
|
||||
column[0])
|
||||
else:
|
||||
self.assertColumnIsNullable(engine, 'sync_point', column[0])
|
||||
|
||||
def _check_060(self, engine, data):
|
||||
column_list = ['needed_by', 'requires', 'replaces', 'replaced_by',
|
||||
'current_template_id']
|
||||
for column in column_list:
|
||||
self.assertColumnExists(engine, 'resource', column)
|
||||
|
||||
def _check_061(self, engine, data):
|
||||
for tab_name in ['stack', 'resource', 'software_deployment']:
|
||||
self.assertColumnType(engine, tab_name, 'status_reason',
|
||||
sqlalchemy.Text)
|
||||
|
||||
def _check_062(self, engine, data):
|
||||
self.assertColumnExists(engine, 'stack', 'parent_resource_name')
|
||||
|
||||
def _check_063(self, engine, data):
|
||||
self.assertColumnExists(engine, 'resource',
|
||||
'properties_data_encrypted')
|
||||
|
||||
def _check_064(self, engine, data):
|
||||
self.assertColumnNotExists(engine, 'raw_template',
|
||||
'predecessor')
|
||||
|
||||
def _check_065(self, engine, data):
|
||||
self.assertColumnExists(engine, 'resource', 'root_stack_id')
|
||||
self.assertIndexExists(engine, 'resource', 'ix_resource_root_stack_id')
|
||||
|
||||
def _check_071(self, engine, data):
|
||||
self.assertIndexExists(engine, 'stack', 'ix_stack_owner_id')
|
||||
self.assertIndexMembers(engine, 'stack', 'ix_stack_owner_id',
|
||||
['owner_id'])
|
||||
|
||||
def _check_073(self, engine, data):
|
||||
# check if column still exists and is not nullable.
|
||||
self.assertColumnIsNotNullable(engine, 'resource_data', 'resource_id')
|
||||
|
|
|
|||
Loading…
Reference in New Issue