Skip to content

Commit 8158c20

Browse files
committed
update: add singleflight into query
1 parent a3138de commit 8158c20

File tree

6 files changed

+356
-250
lines changed

6 files changed

+356
-250
lines changed

cache/afterQuery.go

-128
This file was deleted.

cache/beforeQuery.go

-116
This file was deleted.

cache/cache.go

+1-6
Original file line numberDiff line numberDiff line change
@@ -61,12 +61,7 @@ func (c *Gorm2Cache) Initialize(db *gorm.DB) (err error) {
6161
return err
6262
}
6363

64-
err = db.Callback().Query().Before("gorm:query").Register("gorm:cache:before_query", BeforeQuery(c))
65-
if err != nil {
66-
return err
67-
}
68-
69-
err = db.Callback().Query().After("gorm:query").Register("gorm:cache:after_query", AfterQuery(c))
64+
err = newQueryHandler(c).Bind(db)
7065
if err != nil {
7166
return err
7267
}

0 commit comments

Comments
 (0)