fix

Author: pirosiki197

template/stmt.go

@@ -237,10 +237,6 @@ func (c *cacheConn) execUpdate(ctx context.Context, queryInfo domains.CachePlanQ
 	}
 	if !updateByUnique {
 		for _, cache := range cacheByTable[table] {
-			if !usedBySelectQuery(cache.info.Targets, queryInfo.Update.Targets) {
-				// no need to purge because the cache does not contain the updated column
-				continue
-			}
 			// we should purge all cache
 			cache.cache.Purge()
 		}
@@ -272,16 +268,9 @@ func (c *cacheConn) execDelete(ctx context.Context, queryInfo domains.CachePlanQ
 		return inner.ExecContext(ctx, queryInfo.Query, args)
 	}
 
-	uniqueValue := args[queryInfo.Delete.Conditions[0].Placeholder.Index]
-
 	for _, cache := range cacheByTable[table] {
-		if cache.uniqueOnly {
-			// query like "SELECT * FROM table WHERE pk = ?"
-			// we should forget the cache
-			cache.cache.Forget(cacheKey([]driver.Value{uniqueValue.Value}))
-		} else {
-			cache.cache.Purge()
-		}
+		cache.cache.Purge()
+
 	}
 
 	return inner.ExecContext(ctx, queryInfo.Query, args)

template/stmt.tmpl

@@ -237,10 +237,6 @@ func (c *cacheConn) execUpdate(ctx context.Context, queryInfo domains.CachePlanQ
 	}
 	if !updateByUnique {
 		for _, cache := range cacheByTable[table] {
-			if !usedBySelectQuery(cache.info.Targets, queryInfo.Update.Targets) {
-				// no need to purge because the cache does not contain the updated column
-				continue
-			}
 			// we should purge all cache
 			cache.cache.Purge()
 		}
@@ -272,16 +268,9 @@ func (c *cacheConn) execDelete(ctx context.Context, queryInfo domains.CachePlanQ
 		return inner.ExecContext(ctx, queryInfo.Query, args)
 	}
 
-	uniqueValue := args[queryInfo.Delete.Conditions[0].Placeholder.Index]
-
 	for _, cache := range cacheByTable[table] {
-		if cache.uniqueOnly {
-			// query like "SELECT * FROM table WHERE pk = ?"
-			// we should forget the cache
-			cache.cache.Forget(cacheKey([]driver.Value{uniqueValue.Value}))
-		} else {
-			cache.cache.Purge()
-		}
+		cache.cache.Purge()
+
 	}
 
 	return inner.ExecContext(ctx, queryInfo.Query, args)