#include <assert.h>
#include <sys/types.h>
#include <cstddef>
#include <cstdint>
#include <memory>
#include <utility>
#include "m_ctype.h"
#include "my_inttypes.h"
#include "my_time.h"
#include "mysql/udf_registration_types.h"
#include "mysql_com.h"
#include "mysql_time.h"
#include "prealloced_array.h"
#include "sql-common/json_path.h"
#include "sql/enum_query_type.h"
#include "sql/field.h"
#include "sql/item.h"
#include "sql/item_cmpfunc.h"
#include "sql/item_func.h"
#include "sql/item_strfunc.h"
#include "sql/mem_root_array.h"
#include "sql/parse_location.h"
#include "sql/psi_memory_key.h"
#include "sql_string.h"

Classes
class	Json_path_cache
	Path cache for JSON functions. More...

struct	Json_path_cache::Path_cell
	Struct that points to a cell in m_paths and tells its status. More...

class	Item_json_func
	Base class for all item functions that a return JSON value. More...

class	Item_func_json_valid
	Represents the JSON function JSON_VALID( <value> ) More...

class	Item_func_json_schema_valid
	Represents the JSON function JSON_SCHEMA_VALID( <json schema>, <json doc> ) More...

class	Item_func_json_schema_validation_report
	Represents the JSON function JSON_SCHEMA_VALIDATION_REPORT( <json schema>, <json doc> ) More...

class	Item_func_json_contains
	Represents the JSON function JSON_CONTAINS() More...

class	Item_func_json_contains_path
	Represents the JSON function JSON_CONTAINS_PATH() More...

class	Item_func_json_type
	Represents the JSON function JSON_TYPE. More...

class	Item_typecast_json
	Represents a "CAST( <value> AS JSON )" coercion. More...

class	Item_func_json_length
	Represents the JSON function JSON_LENGTH() More...

class	Item_func_json_depth
	Represents the JSON function JSON_DEPTH() More...

class	Item_func_json_keys
	Represents the JSON function JSON_KEYS() More...

class	Item_func_json_extract
	Represents the JSON function JSON_EXTRACT() More...

class	Item_func_modify_json_in_path
	Base class for all the functions that take a JSON document as the first argument and one of more pairs of a JSON path and a value to insert into the JSON document, and returns the modified JSON document. More...

class	Item_func_json_array_append
	Represents the JSON function JSON_ARRAY_APPEND() More...

class	Item_func_json_insert
	Represents the JSON function JSON_INSERT() More...

class	Item_func_json_array_insert
	Represents the JSON function JSON_ARRAY_INSERT() More...

class	Item_func_json_set_replace
	Common base class for JSON_SET() and JSON_REPLACE(). More...

class	Item_func_json_set
	Represents the JSON function JSON_SET() More...

class	Item_func_json_replace
	Represents the JSON function JSON_REPLACE() More...

class	Item_func_json_array
	Represents the JSON function JSON_ARRAY() More...

class	Item_func_json_row_object
	Represents the JSON function JSON_OBJECT() More...

class	Item_func_json_search
	Represents the JSON function JSON_SEARCH() More...

class	Item_func_json_remove
	Represents the JSON function JSON_REMOVE() More...

class	Item_func_json_merge_preserve
	Represents the JSON function JSON_MERGE_PRESERVE. More...

class	Item_func_json_merge
	Represents the JSON function JSON_MERGE. More...

class	Item_func_json_merge_patch
	Represents the JSON function JSON_MERGE_PATCH. More...

class	Item_func_json_quote
	Represents the JSON function JSON_QUOTE() More...

class	Item_func_json_unquote
	Represents the JSON function JSON_UNQUOTE() More...

class	Item_func_json_pretty
	Represents the JSON_PRETTY function. More...

class	Item_func_json_storage_size
	Class that represents the function JSON_STORAGE_SIZE. More...

class	Item_func_json_storage_free
	Class that represents the function JSON_STORAGE_FREE. More...

class	Item_func_array_cast
	Class that represents CAST(<expr> AS <type> ARRAY) More...

class	Item_func_json_overlaps

class	Item_func_member_of

class	Item_func_json_value
	Class implementing the JSON_VALUE function. More...

