use datetime fields, not strings

prooph · Dec 12, 2016 · a09e32d · a09e32d
1 parent fdce093
commit a09e32d
Show file tree

Hide file tree

Showing 7 changed files with 11 additions and 9 deletions.
diff --git a/src/PDOStreamIterator.php b/src/PDOStreamIterator.php
@@ -12,6 +12,8 @@
 
 namespace Prooph\EventStore\PDO;
 
+use DateTimeImmutable;
+use DateTimeZone;
 use Iterator;
 use PDO;
 use PDOStatement;
@@ -103,10 +105,10 @@ public function current(): ?Message
             return null;
         }
 
-        $createdAt = \DateTimeImmutable::createFromFormat(
-            'Y-m-d\TH:i:s.u',
+        $createdAt = DateTimeImmutable::createFromFormat(
+            'Y-m-d H:i:s.u',
             $this->currentItem->created_at,
-            new \DateTimeZone('UTC')
+            new DateTimeZone('UTC')
         );
 
         return $this->messageFactory->createMessageFromArray($this->currentItem->event_name, [

diff --git a/src/PersistenceStrategy/MySQLAggregateStreamStrategy.php b/src/PersistenceStrategy/MySQLAggregateStreamStrategy.php
@@ -32,7 +32,7 @@ public function createSchema(string $tableName): array
     `event_name` VARCHAR(100) COLLATE utf8_bin NOT NULL,
     `payload` JSON NOT NULL,
     `metadata` JSON NOT NULL,
-    `created_at` CHAR(26) COLLATE utf8_bin NOT NULL,
+    `created_at` DATETIME(6) NOT NULL,
     `version` INT(11) GENERATED ALWAYS AS (JSON_EXTRACT(metadata, '$._aggregate_version')) STORED NOT NULL UNIQUE KEY,
     PRIMARY KEY (`no`),
     UNIQUE KEY `ix_event_id` (`event_id`)

diff --git a/src/PersistenceStrategy/MySQLSimpleStreamStrategy.php b/src/PersistenceStrategy/MySQLSimpleStreamStrategy.php
@@ -31,7 +31,7 @@ public function createSchema(string $tableName): array
     `event_name` VARCHAR(100) COLLATE utf8_bin NOT NULL,
     `payload` JSON NOT NULL,
     `metadata` JSON NOT NULL,
-    `created_at` CHAR(26) COLLATE utf8_bin NOT NULL,
+    `created_at` DATETIME(6) NOT NULL,
     PRIMARY KEY (`no`),
     UNIQUE KEY `ix_event_id` (`event_id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin;

diff --git a/src/PersistenceStrategy/MySQLSingleStreamStrategy.php b/src/PersistenceStrategy/MySQLSingleStreamStrategy.php
@@ -31,7 +31,7 @@ public function createSchema(string $tableName): array
     `event_name` VARCHAR(100) COLLATE utf8_bin NOT NULL,
     `payload` JSON NOT NULL,
     `metadata` JSON NOT NULL,
-    `created_at` CHAR(26) COLLATE utf8_bin NOT NULL,
+    `created_at` DATETIME(6) NOT NULL,
     `version` INT(11) GENERATED ALWAYS AS (JSON_EXTRACT(metadata, '$._aggregate_version')) STORED NOT NULL,
     `aggregate_id` char(38) CHARACTER SET utf8 COLLATE utf8_bin GENERATED ALWAYS AS (JSON_EXTRACT(metadata, '$._aggregate_id')) STORED NOT NULL,
     `aggregate_type` varchar(150) GENERATED ALWAYS AS (JSON_EXTRACT(metadata, '$._aggregate_type')) STORED NOT NULL,

diff --git a/src/PersistenceStrategy/PostgresAggregateStreamStrategy.php b/src/PersistenceStrategy/PostgresAggregateStreamStrategy.php
@@ -32,7 +32,7 @@ public function createSchema(string $tableName): array
     event_name VARCHAR(100) NOT NULL,
     payload JSONB NOT NULL,
     metadata JSONB NOT NULL,
-    created_at CHAR(26) NOT NULL,
+    created_at TIMESTAMP(6) NOT NULL,
     PRIMARY KEY (no),
     UNIQUE (event_id)
 );

diff --git a/src/PersistenceStrategy/PostgresSimpleStreamStrategy.php b/src/PersistenceStrategy/PostgresSimpleStreamStrategy.php
@@ -31,7 +31,7 @@ public function createSchema(string $tableName): array
     event_name VARCHAR(100) NOT NULL,
     payload JSONB NOT NULL,
     metadata JSONB NOT NULL,
-    created_at CHAR(26) NOT NULL,
+    created_at TIMESTAMP(6) NOT NULL,
     PRIMARY KEY (no),
     UNIQUE (event_id)
 );

diff --git a/src/PersistenceStrategy/PostgresSingleStreamStrategy.php b/src/PersistenceStrategy/PostgresSingleStreamStrategy.php
@@ -31,7 +31,7 @@ public function createSchema(string $tableName): array
     event_name VARCHAR(100) NOT NULL,
     payload JSONB NOT NULL,
     metadata JSONB NOT NULL,
-    created_at CHAR(26) NOT NULL,
+    created_at TIMESTAMP(6) NOT NULL,
     PRIMARY KEY (no),
     CONSTRAINT aggregate_version_not_null CHECK ((metadata->>'_aggregate_version') IS NOT NULL),
     CONSTRAINT aggregate_type_not_null CHECK ((metadata->>'_aggregate_type') IS NOT NULL),