Loading src/UnicaenDbImport/Service/DatabaseService.php +3 −0 Original line number Diff line number Diff line Loading @@ -347,14 +347,17 @@ class DatabaseService public function populateImportObservResultTable() { $qb = $this->importObservService->getRepository()->createQueryBuilder('io') ->andWhere("upper(io.tableName) = upper(:table)")->setParameter('table', $this->destination->getTable()) ->andWhere("io.operation = 'UPDATE'") ->andWhere("io.enabled = 1") ->addOrderBy('io.operation, io.tableName, io.columnName'); $importObservRows = $qb->getQuery()->getResult(Query::HYDRATE_ARRAY); if (!empty($importObservRows)) { $sql = $this->codeGenerator->generateSQLForInsertionIntoImportObservResult($importObservRows); $this->queryExecutor->exec($sql, $this->destination->getConnection()); } } /** * @return array Loading Loading
src/UnicaenDbImport/Service/DatabaseService.php +3 −0 Original line number Diff line number Diff line Loading @@ -347,14 +347,17 @@ class DatabaseService public function populateImportObservResultTable() { $qb = $this->importObservService->getRepository()->createQueryBuilder('io') ->andWhere("upper(io.tableName) = upper(:table)")->setParameter('table', $this->destination->getTable()) ->andWhere("io.operation = 'UPDATE'") ->andWhere("io.enabled = 1") ->addOrderBy('io.operation, io.tableName, io.columnName'); $importObservRows = $qb->getQuery()->getResult(Query::HYDRATE_ARRAY); if (!empty($importObservRows)) { $sql = $this->codeGenerator->generateSQLForInsertionIntoImportObservResult($importObservRows); $this->queryExecutor->exec($sql, $this->destination->getConnection()); } } /** * @return array Loading