Commitcc253f9

Nikita Glukhov

committed

Add JsonValueUnwrap(), JsonExtractScalar()

1 parentca218ec commitcc253f9Copy full SHA for cc253f9

File tree

+60

-7

lines changed

+60

-7

lines changed

Lines changed: 46 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -104,6 +104,52 @@ JsonValueCopy(JsonValue res, const JsonValue val)`
`104`	`104`	`returnres;`
`105`	`105`	`}`
`106`	`106`
	`107`	`+JsonValue*`
	`108`	`+JsonExtractScalar(JsonContainerjc,JsonValuescalar)`
	`109`	`+{`
	`110`	`+JsonIterator*it;`
	`111`	`+JsonValueval;`
	`112`	`+`
	`113`	`+Assert(JsonContainerIsScalar(jc));`
	`114`	`+`
	`115`	`+it=JsonIteratorInit(jc);`
	`116`	`+`
	`117`	`+if (JsonIteratorNext(&it,&val, false)!=WJB_BEGIN_ARRAY\|\|`
	`118`	`+JsonIteratorNext(&it,scalar, false)!=WJB_ELEM\|\|`
	`119`	`+JsonIteratorNext(&it,&val, false)!=WJB_END_ARRAY)`
	`120`	`+elog(ERROR,"unexpected structure of scalar json container");`
	`121`	`+`
	`122`	`+returnscalar;`
	`123`	`+}`
	`124`	`+`
	`125`	`+constJsonValue*`
	`126`	`+JsonValueUnwrap(constJsonValueval,JsonValuevalbuf)`
	`127`	`+{`
	`128`	`+if (val->type==jbvBinary)`
	`129`	`+{`
	`130`	`+JsonContainer*jc=val->val.binary.data;`
	`131`	`+`
	`132`	`+if (jc->ops==&jsonvContainerOps)`
	`133`	`+{`
	`134`	`+val= (JsonbValue*)jc->data;`
	`135`	`+Assert(val->type!=jbvBinary);`
	`136`	`+}`
	`137`	`+elseif (JsonContainerIsScalar(jc))`
	`138`	`+{`
	`139`	`+val=JsonExtractScalar(jc,valbuf);`
	`140`	`+Assert(IsAJsonbScalar(val));`
	`141`	`+}`
	`142`	`+}`
	`143`	`+`
	`144`	`+if (val->type==jbvArray&&val->val.array.rawScalar)`
	`145`	`+{`
	`146`	`+val=&val->val.array.elems[0];`
	`147`	`+Assert(IsAJsonbScalar(val));`
	`148`	`+}`
	`149`	`+`
	`150`	`+returnval;`
	`151`	`+}`
	`152`	`+`
`107`	`153`	`staticinlineJsonValue*`
`108`	`154`	`jsonFindKeyInObjectInternal(JsonContainerobj,constcharkey,intlen,`
`109`	`155`	`boollast)`

Lines changed: 2 additions & 7 deletions

Original file line number	Diff line number	Diff line change
`@@ -943,15 +943,9 @@ datum_to_jsonb(Datum val, bool is_null, JsonbInState *result,`
`943`	`943`	`?DatumGetJsontP(val)`
`944`	`944`	`:DatumGetJsonbP(val);`
`945`	`945`	`#endif`
`946`		`-JsonbIterator*it;`
`947`		`-`
`948`		`-it=JsonbIteratorInit(&jsonb->root);`
`949`		`-`
`950`	`946`	`if (JB_ROOT_IS_SCALAR(jsonb))`
`951`	`947`	`{`
`952`		`-(void)JsonbIteratorNext(&it,&jb, true);`
`953`		`-Assert(jb.type==jbvArray);`
`954`		`-(void)JsonbIteratorNext(&it,&jb, true);`
	`948`	`+JsonExtractScalar(&jsonb->root,&jb);`
`955`	`949`	`break;`
`956`	`950`	`}`
`957`	`951`
`@@ -963,6 +957,7 @@ datum_to_jsonb(Datum val, bool is_null, JsonbInState *result,`
`963`	`957`	`else`
`964`	`958`	`{`
`965`	`959`	`JsonbIteratorTokentype;`
	`960`	`+JsonbIterator*it=JsonbIteratorInit(&jsonb->root);`
`966`	`961`
`967`	`962`	`while ((type=JsonbIteratorNext(&it,&jb, false))`
`968`	`963`	`!=WJB_DONE)`

Lines changed: 10 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -724,6 +724,16 @@ pushJsonbValueExt(JsonbParseState **pstate, JsonbIteratorToken seq,`
`724`	`724`	`jbval->type!=jbvBinary\|\| !unpackBinary)`
`725`	`725`	`{`
`726`	`726`	`/* drop through */`
	`727`	`+if (jbval&& (seq==WJB_ELEM\|\|seq==WJB_VALUE))`
	`728`	`+jbval=JsonValueUnwrap(jbval,&v);`
	`729`	`+`
	`730`	`+returnpushJsonbValueScalar(pstate,seq,jbval);`
	`731`	`+}`
	`732`	`+`
	`733`	`+if (*pstate&&JsonContainerIsScalar(jbval->val.binary.data))`
	`734`	`+{`
	`735`	`+jbval=JsonExtractScalar(jbval->val.binary.data,&v);`
	`736`	`+Assert(IsAJsonbScalar(jbval));`
`727`	`737`	`returnpushJsonbValueScalar(pstate,seq,jbval);`
`728`	`738`	`}`
`729`	`739`

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -360,7 +360,9 @@ extern JsonValue JsonToJsonValue(Json json, JsonValue *jv);`
`360`	`360`	`externJsonValueJsonValueUnpackBinary(constJsonValuejbv);`
`361`	`361`	`externJsonContainerJsonValueToContainer(constJsonValueval);`
`362`	`362`	`externJsonValueJsonValueCopy(JsonValueres,constJsonValue*val);`
	`363`	`+externconstJsonValueJsonValueUnwrap(constJsonValueval,JsonValue*buf);`
`363`	`364`	`externJsonContainerJsonCopyFlat(JsonContainerflatContainer);`
	`365`	`+externJsonValueJsonExtractScalar(JsonContainerjc,JsonValue*scalar);`
`364`	`366`
`365`	`367`	`externboolJsonbExtractScalar(JsonbContainerjbc,JsonbValueres);`
`366`	`368`	`externconstcharJsonbTypeName(JsonbValuejb);`

Comments

(0)