| // Copyright 2015 The Vanadium Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style |
| // license that can be found in the LICENSE file. |
| |
| package query_exec |
| |
| import ( |
| "errors" |
| "fmt" |
| "testing" |
| |
| "v.io/syncbase/v23/syncbase/nosql/query_db" |
| "v.io/syncbase/v23/syncbase/nosql/syncql" |
| "v.io/v23" |
| "v.io/v23/context" |
| _ "v.io/x/ref/runtime/factories/generic" |
| "v.io/x/ref/test" |
| ) |
| |
| type mockDB struct { |
| ctx *context.T |
| } |
| |
| func (db *mockDB) GetContext() *context.T { |
| return db.ctx |
| } |
| |
| func init() { |
| var shutdown v23.Shutdown |
| db.ctx, shutdown = test.V23Init() |
| defer shutdown() |
| } |
| |
| func (db *mockDB) GetTable(table string) (query_db.Table, error) { |
| return nil, errors.New(fmt.Sprintf("No such table: %s", table)) |
| } |
| |
| var db mockDB |
| |
| type splitErrorTest struct { |
| err error |
| offset int64 |
| errStr string |
| } |
| |
| func TestSplitError(t *testing.T) { |
| basic := []splitErrorTest{ |
| { |
| syncql.NewErrInvalidSelectField(db.GetContext(), 7), |
| 7, |
| "Select field must be 'k' or 'v[{.<ident>}...]'.", |
| }, |
| { |
| syncql.NewErrTableCantAccess(db.GetContext(), 14, "Bob", errors.New("No such table: Bob")), |
| 14, |
| "Table Bob does not exist (or cannot be accessed): No such table: Bob.", |
| }, |
| } |
| |
| for _, test := range basic { |
| offset, errStr := SplitError(test.err) |
| if offset != test.offset || errStr != test.errStr { |
| t.Errorf("err: %v; got %d:%s, want %d:%s", test.err, offset, errStr, test.offset, test.errStr) |
| } |
| } |
| } |