()
| 204 | } |
| 205 | |
| 206 | func InitLogDB() (err error) { |
| 207 | if os.Getenv("LOG_SQL_DSN") == "" { |
| 208 | LOG_DB = DB |
| 209 | return |
| 210 | } |
| 211 | db, err := chooseDB("LOG_SQL_DSN", true) |
| 212 | if err == nil { |
| 213 | if common.DebugEnabled { |
| 214 | db = db.Debug() |
| 215 | } |
| 216 | LOG_DB = db |
| 217 | sqlDB, err := LOG_DB.DB() |
| 218 | if err != nil { |
| 219 | return err |
| 220 | } |
| 221 | sqlDB.SetMaxIdleConns(common.GetEnvOrDefault("SQL_MAX_IDLE_CONNS", 100)) |
| 222 | sqlDB.SetMaxOpenConns(common.GetEnvOrDefault("SQL_MAX_OPEN_CONNS", 1000)) |
| 223 | sqlDB.SetConnMaxLifetime(time.Second * time.Duration(common.GetEnvOrDefault("SQL_MAX_LIFETIME", 60))) |
| 224 | |
| 225 | if !common.IsMasterNode { |
| 226 | return nil |
| 227 | } |
| 228 | common.SysLog("database migration started") |
| 229 | err = migrateLOGDB() |
| 230 | return err |
| 231 | } else { |
| 232 | common.FatalLog(err) |
| 233 | } |
| 234 | return err |
| 235 | } |
| 236 | |
| 237 | func migrateDB() error { |
| 238 | if !common.UsingPostgreSQL { |
no test coverage detected