-
Notifications
You must be signed in to change notification settings - Fork 0
/
deployment-model.go
97 lines (80 loc) · 1.91 KB
/
deployment-model.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
package models
import (
"errors"
"database/sql"
)
type Deployment struct {
Id int64
ProjectId string
Tag string
Description string
Status int
ReleasePath string
DeploymentPath string
Output string
CreatedAt Time
}
type DeploymentStatusCode int
const (
UNKOWN DeploymentStatusCode = iota
SUCCESS
FAIL
)
var DeploymentStatus = [...]string{
"UNKOWN",
"SUCCESS",
"FAIL",
}
func (d *Deployment) Add() error {
sql := "INSERT INTO deployment(project_id, release_path, deployment_path, tag) values(?,?,?,?)"
stmt, err := Mgr.db.Prepare(sql)
defer stmt.Close()
checkErr(err)
res, err := stmt.Exec(&d.ProjectId, &d.ReleasePath, &d.DeploymentPath, &d.Tag)
checkErr(err)
id, err := res.LastInsertId()
checkErr(err)
d.Id = id
return nil
}
func (d *Deployment) PreDeploy() error {
sql := "update deployment set release_path = ? where id = ?"
stmt, err := Mgr.db.Prepare(sql)
defer stmt.Close()
checkErr(err)
res, err := stmt.Exec(&d.ReleasePath, &d.Id)
checkErr(err)
id, err := res.LastInsertId()
checkErr(err)
d.Id = id
return nil
}
func (d *Deployment) Detail() error {
sql := "SELECT tag,release_path,status,created_at FROM deployment where id = ?"
row := Mgr.db.QueryRow(sql, d.Id)
err := row.Scan(&d.Tag, &d.ReleasePath, &d.Status, &d.CreatedAt)
checkErr(err)
return nil
}
func (d *Deployment) Fail() error {
return setStatus(FAIL, d.Id)
}
func (d *Deployment) Success() error {
return setStatus(SUCCESS, d.Id)
}
func setStatus(status DeploymentStatusCode, id int64) error {
var res sql.Result
var stmt *sql.Stmt
var err error
if stmt, err = Mgr.db.Prepare("update deployment set status = ? where id = ?"); err != nil {
return err
}
defer stmt.Close()
if res, err = stmt.Exec(status, id); err != nil {
return err
}
if ids, err := res.RowsAffected(); ids == 0 || err != nil {
return errors.New("no rows affected")
}
return nil
}