【お試し】Upsert 時に LAST_INSERT_ID 指定

update_db.py

@@ -403,6 +403,7 @@ class VideoDao:
                         %s,
                         %s)
                     ON DUPLICATE KEY UPDATE
+                      id = LAST_INSERT_ID(id),
                       code = VALUES(code),
                       title = VALUES(title),
                       description = VALUES(description),
@@ -623,6 +624,7 @@ class VideoTagDao:
                         %s,
                         %s)
                     ON DUPLICATE KEY UPDATE
+                      id = LAST_INSERT_ID(id),
                       video_id = VALUES(video_id),
                       tag_id = VALUES(tag_id),
                       tagged_at = VALUES(tagged_at),
@@ -756,6 +758,7 @@ class TagDao:
                     VALUES
                       (%s)
                     ON DUPLICATE KEY UPDATE
+                      id = LAST_INSERT_ID(id),
                       name = VALUES(name)""", (tag.name,)))
             tag.id_ = c.lastrowid
 
@@ -837,9 +840,10 @@ class VideoHistoryDao:
                         %s,
                         %s)
                     ON DUPLICATE KEY UPDATE
-                      video_id,
+                      id = LAST_INSERT_ID(id),
-                      fetched_at,
+                      video_id = VALUES(video_id),
-                      views_count""", (video_history.video_id,
+                      fetched_at = VALUES(fetched_at),
+                      views_count = VALUES(views_count)""", (video_history.video_id,
                                                              video_history.fetched_at,
                                                              video_history.views_count)))
 
@@ -938,6 +942,7 @@ class CommentDao:
                         %s,
                         %s)
                     ON DUPLICATE KEY UPDATE
+                      id = LAST_INSERT_ID(id),
                       video_id = VALUES(video_id),
                       comment_no = VALUES(comment_no),
                       user_id = VALUES(user_id),