| 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 |