HiPoweredDev
/
xorm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #43 from nashtsai/conversion-optimize 

Conversion optimize
This commit is contained in:
lunny 2014-01-01 20:58:40 -08:00
parent 0d15b3549c 4a507f758c
commit befdbb9dba
2 changed files with 37 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
base_test.go
View File

@ -359,7 +359,7 @@ func updateSameMapper(engine *Engine, t *testing.T) {
} }
} }
func testdelete(engine *Engine, t *testing.T) { func testDelete(engine *Engine, t *testing.T) {
user := Userinfo{Uid: 1} user := Userinfo{Uid: 1}
cnt, err := engine.Delete(&user) cnt, err := engine.Delete(&user)
if err != nil { if err != nil {
@ -3788,8 +3788,8 @@ func testAll(engine *Engine, t *testing.T) {
insertTwoTable(engine, t) insertTwoTable(engine, t)
fmt.Println("-------------- update --------------") fmt.Println("-------------- update --------------")
update(engine, t) update(engine, t)
fmt.Println("-------------- testdelete --------------") fmt.Println("-------------- testDelete --------------")
testdelete(engine, t) testDelete(engine, t)
fmt.Println("-------------- get --------------") fmt.Println("-------------- get --------------")
get(engine, t) get(engine, t)
fmt.Println("-------------- cascadeGet --------------") fmt.Println("-------------- cascadeGet --------------")

66
session.go
View File

@ -1473,44 +1473,45 @@ func (session *Session) row2Bean(rows *sql.Rows, fields []string, fieldsCount in
case reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64, reflect.Uint: case reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64, reflect.Uint:
hasAssigned = true hasAssigned = true
fieldValue.SetUint(vv.Uint()) fieldValue.SetUint(vv.Uint())
case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
hasAssigned = true
fieldValue.SetUint(uint64(vv.Int()))
} }
//Currently only support Time type
case reflect.Struct: case reflect.Struct:
if fieldType == reflect.TypeOf(c_TIME_DEFAULT) { if fieldType == reflect.TypeOf(c_TIME_DEFAULT) {
if rawValueType == reflect.TypeOf(c_TIME_DEFAULT) { if rawValueType == reflect.TypeOf(c_TIME_DEFAULT) {
hasAssigned = true hasAssigned = true
fieldValue.Set(rawValue) fieldValue.Set(vv)
}
} else if session.Statement.UseCascade {
table := session.Engine.autoMapType(fieldValue.Type())
if table != nil {
var x int64
if rawValueType.Kind() == reflect.Int64 {
x = vv.Int()
}
if x != 0 {
// !nashtsai! TODO for hasOne relationship, it's preferred to use join query for eager fetch
// however, also need to consider adding a 'lazy' attribute to xorm tag which allow hasOne
// property to be fetched lazily
structInter := reflect.New(fieldValue.Type())
newsession := session.Engine.NewSession()
defer newsession.Close()
has, err := newsession.Id(x).Get(structInter.Interface())
if err != nil {
return err
}
if has {
v := structInter.Elem().Interface()
fieldValue.Set(reflect.ValueOf(v))
} else {
return errors.New("cascade obj is not exist!")
}
}
} else {
session.Engine.LogError("unsupported struct type in Scan: ", fieldValue.Type().String())
} }
} }
// else if session.Statement.UseCascade { // TODO
// table := session.Engine.autoMapType(fieldValue.Type())
// if table != nil {
// x, err := strconv.ParseInt(string(data), 10, 64)
// if err != nil {
// return errors.New("arg " + key + " as int: " + er1r.Error())
// }
// if x != 0 {
// // !nashtsai! TODO for hasOne relationship, it's preferred to use join query for eager fetch
// // however, also need to consider adding a 'lazy' attribute to xorm tag which allow hasOne
// // property to be fetched lazily
// structInter := reflect.New(fieldValue.Type())
// newsession := session.Engine.NewSession()
// defer newsession.Close()
// has, err := newsession.Id(x).Get(structInter.Interface())
// if err != nil {
// return err
// }
// if has {
// v = structInter.Elem().Interface()
// fieldValue.Set(reflect.ValueOf(v))
// } else {
// return errors.New("cascade obj is not exist!")
// }
// }
// } else {
// session.Engine.LogError("unsupported struct type in Scan: ", fieldValue.Type().String())
// }
// }
case reflect.Ptr: case reflect.Ptr:
// !nashtsai! TODO merge duplicated codes above // !nashtsai! TODO merge duplicated codes above
//typeStr := fieldType.String() //typeStr := fieldType.String()
@ -1531,7 +1532,8 @@ func (session *Session) row2Bean(rows *sql.Rows, fields []string, fieldsCount in
case reflect.TypeOf(&c_TIME_DEFAULT): case reflect.TypeOf(&c_TIME_DEFAULT):
if rawValueType == reflect.TypeOf(c_TIME_DEFAULT) { if rawValueType == reflect.TypeOf(c_TIME_DEFAULT) {
hasAssigned = true hasAssigned = true
fieldValue.Set(reflect.ValueOf(&rawValue)) var x time.Time = rawValue.Interface().(time.Time)
fieldValue.Set(reflect.ValueOf(&x))
} }
case reflect.TypeOf(&c_FLOAT64_DEFAULT): case reflect.TypeOf(&c_FLOAT64_DEFAULT):
if rawValueType.Kind() == reflect.Float64 { if rawValueType.Kind() == reflect.Float64 {