OLD | NEW |
1 package buildbot | 1 package buildbot |
2 | 2 |
3 import ( | 3 import ( |
4 "database/sql" | 4 "database/sql" |
5 "encoding/json" | 5 "encoding/json" |
6 "fmt" | 6 "fmt" |
7 ) | 7 ) |
8 | 8 |
9 // build from the database. | 9 // build from the database. |
10 func GetCommitsForBuild(master, builder string, buildNumber int) ([]string, erro
r) { | 10 func GetCommitsForBuild(master, builder string, buildNumber int) ([]string, erro
r) { |
(...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
134 if err != nil { | 134 if err != nil { |
135 return fmt.Errorf("Failed to delete build steps from database: %
v", err) | 135 return fmt.Errorf("Failed to delete build steps from database: %
v", err) |
136 } | 136 } |
137 // Actually insert the steps. | 137 // Actually insert the steps. |
138 insertStepStmt, err := tx.Preparex(fmt.Sprintf("REPLACE INTO %s (builder
,master,buildNumber,name,results,number,started,finished) VALUES (?,?,?,?,?,?,?,
?);", TABLE_BUILD_STEPS)) | 138 insertStepStmt, err := tx.Preparex(fmt.Sprintf("REPLACE INTO %s (builder
,master,buildNumber,name,results,number,started,finished) VALUES (?,?,?,?,?,?,?,
?);", TABLE_BUILD_STEPS)) |
139 if err != nil { | 139 if err != nil { |
140 return fmt.Errorf("Unable to push buildsteps into database - Cou
ld not prepare statement: %v", err) | 140 return fmt.Errorf("Unable to push buildsteps into database - Cou
ld not prepare statement: %v", err) |
141 } | 141 } |
142 defer insertStepStmt.Close() | 142 defer insertStepStmt.Close() |
143 for _, s := range b.Steps { | 143 for _, s := range b.Steps { |
144 » » _, err = insertStepStmt.Exec(s.BuilderName, s.MasterName, s.Buil
dNumber, s.Name, s.Results, s.Number, s.Started, s.Finished) | 144 » » _, err = insertStepStmt.Exec(b.BuilderName, b.MasterName, b.Numb
er, s.Name, s.Results, s.Number, s.Started, s.Finished) |
145 if err != nil { | 145 if err != nil { |
146 » » » return fmt.Errorf("Failed to push build into database: %
v", err) | 146 » » » return fmt.Errorf("Failed to push build step into databa
se: %v", err) |
147 } | 147 } |
148 | 148 |
149 } | 149 } |
150 | 150 |
151 // Commits. | 151 // Commits. |
152 | 152 |
153 // First, delete existing revisions so that we don't have leftovers | 153 // First, delete existing revisions so that we don't have leftovers |
154 // hanging around from before. | 154 // hanging around from before. |
155 delCmtsStmt, err := tx.Preparex(fmt.Sprintf("DELETE FROM %s WHERE master
= ? AND builder = ? AND number = ?;", TABLE_BUILD_REVISIONS)) | 155 delCmtsStmt, err := tx.Preparex(fmt.Sprintf("DELETE FROM %s WHERE master
= ? AND builder = ? AND number = ?;", TABLE_BUILD_REVISIONS)) |
156 if err != nil { | 156 if err != nil { |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
204 if err != nil { | 204 if err != nil { |
205 return nil, fmt.Errorf("Unable to retrieve unfinished builds - C
ould not prepare statement: %v", err) | 205 return nil, fmt.Errorf("Unable to retrieve unfinished builds - C
ould not prepare statement: %v", err) |
206 } | 206 } |
207 defer stmt.Close() | 207 defer stmt.Close() |
208 b := []*Build{} | 208 b := []*Build{} |
209 if err = stmt.Select(&b); err != nil { | 209 if err = stmt.Select(&b); err != nil { |
210 return nil, fmt.Errorf("Unable to retrieve unfinished builds: %v
", err) | 210 return nil, fmt.Errorf("Unable to retrieve unfinished builds: %v
", err) |
211 } | 211 } |
212 return b, nil | 212 return b, nil |
213 } | 213 } |
OLD | NEW |