fix

traP-jp · Jan 26, 2025 · 7797d54 · 7797d54
1 parent 0156cd3
commit 7797d54
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 52 deletions.
diff --git a/template/stmt.go b/template/stmt.go
@@ -90,34 +90,9 @@ func (s *customCacheStatement) Exec(args []driver.Value) (driver.Result, error)
 
 func execInsert(queryInfo domains.CachePlanQuery, args []driver.Value) {
 	table := queryInfo.Insert.Table
-	normalizedArgs, _ := normalizer.NormalizeArgs(queryInfo.Query)
-
-	rows := slices.Chunk(args, len(queryInfo.Insert.Columns))
 
 	for _, cache := range cacheByTable[table] {
-		if cache.uniqueOnly {
-			// no need to purge
-			continue
-		}
-
-		selectConditions := cache.info.Conditions
-		if len(selectConditions) != 1 || len(normalizedArgs.ExtraArgs) != 0 || selectConditions[0].Operator != domains.CachePlanOperator_EQ {
-			cache.cache.Purge()
-			continue
-		}
-
-		selectCondition := selectConditions[0]
-		insertColumnIdx := slices.Index(queryInfo.Insert.Columns, selectCondition.Column)
-		if insertColumnIdx >= 0 {
-			// insert query is like "INSERT INTO table (col1, col2, ...) VALUES (?, ?, ...)"
-			// select query is like "SELECT * FROM table WHERE col1 = ?"
-			// forget the cache
-			for row := range rows {
-				cache.cache.Forget(cacheKey([]driver.Value{row[insertColumnIdx]}))
-			}
-		} else {
-			cache.cache.Purge()
-		}
+		cache.cache.Purge()
 	}
 }
 

diff --git a/template/stmt.tmpl b/template/stmt.tmpl
@@ -90,34 +90,9 @@ func (s *customCacheStatement) Exec(args []driver.Value) (driver.Result, error)
 
 func execInsert(queryInfo domains.CachePlanQuery, args []driver.Value) {
 	table := queryInfo.Insert.Table
-	normalizedArgs, _ := normalizer.NormalizeArgs(queryInfo.Query)
-
-	rows := slices.Chunk(args, len(queryInfo.Insert.Columns))
 
 	for _, cache := range cacheByTable[table] {
-		if cache.uniqueOnly {
-			// no need to purge
-			continue
-		}
-
-		selectConditions := cache.info.Conditions
-		if len(selectConditions) != 1 || len(normalizedArgs.ExtraArgs) != 0 || selectConditions[0].Operator != domains.CachePlanOperator_EQ {
-			cache.cache.Purge()
-			continue
-		}
-
-		selectCondition := selectConditions[0]
-		insertColumnIdx := slices.Index(queryInfo.Insert.Columns, selectCondition.Column)
-		if insertColumnIdx >= 0 {
-			// insert query is like "INSERT INTO table (col1, col2, ...) VALUES (?, ?, ...)"
-			// select query is like "SELECT * FROM table WHERE col1 = ?"
-			// forget the cache
-			for row := range rows {
-				cache.cache.Forget(cacheKey([]driver.Value{row[insertColumnIdx]}))
-			}
-		} else {
-			cache.cache.Purge()
-		}
+		cache.cache.Purge()
 	}
 }