Add dameng support #2007

Merged
lunny merged 59 commits from lunny/dm into master 2021-08-24 05:46:09 +00:00
3 changed files with 8 additions and 7 deletions
Showing only changes of commit c636c4fe4a - Show all commits

View File

@ -283,11 +283,9 @@ func Assign(dest, src interface{}, originalLocation *time.Location, convertedLoc
} }
} }
var sv reflect.Value
switch d := dest.(type) { switch d := dest.(type) {
case *string: case *string:
sv = reflect.ValueOf(src) var sv = reflect.ValueOf(src)
switch sv.Kind() { switch sv.Kind() {
case reflect.Bool, case reflect.Bool,
reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64, reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64,

View File

@ -1163,9 +1163,12 @@ func (d *damengDriver) Scan(ctx *ScanContext, rows *core.Rows, types []*sql.Colu
} }
s := ns.String s := ns.String
fields := strings.Split(s, "+") fields := strings.Split(s, "+")
return convert.Assign(vv[i], strings.Replace(fields[0], "T", " ", -1), ctx.DBLocation, ctx.UserLocation) if err := convert.Assign(vv[i], strings.Replace(fields[0], "T", " ", -1), ctx.DBLocation, ctx.UserLocation); err != nil {
return err
}
default:
return fmt.Errorf("don't support convert %T to %T", t, vv[i])
} }
return fmt.Errorf("don't support convert %T to %T", t, vv[i])
} }
} }
} }

View File

@ -192,8 +192,8 @@ func TestInsertDefault(t *testing.T) {
assert.NoError(t, err) assert.NoError(t, err)
assert.True(t, has) assert.True(t, has)
assert.EqualValues(t, -1, di.Status) assert.EqualValues(t, -1, di.Status)
assert.EqualValues(t, di2.Updated.Unix(), di.Updated.Unix()) assert.EqualValues(t, di2.Updated.Unix(), di.Updated.Unix(), di.Updated)
assert.EqualValues(t, di2.Created.Unix(), di.Created.Unix()) assert.EqualValues(t, di2.Created.Unix(), di.Created.Unix(), di.Created)
} }
func TestInsertDefault2(t *testing.T) { func TestInsertDefault2(t *testing.T) {