Adding upstream version 1:10.5.12.upstream/1%10.5.12upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 410 insertions, 0 deletions

diff --git a/storage/connect/bsonudf.h b/storage/connect/bsonudf.h
new file mode 100644
index 00000000..0fe37156
--- /dev/null
+++ b/storage/connect/bsonudf.h
@@ -0,0 +1,410 @@
+/******************** tabjson H Declares Source Code File (.H) *******************/
+/*  Name: bsonudf.h   Version 1.0                                                */
+/*                                                                               */
+/*  (C) Copyright to the author Olivier BERTRAND          2020 - 2021            */
+/*                                                                               */
+/*  This file contains the BSON UDF function and class declares.                 */
+/*********************************************************************************/
+#pragma once
+#include "jsonudf.h"
+#include "bson.h"
+
+#if 0
+#define UDF_EXEC_ARGS \
+  UDF_INIT*, UDF_ARGS*, char*, unsigned long*, char*, char*
+
+// BSON size should be equal on Linux and Windows
+#define BMX 255
+typedef struct BSON* PBSON;
+
+/***********************************************************************/
+/*  Structure used to return binary json to Json UDF functions.        */
+/***********************************************************************/
+struct BSON {
+	char    Msg[BMX + 1];
+	char   *Filename;
+	PGLOBAL G;
+	int     Pretty;
+	ulong   Reslen;
+	my_bool Changed;
+	PJSON   Top;
+	PJSON   Jsp;
+	PBSON   Bsp;
+}; // end of struct BSON
+
+PBSON JbinAlloc(PGLOBAL g, UDF_ARGS* args, ulong len, PJSON jsp);
+
+/*********************************************************************************/
+/*  The JSON tree node. Can be an Object or an Array.                     	  	 */
+/*********************************************************************************/
+typedef struct _jnode {
+	PSZ   Key;                    // The key used for object
+	OPVAL Op;                     // Operator used for this node
+	PVAL  CncVal;                 // To cont value used for OP_CNC
+	int   Rank;                   // The rank in array
+	int   Rx;                     // Read row number
+	int   Nx;                     // Next to read row number
+} JNODE, *PJNODE;
+
+/*********************************************************************************/
+/*  The JSON utility functions.                     	  	                       */
+/*********************************************************************************/
+bool    IsNum(PSZ s);
+char   *NextChr(PSZ s, char sep);
+char   *GetJsonNull(void);
+uint    GetJsonGrpSize(void);
+my_bool JsonSubSet(PGLOBAL g, my_bool b = false);
+my_bool CalcLen(UDF_ARGS* args, my_bool obj, unsigned long& reslen,
+	unsigned long& memlen, my_bool mod = false);
+my_bool JsonInit(UDF_INIT* initid, UDF_ARGS* args, char* message, my_bool mbn,
+	unsigned long reslen, unsigned long memlen,
+	unsigned long more = 0);
+my_bool CheckMemory(PGLOBAL g, UDF_INIT* initid, UDF_ARGS* args, uint n,
+	my_bool m, my_bool obj = false, my_bool mod = false);
+PSZ     MakePSZ(PGLOBAL g, UDF_ARGS* args, int i);
+int     IsArgJson(UDF_ARGS* args, uint i);
+char   *GetJsonFile(PGLOBAL g, char* fn);
+
+/*********************************************************************************/
+/*  Structure JPN. Used to make the locate path.                                 */
+/*********************************************************************************/
+typedef struct _jpn {
+	int  Type;
+	PCSZ Key;
+	int  N;
+} JPN, *PJPN;
+
+#endif // 0
+
+/* --------------------------- New Testing BJSON Stuff --------------------------*/
+extern uint JsonGrpSize;
+uint GetJsonGroupSize(void);
+
+
+typedef class BJNX* PBJNX;
+
+/*********************************************************************************/
+/*  Class BJNX: BJSON access methods.                                            */
+/*********************************************************************************/
+class BJNX : public BDOC {
+public:
+	// Constructors
+	BJNX(PGLOBAL g);
+	BJNX(PGLOBAL g, PBVAL row, int type, int len = 64, int prec = 0, my_bool wr = false);
+
+	// Implementation
+	int     GetPrecision(void) { return Prec; }
+	PVAL    GetValue(void) { return Value; }
+	void    SetRow(PBVAL vp) { Row = vp; }
+	void    SetChanged(my_bool b) { Changed = b; }
+
+	// Methods
+	my_bool SetJpath(PGLOBAL g, char* path, my_bool jb = false);
+	my_bool ParseJpath(PGLOBAL g);
+	void    ReadValue(PGLOBAL g);
+	PBVAL   GetRowValue(PGLOBAL g, PBVAL row, int i);
+	PBVAL   GetJson(PGLOBAL g);
+	my_bool CheckPath(PGLOBAL g);
+	my_bool CheckPath(PGLOBAL g, UDF_ARGS* args, PBVAL jsp, PBVAL& jvp, int n);
+	my_bool WriteValue(PGLOBAL g, PBVAL jvalp);
+	my_bool DeleteItem(PGLOBAL g, PBVAL vlp);
+	char   *Locate(PGLOBAL g, PBVAL jsp, PBVAL jvp, int k = 1);
+	char   *LocateAll(PGLOBAL g, PBVAL jsp, PBVAL jvp, int mx = 10);
+	PSZ     MakeKey(UDF_ARGS* args, int i);
+	PBVAL   MakeValue(UDF_ARGS* args, uint i, bool b = false, PBVAL* top = NULL);
+	PBVAL   MakeTypedValue(PGLOBAL g, UDF_ARGS* args, uint i,
+		                     JTYP type, PBVAL* top = NULL);
+	PBVAL   ParseJsonFile(PGLOBAL g, char* fn, int& pty, size_t& len);
+	char   *MakeResult(UDF_ARGS* args, PBVAL top, uint n = 2);
+	PBSON   MakeBinResult(UDF_ARGS* args, PBVAL top, ulong len, int n = 2);
+
+protected:
+	my_bool SetArrayOptions(PGLOBAL g, char* p, int i, PSZ nm);
+	PVAL    GetColumnValue(PGLOBAL g, PBVAL row, int i);
+	PVAL    ExpandArray(PGLOBAL g, PBVAL arp, int n);
+	PVAL    CalculateArray(PGLOBAL g, PBVAL arp, int n);
+	PVAL    GetCalcValue(PGLOBAL g, PBVAL bap, int n);
+	PBVAL   MakeJson(PGLOBAL g, PBVAL bvp, int n);
+	void    SetJsonValue(PGLOBAL g, PVAL vp, PBVAL vlp);
+	PBVAL   GetRow(PGLOBAL g);
+	PBVAL   MoveVal(PBVAL vlp);
+	PBVAL   MoveJson(PBJNX bxp, PBVAL jvp);
+	PBVAL   MoveArray(PBJNX bxp, PBVAL jvp);
+	PBVAL   MoveObject(PBJNX bxp, PBVAL jvp);
+	PBVAL   MoveValue(PBJNX bxp, PBVAL jvp);
+	my_bool CompareValues(PGLOBAL g, PBVAL v1, PBVAL v2);
+	my_bool LocateArray(PGLOBAL g, PBVAL jarp);
+	my_bool LocateObject(PGLOBAL g, PBVAL jobp);
+	my_bool LocateValue(PGLOBAL g, PBVAL jvp);
+	my_bool LocateArrayAll(PGLOBAL g, PBVAL jarp);
+	my_bool LocateObjectAll(PGLOBAL g, PBVAL jobp);
+	my_bool LocateValueAll(PGLOBAL g, PBVAL jvp);
+	my_bool CompareTree(PGLOBAL g, PBVAL jp1, PBVAL jp2);
+	my_bool AddPath(void);
+
+	// Default constructor not to be used
+	BJNX(void) {}
+
+	// Members
+	PBVAL    Row;
+	PBVAL    Bvalp;
+	PJPN     Jpnp;
+	JOUTSTR *Jp;
+	JNODE   *Nodes;               // The intermediate objects
+	PVAL     Value;
+	//PVAL     MulVal;              // To value used by multiple column
+	char    *Jpath;               // The json path
+	int      Buf_Type;
+	int      Long;
+	int      Prec;
+	int      Nod;                 // The number of intermediate objects
+	int      Xnod;                // Index of multiple values
+	int      K;										// Kth item to locate
+	int      I;										// Index of JPN
+	int      Imax;								// Max number of JPN's
+	int      B;										// Index base
+	my_bool  Xpd;                 // True for expandable column
+	my_bool  Parsed;              // True when parsed
+	my_bool  Found;								// Item found by locate
+	my_bool  Wr;			  					// Write mode
+	my_bool  Jb;			  					// Must return json item
+	my_bool  Changed;			  			// True when contains was modified
+}; // end of class BJNX
+
+extern "C" {
+	DllExport my_bool bson_test_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_test(UDF_EXEC_ARGS);
+	DllExport void bson_test_deinit(UDF_INIT*);
+
+	DllExport my_bool bsonvalue_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bsonvalue(UDF_EXEC_ARGS);
+	DllExport void bsonvalue_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_make_array_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_make_array(UDF_EXEC_ARGS);
+	DllExport void bson_make_array_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_array_add_values_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_array_add_values(UDF_EXEC_ARGS);
+	DllExport void bson_array_add_values_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_array_add_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_array_add(UDF_EXEC_ARGS);
+	DllExport void bson_array_add_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_array_delete_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_array_delete(UDF_EXEC_ARGS);
+	DllExport void bson_array_delete_deinit(UDF_INIT*);
+
+	DllExport my_bool bsonlocate_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bsonlocate(UDF_EXEC_ARGS);
+	DllExport void bsonlocate_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_locate_all_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_locate_all(UDF_EXEC_ARGS);
+	DllExport void bson_locate_all_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_contains_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport long long bson_contains(UDF_INIT*, UDF_ARGS*, char*, char*);
+	DllExport void bson_contains_deinit(UDF_INIT*);
+
+	DllExport my_bool bsoncontains_path_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport long long bsoncontains_path(UDF_INIT*, UDF_ARGS*, char*, char*);
+	DllExport void bsoncontains_path_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_make_object_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_make_object(UDF_EXEC_ARGS);
+	DllExport void bson_make_object_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_object_nonull_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_object_nonull(UDF_EXEC_ARGS);
+	DllExport void bson_object_nonull_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_object_key_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_object_key(UDF_EXEC_ARGS);
+	DllExport void bson_object_key_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_object_add_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_object_add(UDF_EXEC_ARGS);
+	DllExport void bson_object_add_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_object_delete_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_object_delete(UDF_EXEC_ARGS);
+	DllExport void bson_object_delete_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_object_list_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_object_list(UDF_EXEC_ARGS);
+	DllExport void bson_object_list_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_object_values_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_object_values(UDF_EXEC_ARGS);
+	DllExport void bson_object_values_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_item_merge_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_item_merge(UDF_EXEC_ARGS);
+	DllExport void bson_item_merge_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_get_item_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bson_get_item(UDF_EXEC_ARGS);
+	DllExport void bson_get_item_deinit(UDF_INIT*);
+
+	DllExport my_bool bsonget_string_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bsonget_string(UDF_EXEC_ARGS);
+	DllExport void bsonget_string_deinit(UDF_INIT*);
+
+	DllExport my_bool bsonget_int_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport long long bsonget_int(UDF_INIT*, UDF_ARGS*, char*, char*);
+	DllExport void bsonget_int_deinit(UDF_INIT*);
+
+	DllExport my_bool bsonget_real_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport double bsonget_real(UDF_INIT*, UDF_ARGS*, char*, char*);
+	DllExport void bsonget_real_deinit(UDF_INIT*);
+
+	DllExport my_bool bsonset_def_prec_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport long long bsonset_def_prec(UDF_INIT*, UDF_ARGS*, char*, char*);
+
+	DllExport my_bool bsonget_def_prec_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport long long bsonget_def_prec(UDF_INIT*, UDF_ARGS*, char*, char*);
+
+	DllExport my_bool bsonset_grp_size_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport long long bsonset_grp_size(UDF_INIT*, UDF_ARGS*, char*, char*);
+
+	DllExport my_bool bsonget_grp_size_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport long long bsonget_grp_size(UDF_INIT*, UDF_ARGS*, char*, char*);
+
+	DllExport my_bool bson_array_grp_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport void bson_array_grp_clear(UDF_INIT *, char *, char *);
+	DllExport void bson_array_grp_add(UDF_INIT *, UDF_ARGS *, char *, char *);
+	DllExport char *bson_array_grp(UDF_EXEC_ARGS);
+	DllExport void bson_array_grp_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_object_grp_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport void bson_object_grp_clear(UDF_INIT *, char *, char *);
+	DllExport void bson_object_grp_add(UDF_INIT *, UDF_ARGS *, char *, char *);
+	DllExport char *bson_object_grp(UDF_EXEC_ARGS);
+	DllExport void bson_object_grp_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_delete_item_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bson_delete_item(UDF_EXEC_ARGS);
+	DllExport void bson_delete_item_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_set_item_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bson_set_item(UDF_EXEC_ARGS);
+	DllExport void bson_set_item_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_insert_item_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bson_insert_item(UDF_EXEC_ARGS);
+	DllExport void bson_insert_item_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_update_item_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bson_update_item(UDF_EXEC_ARGS);
+	DllExport void bson_update_item_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_file_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bson_file(UDF_EXEC_ARGS);
+	DllExport void bson_file_deinit(UDF_INIT*);
+
+	DllExport my_bool bfile_make_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bfile_make(UDF_EXEC_ARGS);
+	DllExport void bfile_make_deinit(UDF_INIT*);
+
+	DllExport my_bool bfile_convert_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bfile_convert(UDF_EXEC_ARGS);
+	DllExport void bfile_convert_deinit(UDF_INIT*);
+
+	DllExport my_bool bfile_bjson_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bfile_bjson(UDF_EXEC_ARGS);
+	DllExport void bfile_bjson_deinit(UDF_INIT*);
+
+	DllExport my_bool bson_serialize_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bson_serialize(UDF_EXEC_ARGS);
+	DllExport void bson_serialize_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_make_array_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bbin_make_array(UDF_EXEC_ARGS);
+	DllExport void bbin_make_array_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_array_add_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bbin_array_add(UDF_EXEC_ARGS);
+	DllExport void bbin_array_add_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_array_add_values_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bbin_array_add_values(UDF_EXEC_ARGS);
+	DllExport void bbin_array_add_values_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_array_delete_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bbin_array_delete(UDF_EXEC_ARGS);
+	DllExport void bbin_array_delete_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_array_grp_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport void bbin_array_grp_clear(UDF_INIT *, char *, char *);
+	DllExport void bbin_array_grp_add(UDF_INIT *, UDF_ARGS *, char *, char *);
+	DllExport char *bbin_array_grp(UDF_EXEC_ARGS);
+	DllExport void bbin_array_grp_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_object_grp_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport void bbin_object_grp_clear(UDF_INIT *, char *, char *);
+	DllExport void bbin_object_grp_add(UDF_INIT *, UDF_ARGS *, char *, char *);
+	DllExport char *bbin_object_grp(UDF_EXEC_ARGS);
+	DllExport void bbin_object_grp_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_make_object_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bbin_make_object(UDF_EXEC_ARGS);
+	DllExport void bbin_make_object_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_object_nonull_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bbin_object_nonull(UDF_EXEC_ARGS);
+	DllExport void bbin_object_nonull_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_object_key_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bbin_object_key(UDF_EXEC_ARGS);
+	DllExport void bbin_object_key_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_object_add_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bbin_object_add(UDF_EXEC_ARGS);
+	DllExport void bbin_object_add_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_object_delete_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bbin_object_delete(UDF_EXEC_ARGS);
+	DllExport void bbin_object_delete_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_object_list_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bbin_object_list(UDF_EXEC_ARGS);
+	DllExport void bbin_object_list_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_object_values_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bbin_object_values(UDF_EXEC_ARGS);
+	DllExport void bbin_object_values_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_get_item_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bbin_get_item(UDF_EXEC_ARGS);
+	DllExport void bbin_get_item_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_item_merge_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bbin_item_merge(UDF_EXEC_ARGS);
+	DllExport void bbin_item_merge_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_set_item_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bbin_set_item(UDF_EXEC_ARGS);
+	DllExport void bbin_set_item_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_insert_item_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bbin_insert_item(UDF_EXEC_ARGS);
+	DllExport void bbin_insert_item_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_update_item_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bbin_update_item(UDF_EXEC_ARGS);
+	DllExport void bbin_update_item_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_delete_item_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bbin_delete_item(UDF_EXEC_ARGS);
+	DllExport void bbin_delete_item_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_locate_all_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char* bbin_locate_all(UDF_EXEC_ARGS);
+	DllExport void bbin_locate_all_deinit(UDF_INIT*);
+
+	DllExport my_bool bbin_file_init(UDF_INIT*, UDF_ARGS*, char*);
+	DllExport char *bbin_file(UDF_EXEC_ARGS);
+	DllExport void bbin_file_deinit(UDF_INIT*);
+} // extern "C"