json_utils Namespace Reference

Functions
void	set_value (rapidjson::Value &json_val, const ColumnDescriptor &column_desc, rapidjson::Document::AllocatorType &allocator)
void	get_value (const rapidjson::Value &json_val, ColumnDescriptor &column_desc)
std::string	get_type_as_string (const rapidjson::Value &object)
void	set_value (rapidjson::Value &json_val, const size_t &value, rapidjson::Document::AllocatorType &allocator)
void	get_value (const rapidjson::Value &json_val, size_t &value)
void	set_value (rapidjson::Value &json_val, const int &value, rapidjson::Document::AllocatorType &allocator)
void	get_value (const rapidjson::Value &json_val, int &value)
void	set_value (rapidjson::Value &json_val, const std::string &value, rapidjson::Document::AllocatorType &allocator)
void	get_value (const rapidjson::Value &json_val, std::string &value)
void	set_value (rapidjson::Value &json_val, const int64_t &value, rapidjson::Document::AllocatorType &allocator)
void	get_value (const rapidjson::Value &json_val, int64_t &value)
void	set_value (rapidjson::Value &json_val, const bool &value, rapidjson::Document::AllocatorType &allocator)
void	get_value (const rapidjson::Value &json_val, bool &value)
void	set_value (rapidjson::Value &json_val, const SQLTypes &value, rapidjson::Document::AllocatorType &allocator)
void	get_value (const rapidjson::Value &json_val, SQLTypes &value)
void	set_value (rapidjson::Value &json_val, const EncodingType &value, rapidjson::Document::AllocatorType &allocator)
void	get_value (const rapidjson::Value &json_val, EncodingType &value)
void	set_value (rapidjson::Value &json_obj, const shared::StringDictKey &dict_key, rapidjson::Document::AllocatorType &allocator)
void	get_value (const rapidjson::Value &json_obj, shared::StringDictKey &dict_key)
void	set_value (rapidjson::Value &json_val, const SQLTypeInfo &type_info, rapidjson::Document::AllocatorType &allocator)
void	get_value (const rapidjson::Value &json_val, SQLTypeInfo &type_info)
rapidjson::Document	read_from_file (const std::string &file_path)
void	write_to_file (const rapidjson::Document &document, const std::string &filepath)
std::string	write_to_string (const rapidjson::Document &document)
std::optional< std::string >	get_optional_string_value_from_object (const rapidjson::Value &object, const std::string &key)
template<class T >
void	add_value_to_object (rapidjson::Value &object, const T &value, const std::string &name, rapidjson::Document::AllocatorType &allocator)
template<class T >
void	get_value_from_object (const rapidjson::Value &object, T &value, const std::string &name)
template<typename T , typename MemberFunc >
void	get_value_from_object (const rapidjson::Value &json_val, MemberFunc mem_fn, SQLTypeInfo &type_info, const std::string &key)
template<class T >
void	set_value (rapidjson::Value &json_val, const std::vector< T > &vector_value, rapidjson::Document::AllocatorType &allocator)
template<class T >
void	get_value (const rapidjson::Value &json_val, std::vector< T > &vector_value)
template<class T >
void	set_value (rapidjson::Value &json_val, const std::list< T > &list_value, rapidjson::Document::AllocatorType &allocator)
template<class T >
void	get_value (const rapidjson::Value &json_val, std::list< T > &list_value)
template<class T , class V >
void	set_value (rapidjson::Value &json_val, const std::vector< std::pair< T, V >> &vector_value, rapidjson::Document::AllocatorType &allocator)
template<class T , class V >
void	get_value (const rapidjson::Value &json_val, std::vector< std::pair< T, V >> &vector_value)
template<class T , class V >
void	set_value (rapidjson::Value &json_val, const std::list< std::pair< T, V >> &list_value, rapidjson::Document::AllocatorType &allocator)
template<class T , class V >
void	get_value (const rapidjson::Value &json_val, std::list< std::pair< T, V >> &list_value)
template<class T , class V >
void	set_value (rapidjson::Value &json_val, const std::map< T, V > &map_value, rapidjson::Document::AllocatorType &allocator)
template<class T , class V >
void	get_value (const rapidjson::Value &json_val, std::map< T, V > &map_value)

Function Documentation

template<class T >

