Fix mock preload many2many generating empty relation rows

This commit is contained in:
Ian Tan 2017-11-22 20:53:49 +08:00
parent 8cf623a01f
commit c2a28c63c3
3 changed files with 36 additions and 5 deletions

View File

@ -60,6 +60,7 @@ func preloadCallback(scope *Scope) {
currentScope.handleBelongsToPreload(field, currentPreloadConditions) currentScope.handleBelongsToPreload(field, currentPreloadConditions)
case "many_to_many": case "many_to_many":
currentScope.handleManyToManyPreload(field, currentPreloadConditions) currentScope.handleManyToManyPreload(field, currentPreloadConditions)
default: default:
scope.Err(errors.New("unsupported relation")) scope.Err(errors.New("unsupported relation"))
} }
@ -264,6 +265,8 @@ func (scope *Scope) handleBelongsToPreload(field *Field, conditions []interface{
// handleManyToManyPreload used to preload many to many associations // handleManyToManyPreload used to preload many to many associations
func (scope *Scope) handleManyToManyPreload(field *Field, conditions []interface{}) { func (scope *Scope) handleManyToManyPreload(field *Field, conditions []interface{}) {
// spew.Println("___ENTERING HANDLE MANY TO MANY___\r\n")
// spew.Printf("___POPULATING %s___:\r\n%s\r\n", field.Name, spew.Sdump(field))
var ( var (
relation = field.Relationship relation = field.Relationship
joinTableHandler = relation.JoinTableHandler joinTableHandler = relation.JoinTableHandler
@ -303,6 +306,7 @@ func (scope *Scope) handleManyToManyPreload(field *Field, conditions []interface
} }
rows, err := preloadDB.Rows() rows, err := preloadDB.Rows()
// spew.Printf("___RETURNED ROWS___: \r\n%s\r\n", spew.Sdump(rows))
if scope.Err(err) != nil { if scope.Err(err) != nil {
return return
@ -312,6 +316,7 @@ func (scope *Scope) handleManyToManyPreload(field *Field, conditions []interface
columns, _ := rows.Columns() columns, _ := rows.Columns()
for rows.Next() { for rows.Next() {
var ( var (
// This is a Language zero value struct
elem = reflect.New(fieldType).Elem() elem = reflect.New(fieldType).Elem()
fields = scope.New(elem.Addr().Interface()).Fields() fields = scope.New(elem.Addr().Interface()).Fields()
) )
@ -323,6 +328,7 @@ func (scope *Scope) handleManyToManyPreload(field *Field, conditions []interface
} }
scope.scan(rows, columns, append(fields, joinTableFields...)) scope.scan(rows, columns, append(fields, joinTableFields...))
// spew.Printf("___FIELDS___: \r\n%s\r\n", spew.Sdump(fields))
var foreignKeys = make([]interface{}, len(sourceKeys)) var foreignKeys = make([]interface{}, len(sourceKeys))
// generate hashed forkey keys in join table // generate hashed forkey keys in join table
@ -351,12 +357,14 @@ func (scope *Scope) handleManyToManyPreload(field *Field, conditions []interface
foreignFieldNames = []string{} foreignFieldNames = []string{}
) )
// spew.Printf("Foreign fields: %s", spew.Sdump(relation.ForeignFieldNames))
for _, dbName := range relation.ForeignFieldNames { for _, dbName := range relation.ForeignFieldNames {
if field, ok := scope.FieldByName(dbName); ok { if field, ok := scope.FieldByName(dbName); ok {
foreignFieldNames = append(foreignFieldNames, field.Name) foreignFieldNames = append(foreignFieldNames, field.Name)
} }
} }
// spew.Printf("Scope value: %s", spew.Sdump(indirectScopeValue))
if indirectScopeValue.Kind() == reflect.Slice { if indirectScopeValue.Kind() == reflect.Slice {
for j := 0; j < indirectScopeValue.Len(); j++ { for j := 0; j < indirectScopeValue.Len(); j++ {
object := indirect(indirectScopeValue.Index(j)) object := indirect(indirectScopeValue.Index(j))
@ -367,6 +375,9 @@ func (scope *Scope) handleManyToManyPreload(field *Field, conditions []interface
key := toString(getValueFromFields(indirectScopeValue, foreignFieldNames)) key := toString(getValueFromFields(indirectScopeValue, foreignFieldNames))
fieldsSourceMap[key] = append(fieldsSourceMap[key], indirectScopeValue.FieldByName(field.Name)) fieldsSourceMap[key] = append(fieldsSourceMap[key], indirectScopeValue.FieldByName(field.Name))
} }
// spew.Printf("Field source map: %s", spew.Sdump(fieldsSourceMap))
// spew.Printf("Link hash: %s", spew.Sdump(linkHash))
for source, link := range linkHash { for source, link := range linkHash {
for i, field := range fieldsSourceMap[source] { for i, field := range fieldsSourceMap[source] {
//If not 0 this means Value is a pointer and we already added preloaded models to it //If not 0 this means Value is a pointer and we already added preloaded models to it

View File

@ -5,6 +5,7 @@ import (
"fmt" "fmt"
"reflect" "reflect"
"github.com/davecgh/go-spew/spew"
sqlmock "gopkg.in/DATA-DOG/go-sqlmock.v1" sqlmock "gopkg.in/DATA-DOG/go-sqlmock.v1"
) )
@ -46,6 +47,7 @@ func getRowForFields(fields []*Field) []driver.Value {
} }
concreteVal := value.Interface() concreteVal := value.Interface()
// spew.Printf("%v: %v\r\n", field.Name, concreteVal)
if driver.IsValue(concreteVal) { if driver.IsValue(concreteVal) {
values = append(values, concreteVal) values = append(values, concreteVal)
@ -68,6 +70,12 @@ func getRelationRows(rVal reflect.Value, fieldName string, relation *Relationshi
columns []string columns []string
) )
// we need to check for zero values
if reflect.DeepEqual(rVal.Interface(), reflect.New(rVal.Type()).Elem().Interface()) {
spew.Printf("FOUND EMPTY INTERFACE FOR %s\r\n", fieldName)
return nil, false
}
switch relation.Kind { switch relation.Kind {
case "has_one": case "has_one":
scope := &Scope{Value: rVal.Interface()} scope := &Scope{Value: rVal.Interface()}
@ -94,6 +102,9 @@ func getRelationRows(rVal reflect.Value, fieldName string, relation *Relationshi
columns = append(columns, field.DBName) columns = append(columns, field.DBName)
} }
} }
spew.Printf("___GENERATING ROWS FOR %s___\r\n", fieldName)
spew.Printf("___COLUMNS___:\r\n%s\r\n", spew.Sdump(columns))
columns = append(columns, "user_id", "language_id")
rows = sqlmock.NewRows(columns) rows = sqlmock.NewRows(columns)
@ -102,11 +113,14 @@ func getRelationRows(rVal reflect.Value, fieldName string, relation *Relationshi
for i := 0; i < rVal.Len(); i++ { for i := 0; i < rVal.Len(); i++ {
scope := &Scope{Value: rVal.Index(i).Interface()} scope := &Scope{Value: rVal.Index(i).Interface()}
row := getRowForFields(scope.Fields()) row := getRowForFields(scope.Fields())
row = append(row, 1, 1)
rows = rows.AddRow(row...) rows = rows.AddRow(row...)
} }
return rows, true
} }
return rows, true return nil, false
default: default:
return nil, false return nil, false
} }
@ -163,6 +177,7 @@ func (q *SqlmockQuery) getRowsForOutType(out interface{}) []*sqlmock.Rows {
relationRows, hasRows := getRelationRows(rVal, name, relation) relationRows, hasRows := getRelationRows(rVal, name, relation)
if hasRows { if hasRows {
spew.Printf("___GENERATED ROWS FOR %s___\r\n: %s\r\n", name, spew.Sdump(relationRows))
rowsSet = append(rowsSet, relationRows) rowsSet = append(rowsSet, relationRows)
} }
} }
@ -181,6 +196,7 @@ func (q *SqlmockQuery) Returns(out interface{}) ExpectedQuery {
for i, query := range q.queries { for i, query := range q.queries {
query.WillReturnRows(rows[i]) query.WillReturnRows(rows[i])
spew.Printf("___SET RETURN ROW___: %s", spew.Sdump(rows[i]))
} }
return q return q

View File

@ -5,6 +5,7 @@ import (
"reflect" "reflect"
"testing" "testing"
"github.com/davecgh/go-spew/spew"
"github.com/jinzhu/gorm" "github.com/jinzhu/gorm"
) )
@ -181,7 +182,7 @@ func TestMockPreloadMany2Many(t *testing.T) {
} }
in := User{Id: 1} in := User{Id: 1}
languages := []Language{Language{Name: "ZH"}, Language{Name: "EN"}} languages := []Language{Language{Name: "ZH"}}
out := User{Id: 1, Languages: languages} out := User{Id: 1, Languages: languages}
expect.Preload("Languages").Find(&in).Returns(out) expect.Preload("Languages").Find(&in).Returns(out)
@ -191,7 +192,10 @@ func TestMockPreloadMany2Many(t *testing.T) {
t.Error(err) t.Error(err)
} }
// if !reflect.DeepEqual(in, out) { spew.Printf("______IN______\r\n%s\r\n", spew.Sdump(in))
// t.Error("In and out are not equal") spew.Printf("______OUT______\r\n%s\r\n", spew.Sdump(out))
// }
if !reflect.DeepEqual(in, out) {
t.Error("In and out are not equal")
}
} }