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 <dang...@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
dang...@apache.org.

Reply via email to