You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@trafficcontrol.apache.org by da...@apache.org on 2018/02/22 23:10:06 UTC
[incubator-trafficcontrol] 08/10: cleanup; fix column mappings
This is an automated email from the ASF dual-hosted git repository.
dangogh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-trafficcontrol.git
commit a5fdba4342339933e9a11f17d6b4ce39817587e9
Author: Dan Kirkwood <da...@apache.org>
AuthorDate: Thu Feb 22 14:35:21 2018 -0700
cleanup; fix column mappings
---
traffic_ops/traffic_ops_golang/region/regions.go | 40 +++++++++++-------------
1 file changed, 19 insertions(+), 21 deletions(-)
diff --git a/traffic_ops/traffic_ops_golang/region/regions.go b/traffic_ops/traffic_ops_golang/region/regions.go
index 1454d59..fae8258 100644
--- a/traffic_ops/traffic_ops_golang/region/regions.go
+++ b/traffic_ops/traffic_ops_golang/region/regions.go
@@ -73,9 +73,9 @@ func (region *TORegion) Read(db *sqlx.DB, parameters map[string]string, user aut
// Query Parameters to Database Query column mappings
// see the fields mapped in the SQL query
queryParamsToQueryCols := map[string]dbhelpers.WhereColumnInfo{
- "name": dbhelpers.WhereColumnInfo{"name", nil},
- "division": dbhelpers.WhereColumnInfo{"division", nil},
- "id": dbhelpers.WhereColumnInfo{"id", api.IsInt},
+ "name": dbhelpers.WhereColumnInfo{"r.name", nil},
+ "division": dbhelpers.WhereColumnInfo{"r.division", nil},
+ "id": dbhelpers.WhereColumnInfo{"r.id", api.IsInt},
}
where, orderBy, queryValues, errs := dbhelpers.BuildWhereAndOrderBy(parameters, queryParamsToQueryCols)
if len(errs) > 0 {
@@ -92,17 +92,17 @@ func (region *TORegion) Read(db *sqlx.DB, parameters map[string]string, user aut
}
defer rows.Close()
- Regions := []interface{}{}
+ regions := []interface{}{}
for rows.Next() {
var s tc.Region
if err = rows.StructScan(&s); err != nil {
log.Errorf("error parsing Region rows: %v", err)
return nil, []error{tc.DBError}, tc.SystemError
}
- Regions = append(Regions, s)
+ regions = append(regions, s)
}
- return Regions, []error{}, tc.NoError
+ return regions, []error{}, tc.NoError
}
func selectQuery() string {
@@ -149,10 +149,9 @@ func (region *TORegion) Update(db *sqlx.DB, user auth.CurrentUser) (error, tc.Ap
return errors.New("a region with " + err.Error()), eType
}
return err, eType
- } else {
- log.Errorf("received error: %++v from update execution", err)
- return tc.DBError, tc.SystemError
}
+ log.Errorf("received error: %++v from update execution", err)
+ return tc.DBError, tc.SystemError
}
defer resultRows.Close()
@@ -170,9 +169,8 @@ func (region *TORegion) Update(db *sqlx.DB, user auth.CurrentUser) (error, tc.Ap
if rowsAffected != 1 {
if rowsAffected < 1 {
return errors.New("no region found with this id"), tc.DataMissingError
- } else {
- return fmt.Errorf("this update affected too many rows: %d", rowsAffected), tc.SystemError
}
+ return fmt.Errorf("this update affected too many rows: %d", rowsAffected), tc.SystemError
}
err = tx.Commit()
if err != nil {
@@ -215,10 +213,9 @@ func (region *TORegion) Insert(db *sqlx.DB, user auth.CurrentUser) (error, tc.Ap
return errors.New("a region with " + err.Error()), eType
}
return err, eType
- } else {
- log.Errorf("received non pq error: %++v from create execution", err)
- return tc.DBError, tc.SystemError
}
+ log.Errorf("received non pq error: %++v from create execution", err)
+ return tc.DBError, tc.SystemError
}
defer resultRows.Close()
@@ -236,7 +233,8 @@ func (region *TORegion) Insert(db *sqlx.DB, user auth.CurrentUser) (error, tc.Ap
err = errors.New("no region was inserted, no id was returned")
log.Errorln(err)
return tc.DBError, tc.SystemError
- } else if rowsAffected > 1 {
+ }
+ if rowsAffected > 1 {
err = errors.New("too many ids returned from region insert")
log.Errorln(err)
return tc.DBError, tc.SystemError
@@ -281,13 +279,13 @@ func (region *TORegion) Delete(db *sqlx.DB, user auth.CurrentUser) (error, tc.Ap
if err != nil {
return tc.DBError, tc.SystemError
}
- if rowsAffected != 1 {
- if rowsAffected < 1 {
- return errors.New("no region with that id found"), tc.DataMissingError
- } else {
- return fmt.Errorf("this create affected too many rows: %d", rowsAffected), tc.SystemError
- }
+ if rowsAffected < 1 {
+ return errors.New("no region with that id found"), tc.DataMissingError
}
+ if rowsAffected > 1 {
+ return fmt.Errorf("this create affected too many rows: %d", rowsAffected), tc.SystemError
+ }
+
err = tx.Commit()
if err != nil {
log.Errorln("Could not commit transaction: ", err)
--
To stop receiving notification emails like this one, please contact
dangogh@apache.org.