summaryrefslogtreecommitdiffstats
path: root/keystone/identity
diff options
context:
space:
mode:
authorJenkins <jenkins@review.openstack.org>2013-06-14 03:14:59 +0000
committerGerrit Code Review <review@openstack.org>2013-06-14 03:14:59 +0000
commit0e4976f79e8964b42161c13c870908b2e4e90ac5 (patch)
tree6dc437f141075161bcaf51b84c0bf38180857adc /keystone/identity
parentc9633837649ed1883c84a75d526ee50659bcc30e (diff)
parent7b7800608af87e5f84df97f8fef7a69b4f435946 (diff)
downloadkeystone-0e4976f79e8964b42161c13c870908b2e4e90ac5.tar.gz
keystone-0e4976f79e8964b42161c13c870908b2e4e90ac5.tar.xz
keystone-0e4976f79e8964b42161c13c870908b2e4e90ac5.zip
Merge "drop user and group constraints"
Diffstat (limited to 'keystone/identity')
-rw-r--r--keystone/identity/backends/sql.py23
1 files changed, 15 insertions, 8 deletions
diff --git a/keystone/identity/backends/sql.py b/keystone/identity/backends/sql.py
index 394be8f8..b2be8774 100644
--- a/keystone/identity/backends/sql.py
+++ b/keystone/identity/backends/sql.py
@@ -96,10 +96,8 @@ class BaseGrant(sql.DictBase):
class UserProjectGrant(sql.ModelBase, BaseGrant):
__tablename__ = 'user_project_metadata'
user_id = sql.Column(sql.String(64),
- sql.ForeignKey('user.id'),
primary_key=True)
project_id = sql.Column(sql.String(64),
- sql.ForeignKey('project.id'),
primary_key=True)
data = sql.Column(sql.JsonBlob())
@@ -208,15 +206,24 @@ class Identity(sql.Base, identity.Driver):
raise exception.ProjectNotFound(project_id=tenant_name)
return project_ref.to_dict()
- def get_project_users(self, tenant_id):
+ def get_project_user_ids(self, tenant_id):
session = self.get_session()
self.get_project(tenant_id)
- query = session.query(User)
- query = query.join(UserProjectGrant)
+ query = session.query(UserProjectGrant)
query = query.filter(UserProjectGrant.project_id == tenant_id)
- user_refs = query.all()
- return [identity.filter_user(user_ref.to_dict())
- for user_ref in user_refs]
+ project_refs = query.all()
+ return [project_ref.user_id for project_ref in project_refs]
+
+ def get_project_users(self, tenant_id):
+ session = self.get_session()
+ self.get_project(tenant_id)
+ user_refs = []
+ for user_id in self.get_project_user_ids(tenant_id):
+ query = session.query(User)
+ query = query.filter(User.id == user_id)
+ user_ref = query.first()
+ user_refs.append(identity.filter_user(user_ref.to_dict()))
+ return user_refs
def get_metadata(self, user_id=None, tenant_id=None,
domain_id=None, group_id=None):