Typedefs
using	Json_dom_ptr = std::unique_ptr< Json_dom >

typedef Prealloced_array< size_t, 16 >	Sorted_index_array

Enumerations
enum	enum_one_or_all_type { ooa_one , ooa_all , ooa_null , ooa_error , ooa_uninitialized }
	For use by JSON_CONTAINS_PATH() and JSON_SEARCH() More...

Functions
bool	sql_scalar_to_json (Item arg, const char calling_function, String value, String tmp, Json_wrapper wr, Json_scalar_holder scalar, bool scalar_string)
	Get a JSON value from an SQL scalar value. More...

bool	json_value (Item arg, Json_wrapper result, bool *has_value)
	Return the JSON value of the argument in a wrapper. More...

bool	get_json_wrapper (Item *args, uint arg_idx, String str, const char func_name, Json_wrapper wrapper)
	Return the JSON value of the argument in a wrapper. More...

bool	get_json_atom_wrapper (Item *args, uint arg_idx, const char calling_function, String value, String tmp, Json_wrapper wr, Json_scalar_holder scalar, bool accept_string)
	Convert Json values or MySQL values to JSON. More...

bool	ensure_utf8mb4 (const String &val, String buf, const char resptr, size_t reslength, bool require_string)
	Check a non-empty val for character set. More...

bool	geometry_to_json (Json_wrapper wr, String swkb, const char calling_function, int max_decimal_digits, bool add_bounding_box, bool add_short_crs_urn, bool add_long_crs_urn, uint32 geometry_srid)
	Turn a GEOMETRY value into a JSON value per the GeoJSON specification revision 1.0. More...

bool	convert_value_to_json (Item item, const char func_name, Json_wrapper *wr)
	Convert a value represented with an Item to a JSON value. More...

bool	get_atom_null_as_null (Item *args, uint arg_idx, const char calling_function, String value, String tmp, Json_wrapper *wr)
	Convert JSON values or MySQL values to JSON. More...

bool	get_json_object_member_name (const THD thd, Item arg_item, String value, String utf8_res, const char *safep, size_t safe_length)
	Gets a JSON object member name from an Item. More...

bool	parse_json (const String &res, Json_dom_ptr *dom, bool require_str_or_json, const JsonParseErrorHandler &error_handler, const JsonDocumentDepthHandler &depth_handler)
	Parse a JSON dom out of an argument to a JSON function. More...

bool	sort_and_remove_dups (const Json_wrapper &orig, Sorted_index_array *v)
	Sort the elements of a JSON array and remove duplicates. More...

bool	save_json_to_field (THD thd, Field field, const Json_wrapper *w, bool no_error)
	Save JSON to a given field. More...

Typedef Documentation

◆ Json_dom_ptr

using Json_dom_ptr = std::unique_ptr<Json_dom>

◆ Sorted_index_array

typedef Prealloced_array<size_t, 16> Sorted_index_array

Enumeration Type Documentation

◆ enum_one_or_all_type

enum enum_one_or_all_type

For use by JSON_CONTAINS_PATH() and JSON_SEARCH()

Enumerator
ooa_one
ooa_all
ooa_null
ooa_error
ooa_uninitialized

Function Documentation

◆ convert_value_to_json()

bool convert_value_to_json	(	Item *	item,
		const char *	func_name,
		Json_wrapper *	wr
	)

Convert a value represented with an Item to a JSON value.

Parameters

[in]	item	the input value, may be any data type
[in]	func_name	for error reporting
[in,out]	wr	the result wrapper for the JSON value

Returns: false if success, true if error

◆ ensure_utf8mb4()

bool ensure_utf8mb4	(	const String &	val,
		String *	buf,
		const char **	resptr,
		size_t *	reslength,
		bool	require_string
	)

Check a non-empty val for character set.

If it has character set my_charset_binary, signal error and return false. Else, try to convert to my_charset_utf8mb4_bin. If this fails, signal error and return true, else return false.

Parameters

[in]	val	the string to be checked
[in,out]	buf	buffer to hold the converted string
[out]	resptr	the resulting, possibly converted string, only set if no error
[out]	reslength	the length of resptr
[in]	require_string	If true, give error messages if binary string. If we see a conversion error (space), we give error notwithstanding this parameter value