void json_utils::add_value_to_object	(	rapidjson::Value &	object,
		const T &	value,
		const std::string &	name,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 255 of file JsonUtils.h.

References CHECK, setup::name, and set_value().

Referenced by foreign_storage::ParquetDataWrapper::getSerializedDataWrapper(), foreign_storage::AbstractTextFileDataWrapper::getSerializedDataWrapper(), foreign_storage::SingleTextFileReader::serialize(), foreign_storage::CompressedFileReader::serialize(), foreign_storage::MultiFileReader::serialize(), AlterTableAlterColumnCommandRecoveryMgr::serializeRecoveryInformation(), foreign_storage::set_value(), and set_value().

                                                                    {
  CHECK(object.IsObject());
  CHECK(!object.HasMember(name)) << "Found unexpected member: " << name;
  rapidjson::Value json_val;
  set_value(json_val, value, allocator);
  rapidjson::Value json_name;
  json_name.SetString(name, allocator);
  object.AddMember(json_name, json_val, allocator);
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::optional< std::string > json_utils::get_optional_string_value_from_object	(	const rapidjson::Value &	object,
		const std::string &	key
	)

Definition at line 232 of file JsonUtils.cpp.

Referenced by foreign_storage::anonymous_namespace{InternalCatalogDataWrapper.cpp}::get_data_sources().

                          {
  if (object.IsObject() && object.HasMember(key) && object[key].IsString()) {
    return object[key].GetString();
  }
  return {};
}

Here is the caller graph for this function:

std::string json_utils::get_type_as_string

(

const rapidjson::Value &

object

)

Definition at line 29 of file JsonUtils.cpp.

                                                           {
  if (object.IsArray()) {
    return "array";
  } else if (object.IsBool()) {
    return "bool";
  } else if (object.IsDouble()) {
    return "double";
  } else if (object.IsFloat()) {
    return "float";
  } else if (object.IsInt64()) {
    return "int64";
  } else if (object.IsInt()) {
    return "int";
  } else if (object.IsNull()) {
    return "null";
  } else if (object.IsNumber()) {
    return "number";
  } else if (object.IsObject()) {
    return "object";
  } else if (object.IsString()) {
    return "string";
  } else if (object.IsUint64()) {
    return "uint64";
  } else if (object.IsUint()) {
    return "uint";
  }
  return "unknown";
}

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		size_t &	value
	)

Definition at line 64 of file JsonUtils.cpp.

References CHECK.

                                                              {
  CHECK(json_val.IsUint64());
  value = json_val.GetUint64();
}

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		int &	value
	)

Definition at line 75 of file JsonUtils.cpp.

References CHECK.

                                                           {
  CHECK(json_val.IsInt());
  value = json_val.GetInt();
}

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		std::string &	value
	)

Definition at line 87 of file JsonUtils.cpp.

References CHECK.

                                                                 {
  CHECK(json_val.IsString());
  value = json_val.GetString();
}

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		int64_t &	value
	)

Definition at line 98 of file JsonUtils.cpp.

References CHECK.

                                                               {
  CHECK(json_val.IsInt64());
  value = json_val.GetInt64();
}

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		bool &	value
	)

Definition at line 110 of file JsonUtils.cpp.

References CHECK.

                                                            {
  CHECK(json_val.IsBool());
  value = json_val.GetBool();
}

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		SQLTypes &	value
	)

Definition at line 122 of file JsonUtils.cpp.

References CHECK.

                                                                {
  CHECK(json_val.IsInt64());
  value = static_cast<SQLTypes>(json_val.GetInt64());
}

template<class T >

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		std::vector< T > &	vector_value
	)

Definition at line 131 of file JsonUtils.h.

References CHECK, CHECK_EQ, get_value(), and heavydb.dtypes::T.

                                                                           {
  CHECK(json_val.IsArray());
  CHECK_EQ(vector_value.size(), size_t(0));
  for (const auto& json_obj : json_val.GetArray()) {
    T val;
    get_value(json_obj, val);
    vector_value.push_back(val);
  }
}

Here is the call graph for this function:

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		EncodingType &	value
	)

Definition at line 134 of file JsonUtils.cpp.

References CHECK.

                                                                    {
  CHECK(json_val.IsInt64());
  value = static_cast<EncodingType>(json_val.GetInt64());
}

void json_utils::get_value	(	const rapidjson::Value &	json_obj,
		shared::StringDictKey &	dict_key
	)

Definition at line 148 of file JsonUtils.cpp.

References CHECK, shared::StringDictKey::db_id, shared::StringDictKey::dict_id, and get_value_from_object().

                                                                              {
  CHECK(json_obj.IsObject());
  get_value_from_object(json_obj, dict_key.db_id, "db_id");
  get_value_from_object(json_obj, dict_key.dict_id, "dict_id");
}

