(dbID uint, database model.Database, envMap map[string]interface{})
| 390 | } |
| 391 | |
| 392 | func reCreateDB(dbID uint, database model.Database, envMap map[string]interface{}) (*model.DatabaseMysql, error) { |
| 393 | mysqlService := NewIMysqlService() |
| 394 | ctx := context.Background() |
| 395 | _ = mysqlService.Delete(ctx, dto.MysqlDBDelete{ID: dbID, Database: database.Name, Type: database.Type, DeleteBackup: false, ForceDelete: true}) |
| 396 | |
| 397 | dbInfo := getDBCreateInfoFromEnv(envMap, "utf8mb4") |
| 398 | createDB, err := mysqlService.Create(context.Background(), dto.MysqlDBCreate{ |
| 399 | Name: dbInfo.Name, |
| 400 | From: database.From, |
| 401 | Database: database.Name, |
| 402 | Format: dbInfo.Format, |
| 403 | Username: dbInfo.User, |
| 404 | Password: dbInfo.Password, |
| 405 | Permission: "%", |
| 406 | }) |
| 407 | if err != nil { |
| 408 | return nil, err |
| 409 | } |
| 410 | updateCronjobsDBRef(dbID, createDB.ID) |
| 411 | return createDB, nil |
| 412 | } |
| 413 | |
| 414 | func reCreatePostgresqlDB(dbID uint, database model.Database, envMap map[string]interface{}) (*model.DatabasePostgresql, error) { |
| 415 | postgresqlService := NewIPostgresqlService() |
no test coverage detected