Fix cache test

This commit is contained in:
Lunny Xiao 2023-07-20 18:28:42 +08:00
parent fabf0a2895
commit a66a289980
No known key found for this signature in database
GPG Key ID: C3B7C91B632F738A
1 changed files with 4 additions and 2 deletions

View File

@ -231,6 +231,9 @@ func (session *Session) Update(bean interface{}, condiBean ...interface{}) (int6
return 0, err return 0, err
} }
tableName := session.statement.TableName() // table name must been get before exec because statement will be reset
useCache := session.statement.UseCache
res, err := session.exec(updateWriter.String(), append(args, updateWriter.Args()...)...) res, err := session.exec(updateWriter.String(), append(args, updateWriter.Args()...)...)
if err != nil { if err != nil {
return 0, err return 0, err
@ -240,8 +243,7 @@ func (session *Session) Update(bean interface{}, condiBean ...interface{}) (int6
} }
} }
tableName := session.statement.TableName() if cacher := session.engine.GetCacher(tableName); cacher != nil && useCache {
if cacher := session.engine.GetCacher(tableName); cacher != nil && session.statement.UseCache {
session.engine.logger.Debugf("[cache] clear table: %v", tableName) session.engine.logger.Debugf("[cache] clear table: %v", tableName)
cacher.ClearIds(tableName) cacher.ClearIds(tableName)
cacher.ClearBeans(tableName) cacher.ClearBeans(tableName)