Here is the call graph for this function:

template<class T >

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		std::list< T > &	list_value
	)

Definition at line 155 of file JsonUtils.h.

References CHECK, CHECK_EQ, get_value(), and heavydb.dtypes::T.

                                                                       {
  CHECK(json_val.IsArray());
  CHECK_EQ(list_value.size(), size_t(0));
  for (const auto& json_obj : json_val.GetArray()) {
    T val;
    get_value(json_obj, val);
    list_value.push_back(val);
  }
}

Here is the call graph for this function:

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		SQLTypeInfo &	type_info
	)

Definition at line 175 of file JsonUtils.cpp.

References CHECK, SQLTypeInfo::set_comp_param(), SQLTypeInfo::set_compression(), SQLTypeInfo::set_dimension(), SQLTypeInfo::set_notnull(), SQLTypeInfo::set_scale(), SQLTypeInfo::set_size(), SQLTypeInfo::set_subtype(), SQLTypeInfo::set_type(), and SQLTypeInfo::setStringDictKeySkipCompParamCheck().

                                                                       {
  CHECK(json_val.IsObject());
  get_value_from_object<SQLTypes>(
      json_val, std::mem_fn(&SQLTypeInfo::set_type), type_info, "type");
  get_value_from_object<SQLTypes>(
      json_val, std::mem_fn(&SQLTypeInfo::set_subtype), type_info, "sub_type");
  get_value_from_object<int>(
      json_val, std::mem_fn(&SQLTypeInfo::set_dimension), type_info, "dimension");
  get_value_from_object<int>(
      json_val, std::mem_fn(&SQLTypeInfo::set_scale), type_info, "scale");
  get_value_from_object<bool>(
      json_val, std::mem_fn(&SQLTypeInfo::set_notnull), type_info, "notnull");
  get_value_from_object<EncodingType>(
      json_val, std::mem_fn(&SQLTypeInfo::set_compression), type_info, "compression");
  get_value_from_object<int>(
      json_val, std::mem_fn(&SQLTypeInfo::set_comp_param), type_info, "comp_param");
  get_value_from_object<int>(
      json_val, std::mem_fn(&SQLTypeInfo::set_size), type_info, "size");
  get_value_from_object<shared::StringDictKey>(
      json_val,
      // Deserialize StringDictKey without any checks.
      std::mem_fn(&SQLTypeInfo::setStringDictKeySkipCompParamCheck),
      type_info,
      "string_dict_key");
}

Here is the call graph for this function:

template<class T , class V >

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		std::vector< std::pair< T, V >> &	vector_value
	)

Definition at line 181 of file JsonUtils.h.

References CHECK, CHECK_EQ, get_value_from_object(), and heavydb.dtypes::T.

                                                       {
  CHECK(json_val.IsArray());
  CHECK_EQ(vector_value.size(), size_t(0));
  for (const auto& json_obj : json_val.GetArray()) {
    CHECK(json_obj.IsObject());
    T key;
    V value;
    get_value_from_object(json_obj, key, "key");
    get_value_from_object(json_obj, value, "value");
    vector_value.emplace_back(std::make_pair(key, value));
  }
}

Here is the call graph for this function:

template<class T , class V >

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		std::list< std::pair< T, V >> &	list_value
	)

Definition at line 211 of file JsonUtils.h.

References CHECK, CHECK_EQ, get_value_from_object(), and heavydb.dtypes::T.

                                                                                   {
  CHECK(json_val.IsArray());
  CHECK_EQ(list_value.size(), size_t(0));
  for (const auto& json_obj : json_val.GetArray()) {
    CHECK(json_obj.IsObject());
    T key;
    V value;
    get_value_from_object(json_obj, key, "key");
    get_value_from_object(json_obj, value, "value");
    list_value.emplace_back(std::make_pair(key, value));
  }
}

Here is the call graph for this function:

template<class T , class V >

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		std::map< T, V > &	map_value
	)

Definition at line 240 of file JsonUtils.h.

References CHECK, CHECK_EQ, get_value_from_object(), and heavydb.dtypes::T.

                                                                        {
  CHECK(json_val.IsArray());
  CHECK_EQ(map_value.size(), size_t(0));
  for (const auto& json_obj : json_val.GetArray()) {
    CHECK(json_obj.IsObject());
    T key;
    V value;
    get_value_from_object(json_obj, key, "key");
    get_value_from_object(json_obj, value, "value");
    map_value[key] = value;
  }
}

