diff --git a/src/Shared/EventBus/EventRepositoryInMySQL.php b/src/Shared/EventBus/EventRepositoryInMySQL.php index 0c70f76..015ad48 100644 --- a/src/Shared/EventBus/EventRepositoryInMySQL.php +++ b/src/Shared/EventBus/EventRepositoryInMySQL.php @@ -24,17 +24,17 @@ public function __construct(mysqli $mysqli) public function store(Event $event): void { $stmt = $this->mysqli->prepare( - "INSERT INTO `events` - (`eventId`, `domainEvent`, `commandHandlerFQN`, `occurredOn`) + "INSERT INTO `events` + (`eventId`, `domainEvent`, `commandHandlerFQN`, `occurredOn`) VALUES (?, ?, ?, ?) ON DUPLICATE KEY UPDATE `domainEvent`=VALUES(`domainEvent`), `commandHandlerFQN`=VALUES(`commandHandlerFQN`), `occurredOn`=VALUES(`occurredOn`); " ); - $stmt->bind_param('ssss', $eventIdValue, $domainEventValue, $commandHandlerValue, $occurredOnValue); $eventIdValue = $event->getEventId()->toString(); $domainEventValue = json_encode($event->getDomainEvent(), JSON_THROW_ON_ERROR); $commandHandlerValue = $event->getCommandHandlerFQN(); $occurredOnValue = $event->getOccurredOn()->format('Y-m-d H:i:s'); + $stmt->bind_param('ssss', $eventIdValue, $domainEventValue, $commandHandlerValue, $occurredOnValue); $stmt->execute(); } diff --git a/src/Shared/MysqlClient/MysqlClient.php b/src/Shared/MysqlClient/MysqlClient.php index 239176d..484bb58 100644 --- a/src/Shared/MysqlClient/MysqlClient.php +++ b/src/Shared/MysqlClient/MysqlClient.php @@ -31,26 +31,12 @@ public static function resetDatabase(string $database, bool $importFixtures = tr { $structureFile = dirname(__DIR__, 3) . '/resources/structure.sql'; $testDataFile = dirname(__DIR__, 3) . '/resources/test_fixtures.sql'; - shell_exec( - 'mysql -u' . $_ENV['MYSQL_USER'] . ' -p' . $_ENV['MYSQL_PASS'] - . ' -e \'DROP DATABASE IF EXISTS `' . $database . '`\' 2>&1' - ); - shell_exec( - 'mysql -u' . $_ENV['MYSQL_USER'] - . ' -p' . $_ENV['MYSQL_PASS'] - . ' --execute=\'CREATE DATABASE `' . $database . '`\' 2>&1' - ); - shell_exec( - 'mysql -u' . $_ENV['MYSQL_USER'] - . ' -p' . $_ENV['MYSQL_PASS'] - . ' ' . $database . ' < ' . $structureFile . ' 2>&1' - ); + $startMysqlQuery = 'mysql -u' . $_ENV['MYSQL_USER'] . ' -p' . $_ENV['MYSQL_PASS']; + shell_exec($startMysqlQuery . ' -e \'DROP DATABASE IF EXISTS `' . $database . '`\' 2>&1'); + shell_exec($startMysqlQuery . ' --execute=\'CREATE DATABASE `' . $database . '`\' 2>&1'); + shell_exec($startMysqlQuery . ' ' . $database . ' < ' . $structureFile . ' 2>&1'); if ($importFixtures === true) { - shell_exec( - 'mysql -u' . $_ENV['MYSQL_USER'] - . ' -p' . $_ENV['MYSQL_PASS'] - . ' ' . $database . ' < ' . $testDataFile . ' 2>&1' - ); + shell_exec($startMysqlQuery . ' ' . $database . ' < ' . $testDataFile . ' 2>&1'); } } } diff --git a/src/User/Application/Command/ChangePasswordCommand.php b/src/User/Application/Command/ChangePasswordCommand.php index cb25579..1db07e9 100644 --- a/src/User/Application/Command/ChangePasswordCommand.php +++ b/src/User/Application/Command/ChangePasswordCommand.php @@ -26,4 +26,4 @@ public function getPassword(): string { return $this->password; } -} \ No newline at end of file +} diff --git a/src/User/Domain/ValueObject/Email.php b/src/User/Domain/ValueObject/Email.php index c336baa..c1a5f17 100644 --- a/src/User/Domain/ValueObject/Email.php +++ b/src/User/Domain/ValueObject/Email.php @@ -22,4 +22,4 @@ public function __toString(): string { return $this->email; } -} \ No newline at end of file +} diff --git a/src/User/Domain/ValueObject/Password.php b/src/User/Domain/ValueObject/Password.php index c242c4f..4395018 100644 --- a/src/User/Domain/ValueObject/Password.php +++ b/src/User/Domain/ValueObject/Password.php @@ -22,4 +22,4 @@ public function __toString(): string { return $this->password; } -} \ No newline at end of file +} diff --git a/src/User/Domain/ValueObject/StringValueObject.php b/src/User/Domain/ValueObject/StringValueObject.php index 6bc2a80..81a44c8 100644 --- a/src/User/Domain/ValueObject/StringValueObject.php +++ b/src/User/Domain/ValueObject/StringValueObject.php @@ -9,4 +9,4 @@ interface StringValueObject public function toString(): string; public function __toString(): string; -} \ No newline at end of file +} diff --git a/src/User/Domain/ValueObject/UserId.php b/src/User/Domain/ValueObject/UserId.php index 8cea478..df2e108 100644 --- a/src/User/Domain/ValueObject/UserId.php +++ b/src/User/Domain/ValueObject/UserId.php @@ -28,4 +28,4 @@ public function __toString(): string { return $this->identifier; } -} \ No newline at end of file +}