Change ctxt to context to for consistency
rename ctxt in all files under db/ Partial-Bug: #1416922 Change-Id: I41dd3ad26c20791861d443ae9e52c1237a73495b
This commit is contained in:
parent
c96abe002e
commit
8a109e562b
|
@ -43,14 +43,14 @@ class Connection(object):
|
|||
"""Constructor."""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get_bay_list(self, ctxt, columns=None, filters=None, limit=None,
|
||||
def get_bay_list(self, context, columns=None, filters=None, limit=None,
|
||||
marker=None, sort_key=None, sort_dir=None):
|
||||
"""Get specific columns for matching bays.
|
||||
|
||||
Return a list of the specified columns for all bays that match the
|
||||
specified filters.
|
||||
|
||||
:param ctxt: The security context
|
||||
:param context: The security context
|
||||
:param columns: List of column names to return.
|
||||
Defaults to 'id' column when columns == None.
|
||||
:param filters: Filters to apply. Defaults to None.
|
||||
|
@ -83,19 +83,19 @@ class Connection(object):
|
|||
"""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get_bay_by_id(self, ctxt, bay_id):
|
||||
def get_bay_by_id(self, context, bay_id):
|
||||
"""Return a bay.
|
||||
|
||||
:param ctxt: The security context
|
||||
:param context: The security context
|
||||
:param bay_id: The id of a bay.
|
||||
:returns: A bay.
|
||||
"""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get_bay_by_uuid(self, ctxt, bay_uuid):
|
||||
def get_bay_by_uuid(self, context, bay_uuid):
|
||||
"""Return a bay.
|
||||
|
||||
:param ctxt: The security context
|
||||
:param context: The security context
|
||||
:param bay_uuid: The uuid of a bay.
|
||||
:returns: A bay.
|
||||
"""
|
||||
|
@ -117,14 +117,15 @@ class Connection(object):
|
|||
"""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get_baymodel_list(self, ctxt, columns=None, filters=None, limit=None,
|
||||
marker=None, sort_key=None, sort_dir=None):
|
||||
def get_baymodel_list(self, context, columns=None, filters=None,
|
||||
limit=None, marker=None, sort_key=None,
|
||||
sort_dir=None):
|
||||
"""Get specific columns for matching baymodels.
|
||||
|
||||
Return a list of the specified columns for all baymodels that match the
|
||||
specified filters.
|
||||
|
||||
:param ctxt: The security context
|
||||
:param context: The security context
|
||||
:param columns: List of column names to return.
|
||||
Defaults to 'id' column when columns == None.
|
||||
:param filters: Filters to apply. Defaults to None.
|
||||
|
@ -158,19 +159,19 @@ class Connection(object):
|
|||
"""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get_baymodel_by_id(self, ctxt, baymodel_id):
|
||||
def get_baymodel_by_id(self, context, baymodel_id):
|
||||
"""Return a baymodel.
|
||||
|
||||
:param ctxt: The security context
|
||||
:param context: The security context
|
||||
:param baymodel_id: The id of a baymodel.
|
||||
:returns: A baymodel.
|
||||
"""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get_baymodel_by_uuid(self, ctxt, baymodel_uuid):
|
||||
def get_baymodel_by_uuid(self, context, baymodel_uuid):
|
||||
"""Return a baymodel.
|
||||
|
||||
:param ctxt: The security context
|
||||
:param context: The security context
|
||||
:param baymodel_uuid: The uuid of a baymodel.
|
||||
:returns: A baymodel.
|
||||
"""
|
||||
|
@ -192,14 +193,15 @@ class Connection(object):
|
|||
"""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get_container_list(self, ctxt, columns=None, filters=None, limit=None,
|
||||
marker=None, sort_key=None, sort_dir=None):
|
||||
def get_container_list(self, context, columns=None, filters=None,
|
||||
limit=None, marker=None, sort_key=None,
|
||||
sort_dir=None):
|
||||
"""Get specific columns for matching containers.
|
||||
|
||||
Return a list of the specified columns for all containers that match
|
||||
the specified filters.
|
||||
|
||||
:param ctxt: The security context
|
||||
:param context: The security context
|
||||
:param columns: List of column names to return.
|
||||
Defaults to 'id' column when columns == None.
|
||||
:param filters: Filters to apply. Defaults to None.
|
||||
|
@ -234,19 +236,19 @@ class Connection(object):
|
|||
"""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get_container_by_id(self, ctxt, container_id):
|
||||
def get_container_by_id(self, context, container_id):
|
||||
"""Return a container.
|
||||
|
||||
:param ctxt: The security context
|
||||
:param context: The security context
|
||||
:param container_id: The id of a container.
|
||||
:returns: A container.
|
||||
"""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get_container_by_uuid(self, ctxt, container_uuid):
|
||||
def get_container_by_uuid(self, context, container_uuid):
|
||||
"""Return a container.
|
||||
|
||||
:param ctxt: The security context
|
||||
:param context: The security context
|
||||
:param container_uuid: The uuid of a container.
|
||||
:returns: A container.
|
||||
"""
|
||||
|
@ -268,14 +270,14 @@ class Connection(object):
|
|||
"""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get_node_list(self, ctxt, columns=None, filters=None, limit=None,
|
||||
def get_node_list(self, context, columns=None, filters=None, limit=None,
|
||||
marker=None, sort_key=None, sort_dir=None):
|
||||
"""Get specific columns for matching nodes.
|
||||
|
||||
Return a list of the specified columns for all nodes that match the
|
||||
specified filters.
|
||||
|
||||
:param ctxt: The security context
|
||||
:param context: The security context
|
||||
:param columns: List of column names to return.
|
||||
Defaults to 'id' column when columns == None.
|
||||
:param filters: Filters to apply. Defaults to None.
|
||||
|
@ -308,19 +310,19 @@ class Connection(object):
|
|||
"""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get_node_by_id(self, ctxt, node_id):
|
||||
def get_node_by_id(self, context, node_id):
|
||||
"""Return a node.
|
||||
|
||||
:param ctxt: The security context
|
||||
:param context: The security context
|
||||
:param node_id: The id of a node.
|
||||
:returns: A node.
|
||||
"""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get_node_by_uuid(self, ctxt, node_uuid):
|
||||
def get_node_by_uuid(self, context, node_uuid):
|
||||
"""Return a node.
|
||||
|
||||
:param ctxt: The security context
|
||||
:param context: The security context
|
||||
:param node_uuid: The uuid of a node.
|
||||
:returns: A node.
|
||||
"""
|
||||
|
|
|
@ -107,11 +107,11 @@ class Connection(api.Connection):
|
|||
def __init__(self):
|
||||
pass
|
||||
|
||||
def _add_tenant_filters(self, ctxt, query):
|
||||
if ctxt.project_id:
|
||||
query = query.filter_by(project_id=ctxt.project_id)
|
||||
def _add_tenant_filters(self, context, query):
|
||||
if context.project_id:
|
||||
query = query.filter_by(project_id=context.project_id)
|
||||
else:
|
||||
query = query.filter_by(user_id=ctxt.user_id)
|
||||
query = query.filter_by(user_id=context.user_id)
|
||||
|
||||
return query
|
||||
|
||||
|
@ -152,10 +152,10 @@ class Connection(api.Connection):
|
|||
return _paginate_query(models.Bay, limit, marker,
|
||||
sort_key, sort_dir, query)
|
||||
|
||||
def get_bay_list(self, ctxt, filters=None, limit=None, marker=None,
|
||||
def get_bay_list(self, context, filters=None, limit=None, marker=None,
|
||||
sort_key=None, sort_dir=None):
|
||||
query = model_query(models.Bay)
|
||||
query = self._add_tenant_filters(ctxt, query)
|
||||
query = self._add_tenant_filters(context, query)
|
||||
query = self._add_bays_filters(query, filters)
|
||||
return _paginate_query(models.Bay, limit, marker,
|
||||
sort_key, sort_dir, query)
|
||||
|
@ -173,18 +173,18 @@ class Connection(api.Connection):
|
|||
raise exception.BayAlreadyExists(uuid=values['uuid'])
|
||||
return bay
|
||||
|
||||
def get_bay_by_id(self, ctxt, bay_id):
|
||||
def get_bay_by_id(self, context, bay_id):
|
||||
query = model_query(models.Bay)
|
||||
query = self._add_tenant_filters(ctxt, query)
|
||||
query = self._add_tenant_filters(context, query)
|
||||
query = query.filter_by(id=bay_id)
|
||||
try:
|
||||
return query.one()
|
||||
except NoResultFound:
|
||||
raise exception.BayNotFound(bay=bay_id)
|
||||
|
||||
def get_bay_by_uuid(self, ctxt, bay_uuid):
|
||||
def get_bay_by_uuid(self, context, bay_uuid):
|
||||
query = model_query(models.Bay)
|
||||
query = self._add_tenant_filters(ctxt, query)
|
||||
query = self._add_tenant_filters(context, query)
|
||||
query = query.filter_by(uuid=bay_uuid)
|
||||
try:
|
||||
return query.one()
|
||||
|
@ -289,10 +289,10 @@ class Connection(api.Connection):
|
|||
return _paginate_query(models.BayModel, limit, marker,
|
||||
sort_key, sort_dir, query)
|
||||
|
||||
def get_baymodel_list(self, ctxt, filters=None, limit=None, marker=None,
|
||||
def get_baymodel_list(self, context, filters=None, limit=None, marker=None,
|
||||
sort_key=None, sort_dir=None):
|
||||
query = model_query(models.BayModel)
|
||||
query = self._add_tenant_filters(ctxt, query)
|
||||
query = self._add_tenant_filters(context, query)
|
||||
query = self._add_baymodels_filters(query, filters)
|
||||
return _paginate_query(models.BayModel, limit, marker,
|
||||
sort_key, sort_dir, query)
|
||||
|
@ -310,18 +310,18 @@ class Connection(api.Connection):
|
|||
raise exception.BayModelAlreadyExists(uuid=values['uuid'])
|
||||
return baymodel
|
||||
|
||||
def get_baymodel_by_id(self, ctxt, baymodel_id):
|
||||
def get_baymodel_by_id(self, context, baymodel_id):
|
||||
query = model_query(models.BayModel)
|
||||
query = self._add_tenant_filters(ctxt, query)
|
||||
query = self._add_tenant_filters(context, query)
|
||||
query = query.filter_by(id=baymodel_id)
|
||||
try:
|
||||
return query.one()
|
||||
except NoResultFound:
|
||||
raise exception.BayModelNotFound(baymodel=baymodel_id)
|
||||
|
||||
def get_baymodel_by_uuid(self, ctxt, baymodel_uuid):
|
||||
def get_baymodel_by_uuid(self, context, baymodel_uuid):
|
||||
query = model_query(models.BayModel)
|
||||
query = self._add_tenant_filters(ctxt, query)
|
||||
query = self._add_tenant_filters(context, query)
|
||||
query = query.filter_by(uuid=baymodel_uuid)
|
||||
try:
|
||||
return query.one()
|
||||
|
@ -401,10 +401,10 @@ class Connection(api.Connection):
|
|||
return _paginate_query(models.Container, limit, marker,
|
||||
sort_key, sort_dir, query)
|
||||
|
||||
def get_container_list(self, ctxt, filters=None, limit=None, marker=None,
|
||||
sort_key=None, sort_dir=None):
|
||||
def get_container_list(self, context, filters=None, limit=None,
|
||||
marker=None, sort_key=None, sort_dir=None):
|
||||
query = model_query(models.Container)
|
||||
query = self._add_tenant_filters(ctxt, query)
|
||||
query = self._add_tenant_filters(context, query)
|
||||
query = self._add_containers_filters(query, filters)
|
||||
return _paginate_query(models.Container, limit, marker,
|
||||
sort_key, sort_dir, query)
|
||||
|
@ -422,18 +422,18 @@ class Connection(api.Connection):
|
|||
raise exception.ContainerAlreadyExists(uuid=values['uuid'])
|
||||
return container
|
||||
|
||||
def get_container_by_id(self, ctxt, container_id):
|
||||
def get_container_by_id(self, context, container_id):
|
||||
query = model_query(models.Container)
|
||||
query = self._add_tenant_filters(ctxt, query)
|
||||
query = self._add_tenant_filters(context, query)
|
||||
query = query.filter_by(id=container_id)
|
||||
try:
|
||||
return query.one()
|
||||
except NoResultFound:
|
||||
raise exception.ContainerNotFound(container=container_id)
|
||||
|
||||
def get_container_by_uuid(self, ctxt, container_uuid):
|
||||
def get_container_by_uuid(self, context, container_uuid):
|
||||
query = model_query(models.Container)
|
||||
query = self._add_tenant_filters(ctxt, query)
|
||||
query = self._add_tenant_filters(context, query)
|
||||
query = query.filter_by(uuid=container_uuid)
|
||||
try:
|
||||
return query.one()
|
||||
|
@ -507,10 +507,10 @@ class Connection(api.Connection):
|
|||
return _paginate_query(models.Node, limit, marker,
|
||||
sort_key, sort_dir, query)
|
||||
|
||||
def get_node_list(self, ctxt, filters=None, limit=None, marker=None,
|
||||
def get_node_list(self, context, filters=None, limit=None, marker=None,
|
||||
sort_key=None, sort_dir=None):
|
||||
query = model_query(models.Node)
|
||||
query = self._add_tenant_filters(ctxt, query)
|
||||
query = self._add_tenant_filters(context, query)
|
||||
query = self._add_nodes_filters(query, filters)
|
||||
return _paginate_query(models.Node, limit, marker,
|
||||
sort_key, sort_dir, query)
|
||||
|
@ -532,18 +532,18 @@ class Connection(api.Connection):
|
|||
raise exception.NodeAlreadyExists(uuid=values['uuid'])
|
||||
return node
|
||||
|
||||
def get_node_by_id(self, ctxt, node_id):
|
||||
def get_node_by_id(self, context, node_id):
|
||||
query = model_query(models.Node)
|
||||
query = self._add_tenant_filters(ctxt, query)
|
||||
query = self._add_tenant_filters(context, query)
|
||||
query = query.filter_by(id=node_id)
|
||||
try:
|
||||
return query.one()
|
||||
except NoResultFound:
|
||||
raise exception.NodeNotFound(node=node_id)
|
||||
|
||||
def get_node_by_uuid(self, ctxt, node_uuid):
|
||||
def get_node_by_uuid(self, context, node_uuid):
|
||||
query = model_query(models.Node)
|
||||
query = self._add_tenant_filters(ctxt, query)
|
||||
query = self._add_tenant_filters(context, query)
|
||||
query = query.filter_by(uuid=node_uuid)
|
||||
try:
|
||||
return query.one()
|
||||
|
|
Loading…
Reference in New Issue