mariadb/sql/json_schema_helper.cc
Rucha Deodhar 2a0fcd3757 MDEV-32854: Make JSON_DEPTH_LIMIT unlimited
The initial hard capped limit on the depth was 32. It was implemented using
static arrays of relevant type and size 32.
Hence, to implement unlimited depth, dynamic array on mem_root was
implemented which grows by 3200 as needed. Relevant arrays were replaced
with this dynamic array.
2025-07-22 17:32:21 +05:30

104 lines
3.4 KiB
C++

/* Copyright (c) 2016, 2022, MariaDB Corporation.
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; version 2 of the License.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
#include "mariadb.h"
#include "sql_class.h"
#include "sql_parse.h" // For check_stack_overrun
#include <m_string.h>
#include "json_schema_helper.h"
bool json_key_equals(const char* key, LEX_CSTRING val, int key_len)
{
return (size_t)key_len == val.length && !strncmp(key, val.str, key_len);
}
bool json_assign_type(uint *curr_type, json_engine_t *je)
{
const char* curr_value= (const char*)je->value;
int len= je->value_len;
if (json_key_equals(curr_value, { STRING_WITH_LEN("number") }, len))
*curr_type|= (1 << JSON_VALUE_NUMBER);
else if(json_key_equals(curr_value, { STRING_WITH_LEN("string") }, len))
*curr_type|= (1 << JSON_VALUE_STRING);
else if(json_key_equals(curr_value, { STRING_WITH_LEN("array") }, len))
*curr_type|= (1 << JSON_VALUE_ARRAY);
else if(json_key_equals(curr_value, { STRING_WITH_LEN("object") }, len))
*curr_type|= (1 << JSON_VALUE_OBJECT);
else if (json_key_equals(curr_value, { STRING_WITH_LEN("boolean") }, len))
*curr_type|= ((1 << JSON_VALUE_TRUE) | (1 << JSON_VALUE_FALSE));
else if (json_key_equals(curr_value, { STRING_WITH_LEN("null") }, len))
*curr_type|= (1 << JSON_VALUE_NULL);
else
{
my_error(ER_JSON_INVALID_VALUE_FOR_KEYWORD, MYF(0), "type");
return true;
}
return false;
}
const uchar *get_key_name(const void *key_name_, size_t *length, my_bool)
{
auto key_name= static_cast<const char *>(key_name_);
*length= strlen(key_name);
return reinterpret_cast<const uchar *>(key_name);
}
void json_get_normalized_string(json_engine_t *je, String *res,
int *error, MEM_ROOT *current_mem_root,
json_engine_t *temp_je,
MEM_ROOT_DYNAMIC_ARRAY *stack)
{
char *val_begin= (char*)je->value, *val_end= NULL;
String val("",0,je->s.cs);
DYNAMIC_STRING a_res;
if (init_dynamic_string(&a_res, NULL, 0, 0))
goto error;
if (!json_value_scalar(je))
{
if (json_skip_level(je))
goto error;
}
val_end= json_value_scalar(je) ? val_begin+je->value_len :
(char *)je->s.c_str;
val.set((const char*)val_begin, val_end-val_begin, je->s.cs);
if (je->value_type == JSON_VALUE_NUMBER ||
je->value_type == JSON_VALUE_ARRAY ||
je->value_type == JSON_VALUE_OBJECT)
{
if (json_normalize(&a_res, (const char*)val.ptr(),
val_end-val_begin, je->s.cs, current_mem_root, temp_je, stack))
goto error;
}
else if(je->value_type == JSON_VALUE_STRING)
{
strncpy((char*)a_res.str, val.ptr(), je->value_len);
a_res.length= je->value_len;
}
res->append(a_res.str, a_res.length, je->s.cs);
*error= 0;
error:
dynstr_free(&a_res);
return;
}