Returns: True if the string could not be converted. False on success.

Check a non-empty val for character set.

◆ geometry_to_json()

bool geometry_to_json	(	Json_wrapper *	wr,
		String *	swkb,
		const char *	calling_function,
		int	max_decimal_digits,
		bool	add_bounding_box,
		bool	add_short_crs_urn,
		bool	add_long_crs_urn,
		uint32 *	geometry_srid
	)

Turn a GEOMETRY value into a JSON value per the GeoJSON specification revision 1.0.

This method is implemented in item_geofunc.cc.

Parameters

[in,out]	wr	The wrapper to be stuffed with the JSON value.
[in]	swkb	The source GEOMETRY value.
[in]	calling_function	Name of user-invoked function (for errors)
[in]	max_decimal_digits	See the user documentation for ST_AsGeoJSON.
[in]	add_bounding_box	See the user documentation for ST_AsGeoJSON.
[in]	add_short_crs_urn	See the user documentation for ST_AsGeoJSON.
[in]	add_long_crs_urn	See the user documentation for ST_AsGeoJSON.
[in,out]	geometry_srid	Spatial Reference System Identifier to be filled in.

Returns: false if the conversion succeeds, true otherwise

Turn a GEOMETRY value into a JSON value per the GeoJSON specification revision 1.0.

◆ get_atom_null_as_null()

bool get_atom_null_as_null	(	Item **	args,
		uint	arg_idx,
		const char *	calling_function,
		String *	value,
		String *	tmp,
		Json_wrapper *	wr
	)

Convert JSON values or MySQL values to JSON.

Converts SQL NULL to the JSON null literal.

Parameters

[in]	args	arguments to function
[in]	arg_idx	the index of the argument to process
[in]	calling_function	name of the calling function
[in,out]	value	working area (if the returned Json_wrapper points to a binary value rather than a DOM, this string will end up holding the binary representation, and it must stay alive until the wrapper is destroyed or converted from binary to DOM)
[in,out]	tmp	temporary scratch space for converting strings to the correct charset; only used if accept_string is true and conversion is needed
[in,out]	wr	the result wrapper

Returns: false if we found a value or NULL, true otherwise

◆ get_json_atom_wrapper()

bool get_json_atom_wrapper	(	Item **	args,
		uint	arg_idx,
		const char *	calling_function,
		String *	value,
		String *	tmp,
		Json_wrapper *	wr,
		Json_scalar_holder *	scalar,
		bool	accept_string
	)

Convert Json values or MySQL values to JSON.

Parameters

[in]	args	arguments to function
[in]	arg_idx	the index of the argument to process
[in]	calling_function	name of the calling function
[in,out]	value	working area (if the returned Json_wrapper points to a binary value rather than a DOM, this string will end up holding the binary representation, and it must stay alive until the wrapper is destroyed or converted from binary to DOM)
[in,out]	tmp	temporary scratch space for converting strings to the correct charset; only used if accept_string is true and conversion is needed
[in,out]	wr	the result wrapper
[in,out]	scalar	pointer to pre-allocated memory that can be borrowed by the result wrapper if the result is a scalar. If the pointer is NULL, memory for a scalar result will be allocated on the heap.
[in]	accept_string	if true, accept MySQL strings as JSON strings by converting them to UTF8, else emit an error

Returns: false if we found a value or NULL, true otherwise

◆ get_json_object_member_name()

bool get_json_object_member_name	(	const THD *	thd,
		Item *	arg_item,
		String *	value,
		String *	utf8_res,
		const char **	safep,
		size_t *	safe_length
	)

Gets a JSON object member name from an Item.

An error is raised if the Item evaluates to NULL, or if it cannot be converted to a utf8mb4 string.

Parameters

[in]	thd	THD handle
[in]	arg_item	An argument Item
[out]	value	Where to materialize the arg_item's string value
[out]	utf8_res	Buffer for use by ensure_utf8mb4.
[out]	safep	String pointer after any relevant conversion
[out]	safe_length	Corresponding string length

Returns: true if the Item is not a utf8mb4 string

◆ get_json_wrapper()

bool get_json_wrapper	(	Item **	args,
		uint	arg_idx,
		String *	str,
		const char *	func_name,
		Json_wrapper *	wrapper
	)

