aboutsummaryrefslogtreecommitdiff
path: root/weed/query
diff options
context:
space:
mode:
Diffstat (limited to 'weed/query')
-rw-r--r--weed/query/json/query_json.go2
-rw-r--r--weed/query/json/query_json_test.go7
-rw-r--r--weed/query/sqltypes/type.go51
-rw-r--r--weed/query/sqltypes/value.go2
4 files changed, 28 insertions, 34 deletions
diff --git a/weed/query/json/query_json.go b/weed/query/json/query_json.go
index b061df97d..46f3b1b56 100644
--- a/weed/query/json/query_json.go
+++ b/weed/query/json/query_json.go
@@ -26,7 +26,7 @@ func QueryJson(jsonLine string, projections []string, query Query) (passedFilter
return false, nil
}
-func filterJson(jsonLine string, query Query) bool{
+func filterJson(jsonLine string, query Query) bool {
value := gjson.Get(jsonLine, query.Field)
diff --git a/weed/query/json/query_json_test.go b/weed/query/json/query_json_test.go
index 621d4f548..1794bb333 100644
--- a/weed/query/json/query_json_test.go
+++ b/weed/query/json/query_json_test.go
@@ -55,9 +55,9 @@ func TestGjson(t *testing.T) {
`
- projections := []string{"quiz","fruit"}
+ projections := []string{"quiz", "fruit"}
- gjson.ForEachLine(data, func(line gjson.Result) bool{
+ gjson.ForEachLine(data, func(line gjson.Result) bool {
println(line.Raw)
println("+++++++++++")
results := gjson.GetMany(line.Raw, projections...)
@@ -68,8 +68,6 @@ func TestGjson(t *testing.T) {
return true
})
-
-
}
func TestJsonQueryRow(t *testing.T) {
@@ -133,4 +131,3 @@ func TestJsonQueryNumber(t *testing.T) {
println(string(buf))
}
-
diff --git a/weed/query/sqltypes/type.go b/weed/query/sqltypes/type.go
index cfce50a53..f4f3dd471 100644
--- a/weed/query/sqltypes/type.go
+++ b/weed/query/sqltypes/type.go
@@ -73,30 +73,29 @@ func IsTemporal(t Type) bool {
// Vitess data types. These are idiomatically
// named synonyms for the Type values.
const (
- Null = Type_NULL_TYPE
- Int8 = Type_INT8
- Uint8 = Type_UINT8
- Int16 = Type_INT16
- Uint16 = Type_UINT16
- Int32 = Type_INT32
- Uint32 = Type_UINT32
- Int64 = Type_INT64
- Uint64 = Type_UINT64
- Float32 = Type_FLOAT32
- Float64 = Type_FLOAT64
- Timestamp = Type_TIMESTAMP
- Date = Type_DATE
- Time = Type_TIME
- Datetime = Type_DATETIME
- Year = Type_YEAR
- Decimal = Type_DECIMAL
- Text = Type_TEXT
- Blob = Type_BLOB
- VarChar = Type_VARCHAR
- VarBinary = Type_VARBINARY
- Char = Type_CHAR
- Binary = Type_BINARY
- Bit = Type_BIT
- TypeJSON = Type_JSON
+ Null = Type_NULL_TYPE
+ Int8 = Type_INT8
+ Uint8 = Type_UINT8
+ Int16 = Type_INT16
+ Uint16 = Type_UINT16
+ Int32 = Type_INT32
+ Uint32 = Type_UINT32
+ Int64 = Type_INT64
+ Uint64 = Type_UINT64
+ Float32 = Type_FLOAT32
+ Float64 = Type_FLOAT64
+ Timestamp = Type_TIMESTAMP
+ Date = Type_DATE
+ Time = Type_TIME
+ Datetime = Type_DATETIME
+ Year = Type_YEAR
+ Decimal = Type_DECIMAL
+ Text = Type_TEXT
+ Blob = Type_BLOB
+ VarChar = Type_VARCHAR
+ VarBinary = Type_VARBINARY
+ Char = Type_CHAR
+ Binary = Type_BINARY
+ Bit = Type_BIT
+ TypeJSON = Type_JSON
)
-
diff --git a/weed/query/sqltypes/value.go b/weed/query/sqltypes/value.go
index 428755cc3..012de2b45 100644
--- a/weed/query/sqltypes/value.go
+++ b/weed/query/sqltypes/value.go
@@ -19,7 +19,6 @@ type Value struct {
val []byte
}
-
// NewValue builds a Value using typ and val. If the value and typ
// don't match, it returns an error.
func NewValue(typ Type, val []byte) (v Value, err error) {
@@ -62,7 +61,6 @@ func MakeTrusted(typ Type, val []byte) Value {
return Value{typ: typ, val: val}
}
-
// NewInt64 builds an Int64 Value.
func NewInt64(v int64) Value {
return MakeTrusted(Int64, strconv.AppendInt(nil, v, 10))