(parentTask *task.Task, resourceKey, tmpDir, name string, databaseID uint)
| 95 | } |
| 96 | |
| 97 | func backupDatabaseWithTask(parentTask *task.Task, resourceKey, tmpDir, name string, databaseID uint) error { |
| 98 | switch resourceKey { |
| 99 | case constant.AppMysql, constant.AppMariaDB: |
| 100 | db, err := mysqlRepo.Get(repo.WithByID(databaseID)) |
| 101 | if err != nil { |
| 102 | return err |
| 103 | } |
| 104 | parentTask.LogStart(task.GetTaskName(db.Name, task.TaskBackup, task.TaskScopeDatabase)) |
| 105 | databaseHelper := DatabaseHelper{Database: db.MysqlName, DBType: resourceKey, Name: db.Name} |
| 106 | if err := handleMysqlBackup(databaseHelper, parentTask, 0, tmpDir, fmt.Sprintf("%s.sql.gz", name), "", ""); err != nil { |
| 107 | return err |
| 108 | } |
| 109 | parentTask.LogSuccess(task.GetTaskName(db.Name, task.TaskBackup, task.TaskScopeDatabase)) |
| 110 | case constant.AppPostgresql: |
| 111 | db, err := postgresqlRepo.Get(repo.WithByID(databaseID)) |
| 112 | if err != nil { |
| 113 | return err |
| 114 | } |
| 115 | parentTask.LogStart(task.GetTaskName(db.Name, task.TaskBackup, task.TaskScopeDatabase)) |
| 116 | databaseHelper := DatabaseHelper{Database: db.PostgresqlName, DBType: resourceKey, Name: db.Name} |
| 117 | if err := handlePostgresqlBackup(databaseHelper, parentTask, 0, tmpDir, fmt.Sprintf("%s.sql.gz", name), "", ""); err != nil { |
| 118 | return err |
| 119 | } |
| 120 | parentTask.LogSuccess(task.GetTaskName(db.Name, task.TaskBackup, task.TaskScopeDatabase)) |
| 121 | } |
| 122 | return nil |
| 123 | } |
| 124 | |
| 125 | func handleAppBackup(install *model.AppInstall, parentTask *task.Task, recordID uint, backupDir, fileName, excludes, secret, taskID string) error { |
| 126 | var ( |
no test coverage detected