Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(348)

Side by Side Diff: go/buildbot/db.go

Issue 813443002: Overhaul database package (Closed) Base URL: https://skia.googlesource.com/buildbot@master
Patch Set: Move README Created 6 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698