Return the JSON value of the argument in a wrapper.

Abstracts whether the value comes from a field or a function or a valid JSON text.

Parameters

[in]	args	the arguments
[in]	arg_idx	the argument index
[out]	str	the string buffer
[in]	func_name	the name of the function we are executing
[out]	wrapper	the JSON value wrapper

Returns: false if we found a value or NULL, true if not.

◆ json_value()

bool json_value	(	Item *	arg,
		Json_wrapper *	result,
		bool *	has_value
	)

Return the JSON value of the argument in a wrapper.

Handles arguments with type JSON, including array objects (which do not report type JSON but rather the type of individual elements).

Does not handle literals. See also get_json_wrapper.

Parameters

[in]	arg	the argument
[in,out]	result	the JSON value wrapper
[out]	has_value	true if argument was handled, false otherwise undefined when error

◆ parse_json()

bool parse_json	(	const String &	res,
		Json_dom_ptr *	dom,
		bool	require_str_or_json,
		const JsonParseErrorHandler &	error_handler,
		const JsonDocumentDepthHandler &	depth_handler
	)

Parse a JSON dom out of an argument to a JSON function.

Parameters

[in]	res	Pointer to string value of arg.
[in,out]	dom	If non-null, we want any text parsed DOM returned at the location pointed to
[in]	require_str_or_json	If true, generate an error if other types used as input
[in]	error_handler	Pointer to a function that should handle reporting of parsing error.
[in]	depth_handler	Pointer to a function that should handle error occurred when depth is exceeded.

Returns: false if the arg parsed as valid JSON, true otherwise

◆ save_json_to_field()

bool save_json_to_field	(	THD *	thd,
		Field *	field,
		const Json_wrapper *	w,
		bool	no_error
	)

Save JSON to a given field.

Value is saved in type-aware manner. Into a JSON-typed column any JSON data could be saved. Into an SQL scalar field only a scalar could be saved. If data being saved isn't scalar or can't be coerced to the target type, an error is returned.

Parameters

thd	Thread handler
field	Field to save data to
w	JSON data to save
no_error	If true, don't raise an error when the value cannot be converted to the target type

Returns: false ok true coercion error occur

◆ sort_and_remove_dups()

bool sort_and_remove_dups	(	const Json_wrapper &	orig,
		Sorted_index_array *	v
	)

Sort the elements of a JSON array and remove duplicates.

Parameters

[in]	orig	the original JSON array
[out]	v	vector that will be filled with the indexes of the array elements in increasing order

Returns: false on success, true on error

◆ sql_scalar_to_json()

bool sql_scalar_to_json	(	Item *	arg,
		const char *	calling_function,
		String *	value,
		String *	tmp,
		Json_wrapper *	wr,
		Json_scalar_holder *	scalar,
		bool	scalar_string
	)

Get a JSON value from an SQL scalar value.

Parameters

[in]	arg	the function argument
[in]	calling_function	the name of the calling function
[in,out]	value	a scratch area
[in,out]	tmp	temporary scratch space for converting strings to the correct charset; only used if accept_string is true and conversion is needed
[out]	wr	the retrieved JSON value
[in,out]	scalar	pointer to pre-allocated memory that can be borrowed by the result wrapper to hold the scalar result. If the pointer is NULL, memory will be allocated on the heap.
[in]	scalar_string	if true, interpret SQL strings as scalar JSON strings. if false, interpret SQL strings as JSON objects. If conversion fails, return the string as a scalar JSON string instead.

Returns: false if we could get a value or NULL, otherwise true

Scalar processing is irrelevant. Geometry types are converted to JSON objects.

Classes

Typedefs

Enumerations

Functions

Typedef Documentation

◆ Json_dom_ptr

◆ Sorted_index_array

Enumeration Type Documentation

◆ enum_one_or_all_type

Function Documentation

◆ convert_value_to_json()

◆ ensure_utf8mb4()

◆ geometry_to_json()

◆ get_atom_null_as_null()

◆ get_json_atom_wrapper()

◆ get_json_object_member_name()

◆ get_json_wrapper()

◆ json_value()

◆ parse_json()

◆ save_json_to_field()

◆ sort_and_remove_dups()

◆ sql_scalar_to_json()