Method WhereTrue

driver/common/tabletypes.go:151–195

(row []interface{})

}

func (t *TableContext) WhereTrue(row []interface{}) (bool, error) {
	var m = make(map[string]interface{})
	for field, idx := range t.WhereCtx.FieldsMap {
		nCols := len(row)
		if idx >= nCols {
			return false, fmt.Errorf("cannot eval 'where' predicate: no enough columns (%v < %v). table %v.%v",
				nCols, idx, t.Table.TableSchema, t.Table.TableName)
		}

		//fmt.Printf("**** type of %v %T\n", field, *values.ValuesPointers[idx])
		rawValue := row[idx]
		var value interface{}
		if rawValue == nil {
			value = rawValue
		} else {
			switch t.Table.OriginalTableColumns.ColumnList()[idx].Type {
			case mysqlconfig.TextColumnType:
				bs, ok := rawValue.([]byte)
				if !ok {
					return false,
						fmt.Errorf("where_predicate. expect []byte for TextColumnType, but got %T. table %v.%v",
							rawValue, t.Table.TableSchema, t.Table.TableName)
				}
				value = string(bs)
			default:
				value = rawValue
			}
		}

		m[field] = value
	}
	ctx := datasource.NewContextSimpleNative(m)
	val, ok := vm.Eval(ctx, t.WhereCtx.Ast)
	if !ok {
		return false, fmt.Errorf("cannot eval 'where' predicate with the row value. %v.%v %v",
			t.Table.TableSchema, t.Table.TableName, t.WhereCtx.Where)
	}
	r, ok := val.Value().(bool)
	if !ok {
		return false, fmt.Errorf("'where' predicate does not eval to bool. %v.%v %v",
			t.Table.TableSchema, t.Table.TableName, t.WhereCtx.Where)
	}

	return r, nil
}

type WhereContext struct {
	Where     string