重构seq服务,解决并发id重复问题

miaoxing · Jan 30, 2017 · f8c0be5 · f8c0be5
1 parent ad8c1a2
commit f8c0be5
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/Migration/V20161116144532CreateSeqTable.php b/src/Migration/V20161116144532CreateSeqTable.php
@@ -14,9 +14,9 @@ public function up()
         $this->schema->table('seq')
             ->bigInt('id')->autoIncrement()
             ->primary('id')
+            ->tinyInt('stub')
+            ->unique('stub')
             ->exec();
-
-        $this->db->insert('seq', ['id' => 1]);
     }
 
     /**

diff --git a/src/Service/Seq.php b/src/Service/Seq.php
@@ -35,7 +35,7 @@ public function __invoke($offset = 100)
                 return $this->redis->incr($name, $offset);
 
             case 'db':
-                $stmt = $this->db->query("UPDATE $name SET id = id + $offset;SELECT id FROM $name");
+                $stmt = $this->db->query("REPLACE INTO $name (stub) VALUES (1);SELECT LAST_INSERT_ID();");
                 $stmt->nextRowset();
 
                 return (int) $stmt->fetchColumn();