hotfix: ignore transaction

pirosiki197 · pirosiki197 · commit e15821eaaebf · 2025-01-26T13:53:42.000+09:00
diff --git a/template/driver.go b/template/driver.go
@@ -120,6 +120,8 @@ func (c *cacheConn) Prepare(rawQuery string) (driver.Stmt, error) {
 			PurgeAllCaches()
 		}
 		return c.inner.Prepare(rawQuery)
+	} else if strings.Contains(normalizedQuery, "FOR UPDATE") {
+		return c.inner.Prepare(rawQuery)
 	}
 
 	if queryInfo.Type == domains.CachePlanQueryType_SELECT && !queryInfo.Select.Cache {
diff --git a/template/driver.tmpl b/template/driver.tmpl
@@ -119,6 +119,8 @@ func (c *cacheConn) Prepare(rawQuery string) (driver.Stmt, error) {
 			PurgeAllCaches()
 		}
 		return c.inner.Prepare(rawQuery)
+	} else if strings.Contains(normalizedQuery, "FOR UPDATE") {
+		return c.inner.Prepare(rawQuery)
 	}
 
 	if queryInfo.Type == domains.CachePlanQueryType_SELECT && !queryInfo.Select.Cache {
diff --git a/template/stmt.go b/template/stmt.go
@@ -389,6 +389,8 @@ func (c *cacheConn) QueryContext(ctx context.Context, rawQuery string, nvargs []
 	queryInfo, ok := queryMap[normalizedQuery]
 	if !ok {
 		return inner.QueryContext(ctx, rawQuery, nvargs)
+	} else if strings.Contains(normalizedQuery, "FOR UPDATE") {
+		return inner.QueryContext(ctx, rawQuery, nvargs)
 	}
 	if queryInfo.Type != domains.CachePlanQueryType_SELECT || !queryInfo.Select.Cache {
 		return inner.QueryContext(ctx, rawQuery, nvargs)
diff --git a/template/stmt.tmpl b/template/stmt.tmpl
@@ -389,6 +389,8 @@ func (c *cacheConn) QueryContext(ctx context.Context, rawQuery string, nvargs []
 	queryInfo, ok := queryMap[normalizedQuery]
 	if !ok {
 		return inner.QueryContext(ctx, rawQuery, nvargs)
+	} else if strings.Contains(normalizedQuery, "FOR UPDATE") {
+		return inner.QueryContext(ctx, rawQuery, nvargs)
 	}
 	if queryInfo.Type != domains.CachePlanQueryType_SELECT || !queryInfo.Select.Cache {
 		return inner.QueryContext(ctx, rawQuery, nvargs)

Original file line number	Diff line number	Diff line change
`@@ -120,6 +120,8 @@ func (c *cacheConn) Prepare(rawQuery string) (driver.Stmt, error) {`
`120`	`120`	`PurgeAllCaches()`
`121`	`121`	`}`
`122`	`122`	`return c.inner.Prepare(rawQuery)`
	`123`	`+ } else if strings.Contains(normalizedQuery, "FOR UPDATE") {`
	`124`	`+ return c.inner.Prepare(rawQuery)`
`123`	`125`	`}`
`124`	`126`
`125`	`127`	`if queryInfo.Type == domains.CachePlanQueryType_SELECT && !queryInfo.Select.Cache {`
Original file line number	Diff line number	Diff line change
`@@ -119,6 +119,8 @@ func (c *cacheConn) Prepare(rawQuery string) (driver.Stmt, error) {`
`119`	`119`	`PurgeAllCaches()`
`120`	`120`	`}`
`121`	`121`	`return c.inner.Prepare(rawQuery)`
	`122`	`+ } else if strings.Contains(normalizedQuery, "FOR UPDATE") {`
	`123`	`+ return c.inner.Prepare(rawQuery)`
`122`	`124`	`}`
`123`	`125`
`124`	`126`	`if queryInfo.Type == domains.CachePlanQueryType_SELECT && !queryInfo.Select.Cache {`
Original file line number	Diff line number	Diff line change
`@@ -389,6 +389,8 @@ func (c *cacheConn) QueryContext(ctx context.Context, rawQuery string, nvargs []`
`389`	`389`	`queryInfo, ok := queryMap[normalizedQuery]`
`390`	`390`	`if !ok {`
`391`	`391`	`return inner.QueryContext(ctx, rawQuery, nvargs)`
	`392`	`+ } else if strings.Contains(normalizedQuery, "FOR UPDATE") {`
	`393`	`+ return inner.QueryContext(ctx, rawQuery, nvargs)`
`392`	`394`	`}`
`393`	`395`	`if queryInfo.Type != domains.CachePlanQueryType_SELECT \|\| !queryInfo.Select.Cache {`
`394`	`396`	`return inner.QueryContext(ctx, rawQuery, nvargs)`