| @@ 44-55 (lines=12) @@ | ||
| 41 | /** |
|
| 42 | * @inheritdoc |
|
| 43 | */ |
|
| 44 | public function deleteByLabelNameAndRelationId( |
|
| 45 | LabelName $labelName, |
|
| 46 | StringLiteral $relationId |
|
| 47 | ) { |
|
| 48 | $queryBuilder = $this->createQueryBuilder() |
|
| 49 | ->delete($this->getTableName()) |
|
| 50 | ->where(SchemaConfigurator::LABEL_NAME . ' = ?') |
|
| 51 | ->andWhere(SchemaConfigurator::RELATION_ID . ' = ?') |
|
| 52 | ->setParameters([$labelName->toNative(), $relationId->toNative()]); |
|
| 53 | ||
| 54 | $this->executeTransactional($queryBuilder); |
|
| 55 | } |
|
| 56 | ||
| 57 | /** |
|
| 58 | * @inheritdoc |
|
| @@ 73-87 (lines=15) @@ | ||
| 70 | /** |
|
| 71 | * @inheritdoc |
|
| 72 | */ |
|
| 73 | public function deleteImportedByRelationId(StringLiteral $relationId) |
|
| 74 | { |
|
| 75 | $queryBuilder = $this->createQueryBuilder() |
|
| 76 | ->delete($this->getTableName()) |
|
| 77 | ->where(SchemaConfigurator::RELATION_ID . ' = :relationId') |
|
| 78 | ->andWhere(SchemaConfigurator::IMPORTED . ' = :imported') |
|
| 79 | ->setParameters( |
|
| 80 | [ |
|
| 81 | ':relationId' => $relationId->toNative(), |
|
| 82 | ':imported' => true, |
|
| 83 | ] |
|
| 84 | ); |
|
| 85 | ||
| 86 | $this->executeTransactional($queryBuilder); |
|
| 87 | } |
|
| 88 | ||
| 89 | /** |
|
| 90 | * @param QueryBuilder $queryBuilder |
|