TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-04 16:00:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

启动时自动设置binlog过期时间

Browse Source
This commit is contained in:
刘祥超
2022-09-16 10:39:17 +08:00
parent 320d381bd9
commit ca94e31451
1 changed files with 29 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
internal/nodes/api_node.go
View File

@@ -390,9 +390,9 @@ func (this *APINode) setupDB() error {
if err != nil { if err != nil {
return err return err
} }
value := result.GetString("Value") var value = result.GetString("Value")
if regexp.MustCompile(`^\d+$`).MatchString(value) { if regexp.MustCompile(`^\d+$`).MatchString(value) {
valueInt := types.Int(value) var valueInt = types.Int(value)
if valueInt < 65535 { if valueInt < 65535 {
_, err := db.Exec("SET GLOBAL max_prepared_stmt_count=65535") _, err := db.Exec("SET GLOBAL max_prepared_stmt_count=65535")
if err != nil { if err != nil {
@@ -405,6 +405,33 @@ then restart mysqld.`)
} }
} }
// 调整binlog过期时间
{
const binlogExpireDays = 7
version, err := db.FindCol(0, "SELECT VERSION()")
if err == nil {
var versionString = types.String(version)
if strings.HasPrefix(versionString, "8.") {
result, err := db.FindOne("SHOW VARIABLES WHERE variable_name='binlog_expire_logs_seconds'")
if err == nil && result != nil {
var oldValue = result.GetInt("Value")
if oldValue > binlogExpireDays*86400 {
_, _ = db.Exec("SET GLOBAL binlog_expire_logs_seconds=" + types.String(binlogExpireDays*86400))
}
}
} else if strings.HasPrefix(versionString, "5.") {
result, err := db.FindOne("SHOW VARIABLES WHERE variable_name='expire_logs_days'")
if err == nil && result != nil {
var oldValue = result.GetInt("Value")
if oldValue > binlogExpireDays {
_, _ = db.Exec("SET GLOBAL expire_logs_days=" + types.String(binlogExpireDays))
}
}
}
}
}
return nil return nil
} }