Merge remote-tracking branch 'origin/feature/sup_lru_prepareStmt' into feature/sup_lru_prepareStmt

This commit is contained in:
xiezhaodong 2025-04-25 16:21:22 +08:00
commit 4571df5a0f
2 changed files with 6 additions and 4 deletions

View File

@ -35,7 +35,7 @@ type Config struct {
// PrepareStmt executes the given query in cached statement
PrepareStmt bool
// PrepareStmt cache support LRU expired,
//default maxsize=int64 Max value and ttl=1h
// default maxsize=int64 Max value and ttl=1h
PrepareStmtMaxSize int
PrepareStmtTTL time.Duration
@ -110,6 +110,8 @@ type DB struct {
type Session struct {
DryRun bool
PrepareStmt bool
PrepareStmtMaxSize int
PrepareStmtTTL time.Duration
NewDB bool
Initialized bool
SkipHooks bool
@ -273,7 +275,7 @@ func (db *DB) Session(config *Session) *DB {
if v, ok := db.cacheStore.Load(preparedStmtDBKey); ok {
preparedStmt = v.(*PreparedStmtDB)
} else {
preparedStmt = NewPreparedStmtDB(db.ConnPool, db.Config.PrepareStmtMaxSize, db.Config.PrepareStmtTTL)
preparedStmt = NewPreparedStmtDB(db.ConnPool, config.PrepareStmtMaxSize, config.PrepareStmtTTL)
db.cacheStore.Store(preparedStmtDBKey, preparedStmt)
}

View File

@ -1,7 +1,7 @@
package lru
// golang -lru
//https://github.com/hashicorp/golang-lru
// https://github.com/hashicorp/golang-lru
import (
"sync"
"time"
@ -226,7 +226,7 @@ func (c *LRU[K, V]) KeyValues() map[K]V {
continue
}
maps[ent.Key] = ent.Value
//keys = append(keys, ent.Key)
// keys = append(keys, ent.Key)
}
return maps
}