mirror of
https://github.com/json-iterator/go.git
synced 2024-11-27 08:30:57 +02:00
169 lines
3.5 KiB
Go
169 lines
3.5 KiB
Go
package jsoniter
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"github.com/json-iterator/go/require"
|
|
"testing"
|
|
)
|
|
|
|
func Test_skip_number(t *testing.T) {
|
|
iter := ParseString(ConfigDefault, `[-0.12, "b"]`)
|
|
iter.ReadArray()
|
|
iter.Skip()
|
|
iter.ReadArray()
|
|
if iter.ReadString() != "b" {
|
|
t.FailNow()
|
|
}
|
|
}
|
|
|
|
func Test_skip_null(t *testing.T) {
|
|
iter := ParseString(ConfigDefault, `[null , "b"]`)
|
|
iter.ReadArray()
|
|
iter.Skip()
|
|
iter.ReadArray()
|
|
if iter.ReadString() != "b" {
|
|
t.FailNow()
|
|
}
|
|
}
|
|
|
|
func Test_skip_true(t *testing.T) {
|
|
iter := ParseString(ConfigDefault, `[true , "b"]`)
|
|
iter.ReadArray()
|
|
iter.Skip()
|
|
iter.ReadArray()
|
|
if iter.ReadString() != "b" {
|
|
t.FailNow()
|
|
}
|
|
}
|
|
|
|
func Test_skip_false(t *testing.T) {
|
|
iter := ParseString(ConfigDefault, `[false , "b"]`)
|
|
iter.ReadArray()
|
|
iter.Skip()
|
|
iter.ReadArray()
|
|
if iter.ReadString() != "b" {
|
|
t.FailNow()
|
|
}
|
|
}
|
|
|
|
func Test_skip_array(t *testing.T) {
|
|
iter := ParseString(ConfigDefault, `[[1, [2, [3], 4]], "b"]`)
|
|
iter.ReadArray()
|
|
iter.Skip()
|
|
iter.ReadArray()
|
|
if iter.ReadString() != "b" {
|
|
t.FailNow()
|
|
}
|
|
}
|
|
|
|
func Test_skip_empty_array(t *testing.T) {
|
|
iter := ParseString(ConfigDefault, `[ [ ], "b"]`)
|
|
iter.ReadArray()
|
|
iter.Skip()
|
|
iter.ReadArray()
|
|
if iter.ReadString() != "b" {
|
|
t.FailNow()
|
|
}
|
|
}
|
|
|
|
func Test_skip_nested(t *testing.T) {
|
|
iter := ParseString(ConfigDefault, `[ {"a" : [{"b": "c"}], "d": 102 }, "b"]`)
|
|
iter.ReadArray()
|
|
iter.Skip()
|
|
iter.ReadArray()
|
|
if iter.ReadString() != "b" {
|
|
t.FailNow()
|
|
}
|
|
}
|
|
|
|
func Test_skip_and_return_bytes(t *testing.T) {
|
|
should := require.New(t)
|
|
iter := ParseString(ConfigDefault, `[ {"a" : [{"b": "c"}], "d": 102 }, "b"]`)
|
|
iter.ReadArray()
|
|
skipped := iter.SkipAndReturnBytes()
|
|
should.Equal(`{"a" : [{"b": "c"}], "d": 102 }`, string(skipped))
|
|
}
|
|
|
|
func Test_skip_and_return_bytes_with_reader(t *testing.T) {
|
|
should := require.New(t)
|
|
iter := Parse(ConfigDefault, bytes.NewBufferString(`[ {"a" : [{"b": "c"}], "d": 102 }, "b"]`), 4)
|
|
iter.ReadArray()
|
|
skipped := iter.SkipAndReturnBytes()
|
|
should.Equal(`{"a" : [{"b": "c"}], "d": 102 }`, string(skipped))
|
|
}
|
|
|
|
type TestResp struct {
|
|
Code uint64
|
|
}
|
|
|
|
func Benchmark_jsoniter_skip(b *testing.B) {
|
|
input := []byte(`
|
|
{
|
|
"_shards":{
|
|
"total" : 5,
|
|
"successful" : 5,
|
|
"failed" : 0
|
|
},
|
|
"hits":{
|
|
"total" : 1,
|
|
"hits" : [
|
|
{
|
|
"_index" : "twitter",
|
|
"_type" : "tweet",
|
|
"_id" : "1",
|
|
"_source" : {
|
|
"user" : "kimchy",
|
|
"postDate" : "2009-11-15T14:12:12",
|
|
"message" : "trying out Elasticsearch"
|
|
}
|
|
}
|
|
]
|
|
},
|
|
"code": 200
|
|
}`)
|
|
for n := 0; n < b.N; n++ {
|
|
result := TestResp{}
|
|
iter := ParseBytes(ConfigDefault, input)
|
|
for field := iter.ReadObject(); field != ""; field = iter.ReadObject() {
|
|
switch field {
|
|
case "code":
|
|
result.Code = iter.ReadUint64()
|
|
default:
|
|
iter.Skip()
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
func Benchmark_json_skip(b *testing.B) {
|
|
input := []byte(`
|
|
{
|
|
"_shards":{
|
|
"total" : 5,
|
|
"successful" : 5,
|
|
"failed" : 0
|
|
},
|
|
"hits":{
|
|
"total" : 1,
|
|
"hits" : [
|
|
{
|
|
"_index" : "twitter",
|
|
"_type" : "tweet",
|
|
"_id" : "1",
|
|
"_source" : {
|
|
"user" : "kimchy",
|
|
"postDate" : "2009-11-15T14:12:12",
|
|
"message" : "trying out Elasticsearch"
|
|
}
|
|
}
|
|
]
|
|
},
|
|
"code": 200
|
|
}`)
|
|
for n := 0; n < b.N; n++ {
|
|
result := TestResp{}
|
|
json.Unmarshal(input, &result)
|
|
}
|
|
}
|