Enable diffs for compressed chunks

Author: Nikita Glukhov

contrib/jsonb_toaster/jsonb_toast_internals.c

@@ -141,6 +141,7 @@ jsonx_toast_make_pointer_compressed_chunks(Oid toasterid,
 struct varlena *
 jsonx_toast_make_pointer_diff(Oid toasterid,
 							  struct varatt_external *toast_pointer,
+							  bool compressed_chunks,
 							  int32 diff_offset, int32 diff_len,
 							  const void *diff_data)
 {
@@ -150,7 +151,10 @@ jsonx_toast_make_pointer_diff(Oid toasterid,
 		TOAST_POINTER_SIZE + offsetof(JsonxPointerDiff, data) + diff_len;
 
 	struct varlena *result =
-		jsonx_toast_make_custom_pointer(toasterid, JSONX_POINTER_DIFF,
+		jsonx_toast_make_custom_pointer(toasterid,
+										compressed_chunks ?
+											JSONX_POINTER_DIFF_COMP :
+											JSONX_POINTER_DIFF,
 										datalen, toast_pointer->va_rawsize, &data);
 
 	SET_VARTAG_EXTERNAL(data, VARTAG_ONDISK);
@@ -169,7 +173,10 @@ jsonxMakeToastPointer(JsonbToastedContainerPointerData *ptr)
 	if (ptr->ntids || ptr->has_diff)
 	{
 		char	   *data;
-		uint32		header = ptr->has_diff ? JSONX_POINTER_DIFF :
+		uint32		header = ptr->has_diff ?
+				(ptr->compressed_chunks ?
+					JSONX_POINTER_DIFF_COMP :
+					JSONX_POINTER_DIFF) :
 			ptr->ntids | (ptr->compressed_tids ?
 						  JSONX_POINTER_DIRECT_TIDS_COMP :
 						  JSONX_POINTER_DIRECT_TIDS);
@@ -209,7 +216,9 @@ jsonxWriteToastPointer(StringInfo buffer, JsonbToastedContainerPointerData *ptr)
 		char		custom_ptr[JSONX_CUSTOM_PTR_HEADER_SIZE];
 		char		toast_ptr[TOAST_POINTER_SIZE];
 		uint32		header = ptr->has_diff ?
-			JSONX_POINTER_DIFF :
+			(ptr->compressed_chunks ?
+				JSONX_POINTER_DIFF_COMP :
+				JSONX_POINTER_DIFF) :
 			ptr->ntids | (ptr->compressed_tids ?
 						  JSONX_POINTER_DIRECT_TIDS_COMP :
 						  JSONX_POINTER_DIRECT_TIDS);
@@ -989,12 +998,16 @@ jsonx_create_fetch_datum_iterator(struct varlena *attr, Oid toasterid,
 	iter->toasterid = toasterid;
 	iter->chunk_tids_inline_size = inline_size;
 
-	if (inline_size <= 0 || type == JSONX_POINTER_DIFF)
+	if (inline_size <= 0 ||
+		type == JSONX_POINTER_DIFF ||
+		type == JSONX_POINTER_DIFF_COMP)
 	{
 		iter->nchunk_tids = 0;
 		iter->chunk_tids = NULL;
 		iter->compressed_chunk_tids = NULL;
-		iter->compressed_chunks = type == JSONX_POINTER_COMPRESSED_CHUNKS;
+		iter->compressed_chunks =
+			type == JSONX_POINTER_COMPRESSED_CHUNKS ||
+			type == JSONX_POINTER_DIFF_COMP;
 	}
 	else
 	{
@@ -1628,7 +1641,8 @@ jsonx_create_detoast_iterator(struct varlena *attr)
 			/* prepare buffer to received decompressed data */
 			iter->buf = create_toast_buffer(toast_pointer.va_rawsize, false);
 
-			if (type == JSONX_POINTER_DIFF)
+			if (type == JSONX_POINTER_DIFF ||
+				type == JSONX_POINTER_DIFF_COMP)
 				iter->orig_buf = create_toast_buffer(toast_pointer.va_rawsize, false);
 			else
 				iter->orig_buf = iter->buf;
@@ -1642,7 +1656,8 @@ jsonx_create_detoast_iterator(struct varlena *attr)
 			iter->buf = iter->orig_buf = iter->fetch_datum_iterator->buf;
 		}
 
-		if (type == JSONX_POINTER_DIFF)
+		if (type == JSONX_POINTER_DIFF ||
+			type == JSONX_POINTER_DIFF_COMP)
 		{
 			JsonxPointerDiff *diff = (JsonxPointerDiff *) inline_data;
 

contrib/jsonb_toaster/jsonb_toaster.c

@@ -2272,6 +2272,7 @@ jsonxSetPathInplace(JsonContainer *jc, int idx,
 				toast_diff = PointerGetDatum(
 					jsonx_toast_make_pointer_diff(jbcptr.toasterid,
 												  &jbcptr.ptr,
+												  jbcptr.compressed_chunks,
 												  diff.offset,
 												  len, val));
 

contrib/jsonb_toaster/jsonb_toaster.h

@@ -23,6 +23,7 @@
 #define JSONX_POINTER_DIRECT_TIDS_COMP		0x30000000
 #define JSONX_POINTER_COMPRESSED_CHUNKS		0x40000000
 #define JSONX_POINTER_DIFF					0x50000000
+#define JSONX_POINTER_DIFF_COMP				0x60000000
 
 #define JSONX_CUSTOM_PTR_HEADER_SIZE		(INTALIGN(VARATT_CUSTOM_SIZE(0)) + sizeof(uint32))
 
@@ -140,6 +141,7 @@ jsonx_toast_make_plain_pointer(Oid toasterid, JsonbContainerHeader *jbc, int len
 
 extern struct varlena *
 jsonx_toast_make_pointer_diff(Oid toasterid, struct varatt_external *ptr,
+							  bool compressed_chunks,
 							  int32 diff_offset, int32 diff_len,
 							  const void *diff_data);