WebnetFr\DatabaseAnonymizer\Anonymizer::anonymize()

Complexity

Conditions	7
Paths	7

Size

Total Lines	36
Code Lines	20

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function anonymize(Connection $connection, array $targets)
    {
        foreach ($targets as $targetTable) {
            $allFieldNames = $targetTable->getAllFieldNames();
            $pk = $targetTable->getPrimaryKey();

            // Select all rows form current table:
            // SELECT <all target fields> FROM <target table>
            $fetchRowsSQL = $connection->createQueryBuilder()
                ->select(join(',', $allFieldNames))
                ->from($targetTable->getName())
                ->getSQL();
            $fetchRowsStmt = $connection->prepare($fetchRowsSQL);
            $fetchRowsStmt->execute();

            // Anonymize all rows in current target table.
            while ($row = $fetchRowsStmt->fetch()) {
                $values = [];
                // Anonymize all target fields in current row.
                foreach ($targetTable->getTargetFields() as $targetField) {
                    $anonValue = $targetField->generate();

                    if (!is_null($anonValue) && !is_string($anonValue)) {
                        throw new InvalidAnonymousValueException('Generated value must be null or string');
                    }

                    // Set anonymized value.
                    $values[$targetField->getName()] =  $anonValue;
                }

                $pkValues = [];
                foreach ($pk as $pkField) {
                    $pkValues[$pkField] = $row[$pkField];
                }

                $connection->update($targetTable->getName(), $values, $pkValues);
            }