Here is the call graph for this function:

void json_utils::get_value	(	const rapidjson::Value &	json_val,
		ColumnDescriptor &	column_desc
	)

Definition at line 578 of file AlterColumnRecovery.cpp.

References CHECK, ColumnDescriptor::chunks, ColumnDescriptor::columnId, ColumnDescriptor::columnName, ColumnDescriptor::columnType, ColumnDescriptor::db_id, ColumnDescriptor::default_value, get_value_from_object(), ColumnDescriptor::isDeletedCol, ColumnDescriptor::isGeoPhyCol, ColumnDescriptor::isSystemCol, ColumnDescriptor::isVirtualCol, ColumnDescriptor::sourceName, ColumnDescriptor::tableId, and ColumnDescriptor::virtualExpr.

Referenced by get_value(), and get_value_from_object().

                                                                              {
  CHECK(json_val.IsObject());

  bool has_default_value;
  get_value_from_object(json_val, has_default_value, "has_default_value");
  if (has_default_value) {
    std::string default_value;
    get_value_from_object(json_val, default_value, "default_value_literal");
    column_desc.default_value = default_value;
  } else {
    column_desc.default_value = std::nullopt;
  }

  get_value_from_object(json_val, column_desc.chunks, "chunks");
  get_value_from_object(json_val, column_desc.columnId, "column_id");
  get_value_from_object(json_val, column_desc.columnName, "column_name");
  get_value_from_object(json_val, column_desc.db_id, "db_id");
  get_value_from_object(json_val, column_desc.isDeletedCol, "is_deleted_col");
  get_value_from_object(json_val, column_desc.isGeoPhyCol, "is_geo_phy_col");
  get_value_from_object(json_val, column_desc.isSystemCol, "is_system_col");
  get_value_from_object(json_val, column_desc.isVirtualCol, "is_virtual_col");
  get_value_from_object(json_val, column_desc.sourceName, "source_name");
  get_value_from_object(json_val, column_desc.tableId, "table_id");
  get_value_from_object(json_val, column_desc.virtualExpr, "virtual_expr");
  get_value_from_object(json_val, column_desc.columnType, "column_type");
}

Here is the call graph for this function:

Here is the caller graph for this function:

template<class T >

void json_utils::get_value_from_object	(	const rapidjson::Value &	object,
		T &	value,
		const std::string &	name
	)

Definition at line 270 of file JsonUtils.h.

References CHECK, get_value(), and setup::name.

Referenced by foreign_storage::CompressedFileReader::CompressedFileReader(), AlterTableAlterColumnCommandRecoveryMgr::deserializeRecoveryInformation(), foreign_storage::get_value(), get_value(), get_value_from_object(), foreign_storage::MultiFileReader::MultiFileReader(), foreign_storage::ParquetDataWrapper::restoreDataWrapperInternals(), foreign_storage::AbstractTextFileDataWrapper::restoreDataWrapperInternals(), and foreign_storage::SingleTextFileReader::SingleTextFileReader().

                                                  {
  CHECK(object.IsObject());
  CHECK(object.HasMember(name)) << "Could not find member: " << name;
  get_value(object[name], value);
}

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename T , typename MemberFunc >

void json_utils::get_value_from_object	(	const rapidjson::Value &	json_val,
		MemberFunc	mem_fn,
		SQLTypeInfo &	type_info,
		const std::string &	key
	)

Definition at line 105 of file JsonUtils.h.

References get_value_from_object(), and heavydb.dtypes::T.

                                                 {
  T value;
  auto setter = std::bind(mem_fn, &type_info, std::placeholders::_1);
  get_value_from_object(json_val, value, key);
  setter(value);
}

Here is the call graph for this function:

rapidjson::Document json_utils::read_from_file

(

const std::string &

file_path

)

Definition at line 201 of file JsonUtils.cpp.

Referenced by AlterTableAlterColumnCommandRecoveryMgr::deserializeRecoveryInformation(), foreign_storage::ParquetDataWrapper::restoreDataWrapperInternals(), and foreign_storage::AbstractTextFileDataWrapper::restoreDataWrapperInternals().

                                                             {
  std::ifstream ifs(file_path);
  if (!ifs) {
    throw std::runtime_error{"Error trying to open file \"" + file_path +
                             "\". The error was: " + std::strerror(errno)};
  }

  rapidjson::IStreamWrapper isw(ifs);
  rapidjson::Document d;
  d.ParseStream(isw);
  return d;
}

