diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-06-14 03:14:59 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-06-14 03:14:59 +0000 |
| commit | 0e4976f79e8964b42161c13c870908b2e4e90ac5 (patch) | |
| tree | 6dc437f141075161bcaf51b84c0bf38180857adc /keystone/identity | |
| parent | c9633837649ed1883c84a75d526ee50659bcc30e (diff) | |
| parent | 7b7800608af87e5f84df97f8fef7a69b4f435946 (diff) | |
| download | keystone-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.py | 23 |
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): |
