API の処理に時間がかかりすぎる問題 (#442) (#449)

Reviewed-on: #449
Co-authored-by: miteruzo <miteruzo@naver.com>

backend/app/models/history_access.rb

@@ -59,20 +59,21 @@ class HistoryAccess < ActiveSupport::CurrentAttributes
   end
 
   def self.json_reference(table, key, document)
-    "NOT EXISTS (SELECT 1 FROM JSON_TABLE(COALESCE(#{ document }, JSON_ARRAY()), " +
+    # A scalar lookup avoids MySQL's semijoin rewrite losing the JSON row correlation.
+    "(SELECT 1 FROM JSON_TABLE(COALESCE(#{ document }, JSON_ARRAY()), " +
         "'$[*]' COLUMNS (reference_id BIGINT PATH '$' NULL ON EMPTY)) reference_entry " +
         "JOIN (#{ discarded_keys(table, key) }) blocked " +
-        "ON reference_entry.reference_id = blocked.#{ key })"
+        "ON reference_entry.reference_id = blocked.#{ key } LIMIT 1) IS NULL"
   end
 
   def self.list_reference(table, key, document)
     # Preserve FIND_IN_SET's exact token semantics, including empty tokens.
     array = "CONCAT('[', REPLACE(JSON_QUOTE(REPLACE(COALESCE(#{ document }, ''), " +
         "' ', ',')), ',', '\",\"'), ']')"
-    "NOT EXISTS (SELECT 1 FROM JSON_TABLE(#{ array }, '$[*]' " +
+    "(SELECT 1 FROM JSON_TABLE(#{ array }, '$[*]' " +
         "COLUMNS (reference_id VARCHAR(255) PATH '$')) reference_entry " +
         "JOIN (#{ discarded_keys(table, key) }) blocked " +
-        "ON reference_entry.reference_id = CAST(blocked.#{ key } AS CHAR))"
+        "ON reference_entry.reference_id = CAST(blocked.#{ key } AS CHAR) LIMIT 1) IS NULL"
   end
 
   def self.snapshot_reference(model, row, external: false)
@@ -91,8 +92,8 @@ class HistoryAccess < ActiveSupport::CurrentAttributes
       match += ' AND reference_version.version_no = tag_reference.version_no'
       latest = ''
     end
-    "NOT EXISTS (SELECT 1 FROM #{ source } JOIN #{ table } reference_version ON #{ match } " +
-        "WHERE NOT (#{ sql(model, 'reference_version') }) #{ latest })"
+    "(SELECT 1 FROM #{ source } JOIN #{ table } reference_version ON #{ match } " +
+        "WHERE NOT (#{ sql(model, 'reference_version') }) #{ latest } LIMIT 1) IS NULL"
   end
 
   def self.reference_sql(table, row)
@@ -109,11 +110,15 @@ class HistoryAccess < ActiveSupport::CurrentAttributes
       # conservatively; never expose a private linked name through an external tag.
       names = "JSON_MERGE_PRESERVE(JSON_ARRAY(private_tag.name), " +
           "COALESCE(JSON_EXTRACT(private_tag.names, '$**.name'), JSON_ARRAY()))"
-      ["NOT EXISTS (SELECT 1 FROM tag_versions private_tag " +
+      # DISTINCT prevents merging this independent name set into the correlated scan.
+      # Keep byte-distinct names even when the column collation considers them equal.
+      private_names = 'SELECT DISTINCT private_name.name, ' +
+          'CAST(private_name.name AS BINARY) AS name_bytes FROM tag_versions private_tag ' +
           "JOIN (#{ discarded_keys('tag_versions', 'tag_id') }) blocked " +
-          "ON blocked.tag_id = private_tag.tag_id " +
+          'ON blocked.tag_id = private_tag.tag_id ' +
           "JOIN JSON_TABLE(#{ names }, '$[*]' COLUMNS (name TEXT PATH '$')) private_name " +
-          "WHERE private_name.name <> '' AND " +
+          "WHERE private_name.name <> ''"
+      ["NOT EXISTS (SELECT 1 FROM (#{ private_names }) private_name WHERE " +
           "LOCATE(CONCAT(' ', private_name.name, ' '), " +
           "CONCAT(' ', COALESCE(#{ row }.linked_tags, ''), ' ')) > 0)"]
     when 'tag_versions'