Here is the caller graph for this function:

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const size_t &	value,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 59 of file JsonUtils.cpp.

                                                          {
  json_val.SetUint64(value);
}

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const int &	value,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 69 of file JsonUtils.cpp.

                                                          {
  json_val.SetInt(value);
}

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const std::string &	value,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 80 of file JsonUtils.cpp.

                                                          {
  json_val.SetString(value, allocator);
}

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const int64_t &	value,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 92 of file JsonUtils.cpp.

                                                          {
  json_val.SetInt64(value);
}

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const bool &	value,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 104 of file JsonUtils.cpp.

                                                          {
  json_val.SetBool(value);
}

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const SQLTypes &	value,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 116 of file JsonUtils.cpp.

                                                          {
  json_val.SetInt64(static_cast<int64_t>(value));
}

template<class T >

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const std::vector< T > &	vector_value,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 119 of file JsonUtils.h.

References set_value().

                                                          {
  json_val.SetArray();
  for (const auto& value : vector_value) {
    rapidjson::Value json_obj;
    set_value(json_obj, value, allocator);
    json_val.PushBack(json_obj, allocator);
  }
}

Here is the call graph for this function:

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const EncodingType &	value,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 128 of file JsonUtils.cpp.

                                                          {
  json_val.SetInt64(static_cast<int64_t>(value));
}

