| @@ 153-168 (lines=16) @@ | ||
| 150 | * |
|
| 151 | * @return IQueryBuilder |
|
| 152 | */ |
|
| 153 | protected function getMembersUpdateSql($circleId, Member $member) { |
|
| 154 | $qb = $this->dbConnection->getQueryBuilder(); |
|
| 155 | $expr = $qb->expr(); |
|
| 156 | ||
| 157 | /** @noinspection PhpMethodParametersCountMismatchInspection */ |
|
| 158 | $qb->update(self::TABLE_MEMBERS) |
|
| 159 | ->where( |
|
| 160 | $expr->andX( |
|
| 161 | $expr->eq('circle_id', $qb->createNamedParameter($circleId)), |
|
| 162 | $expr->eq('user_id', $qb->createNamedParameter($member->getUserId())), |
|
| 163 | $expr->eq('user_type', $qb->createNamedParameter($member->getType())) |
|
| 164 | ) |
|
| 165 | ); |
|
| 166 | ||
| 167 | return $qb; |
|
| 168 | } |
|
| 169 | ||
| 170 | ||
| 171 | /** |
|
| @@ 54-64 (lines=11) @@ | ||
| 51 | * |
|
| 52 | * @param Member $member |
|
| 53 | */ |
|
| 54 | public function removeSharesFromMember(Member $member) { |
|
| 55 | $qb = $this->getSharesDeleteSql(); |
|
| 56 | $expr = $qb->expr(); |
|
| 57 | ||
| 58 | $andX = $expr->andX(); |
|
| 59 | $andX->add($expr->eq('share_with', $qb->createNamedParameter($member->getCircleId()))); |
|
| 60 | $andX->add($expr->eq('uid_initiator', $qb->createNamedParameter($member->getUserId()))); |
|
| 61 | $qb->andWhere($andX); |
|
| 62 | ||
| 63 | $qb->execute(); |
|
| 64 | } |
|
| 65 | ||
| 66 | ||
| 67 | /** |
|