void json_utils::set_value	(	rapidjson::Value &	json_obj,
		const shared::StringDictKey &	dict_key,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 140 of file JsonUtils.cpp.

References add_value_to_object(), shared::StringDictKey::db_id, and shared::StringDictKey::dict_id.

                                                          {
  json_obj.SetObject();
  add_value_to_object(json_obj, dict_key.db_id, "db_id", allocator);
  add_value_to_object(json_obj, dict_key.dict_id, "dict_id", allocator);
}

Here is the call graph for this function:

template<class T >

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const std::list< T > &	list_value,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 143 of file JsonUtils.h.

References set_value().

                                                          {
  json_val.SetArray();
  for (const auto& value : list_value) {
    rapidjson::Value json_obj;
    set_value(json_obj, value, allocator);
    json_val.PushBack(json_obj, allocator);
  }
}

Here is the call graph for this function:

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const SQLTypeInfo &	type_info,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 155 of file JsonUtils.cpp.

References add_value_to_object(), SQLTypeInfo::get_comp_param(), SQLTypeInfo::get_compression(), SQLTypeInfo::get_dimension(), SQLTypeInfo::get_notnull(), SQLTypeInfo::get_scale(), SQLTypeInfo::get_size(), SQLTypeInfo::get_subtype(), SQLTypeInfo::get_type(), and SQLTypeInfo::getStringDictKeySkipCompParamCheck().

                                                          {
  json_val.SetObject();
  add_value_to_object(json_val, type_info.get_type(), "type", allocator);
  add_value_to_object(json_val, type_info.get_subtype(), "sub_type", allocator);
  add_value_to_object(json_val, type_info.get_dimension(), "dimension", allocator);
  add_value_to_object(json_val, type_info.get_scale(), "scale", allocator);
  add_value_to_object(json_val, type_info.get_notnull(), "notnull", allocator);
  add_value_to_object(json_val, type_info.get_compression(), "compression", allocator);
  add_value_to_object(json_val, type_info.get_comp_param(), "comp_param", allocator);
  add_value_to_object(json_val, type_info.get_size(), "size", allocator);
  add_value_to_object(json_val,
                      // Serialize StringDictKey without any checks, since the string
                      // dictionary ID may not be set at this point.
                      type_info.getStringDictKeySkipCompParamCheck(),
                      "string_dict_key",
                      allocator);
}

Here is the call graph for this function:

template<class T , class V >

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const std::vector< std::pair< T, V >> &	vector_value,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 167 of file JsonUtils.h.

References add_value_to_object().

                                                          {
  json_val.SetArray();
  for (const auto& pair : vector_value) {
    rapidjson::Value pair_obj;
    pair_obj.SetObject();
    add_value_to_object(pair_obj, pair.first, "key", allocator);
    add_value_to_object(pair_obj, pair.second, "value", allocator);
    json_val.PushBack(pair_obj, allocator);
  }
}

Here is the call graph for this function:

template<class T , class V >

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const std::list< std::pair< T, V >> &	list_value,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 197 of file JsonUtils.h.

References add_value_to_object().

                                                          {
  json_val.SetArray();
  for (const auto& pair : list_value) {
    rapidjson::Value pair_obj;
    pair_obj.SetObject();
    add_value_to_object(pair_obj, pair.first, "key", allocator);
    add_value_to_object(pair_obj, pair.second, "value", allocator);
    json_val.PushBack(pair_obj, allocator);
  }
}

Here is the call graph for this function:

template<class T , class V >

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const std::map< T, V > &	map_value,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 226 of file JsonUtils.h.

References add_value_to_object().

                                                          {
  json_val.SetArray();
  for (const auto& pair : map_value) {
    rapidjson::Value pair_obj;
    pair_obj.SetObject();
    add_value_to_object(pair_obj, pair.first, "key", allocator);
    add_value_to_object(pair_obj, pair.second, "value", allocator);
    json_val.PushBack(pair_obj, allocator);
  }
}

Here is the call graph for this function:

void json_utils::set_value	(	rapidjson::Value &	json_val,
		const ColumnDescriptor &	column_desc,
		rapidjson::Document::AllocatorType &	allocator
	)

Definition at line 552 of file AlterColumnRecovery.cpp.

References add_value_to_object(), ColumnDescriptor::chunks, ColumnDescriptor::columnId, ColumnDescriptor::columnName, ColumnDescriptor::columnType, ColumnDescriptor::db_id, ColumnDescriptor::default_value, ColumnDescriptor::isDeletedCol, ColumnDescriptor::isGeoPhyCol, ColumnDescriptor::isSystemCol, ColumnDescriptor::isVirtualCol, ColumnDescriptor::sourceName, ColumnDescriptor::tableId, and ColumnDescriptor::virtualExpr.

Referenced by add_value_to_object(), and set_value().

                                                          {
  json_val.SetObject();
  auto default_value = column_desc.default_value;
  if (default_value.has_value()) {
    add_value_to_object(json_val, true, "has_default_value", allocator);
    add_value_to_object(
        json_val, default_value.value(), "default_value_literal", allocator);
  } else {
    add_value_to_object(json_val, false, "has_default_value", allocator);
  }
  add_value_to_object(json_val, column_desc.chunks, "chunks", allocator);
  add_value_to_object(json_val, column_desc.columnId, "column_id", allocator);
  add_value_to_object(json_val, column_desc.columnName, "column_name", allocator);
  add_value_to_object(json_val, column_desc.columnType, "column_type", allocator);
  add_value_to_object(json_val, column_desc.db_id, "db_id", allocator);
  add_value_to_object(json_val, column_desc.isDeletedCol, "is_deleted_col", allocator);
  add_value_to_object(json_val, column_desc.isGeoPhyCol, "is_geo_phy_col", allocator);
  add_value_to_object(json_val, column_desc.isSystemCol, "is_system_col", allocator);
  add_value_to_object(json_val, column_desc.isVirtualCol, "is_virtual_col", allocator);
  add_value_to_object(json_val, column_desc.sourceName, "source_name", allocator);
  add_value_to_object(json_val, column_desc.tableId, "table_id", allocator);
  add_value_to_object(json_val, column_desc.virtualExpr, "virtual_expr", allocator);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void json_utils::write_to_file	(	const rapidjson::Document &	document,
		const std::string &	filepath
	)

Definition at line 214 of file JsonUtils.cpp.

                                                                                 {
  std::ofstream ofs(filepath);
  if (!ofs) {
    throw std::runtime_error{"Error trying to create file \"" + filepath +
                             "\". The error was: " + std::strerror(errno)};
  }
  rapidjson::OStreamWrapper osw(ofs);
  rapidjson::Writer<rapidjson::OStreamWrapper> writer(osw);
  document.Accept(writer);
}

std::string json_utils::write_to_string

(

const rapidjson::Document &

document

)

Definition at line 225 of file JsonUtils.cpp.

Referenced by foreign_storage::ParquetDataWrapper::getSerializedDataWrapper(), foreign_storage::AbstractTextFileDataWrapper::getSerializedDataWrapper(), and AlterTableAlterColumnCommandRecoveryMgr::serializeRecoveryInformation().

                                                             {
  rapidjson::StringBuffer buffer;
  rapidjson::Writer<rapidjson::StringBuffer> writer(buffer);
  document.Accept(writer);
  return buffer.GetString();
}

Here is the caller graph for this function: