handler_db_object_table.cc File Reference

#include "mrs/endpoint/handler/handler_db_object_table.h"
#include <algorithm>
#include <set>
#include <string>
#include <string_view>
#include <tuple>
#include <utility>
#include <vector>
#include "mysql/harness/logging/logging.h"
#include "mysql/harness/string_utils.h"
#include "mysqld_error.h"
#include "helper/container/generic.h"
#include "helper/container/to_string.h"
#include "helper/http/url.h"
#include "helper/json/rapid_json_to_text.h"
#include "helper/json/to_sqlstring.h"
#include "helper/json/to_string.h"
#include "helper/media_detector.h"
#include "helper/mysql_numeric_value.h"
#include "mrs/database/filter_object_generator.h"
#include "mrs/database/helper/object_row_ownership.h"
#include "mrs/database/helper/query_gtid_executed.h"
#include "mrs/database/helper/query_retry_on_ro.h"
#include "mrs/database/json_mapper/select.h"
#include "mrs/database/query_rest_sp_media.h"
#include "mrs/database/query_rest_table.h"
#include "mrs/database/query_rest_table_single_row.h"
#include "mrs/database/query_rest_table_updater.h"
#include "mrs/endpoint/db_schema_endpoint.h"
#include "mrs/endpoint/handler/helper/url_paths.h"
#include "mrs/endpoint/handler/helper/utilities.h"
#include "mrs/endpoint/handler/helper/utils_proto.h"
#include "mrs/endpoint/url_host_endpoint.h"
#include "mrs/http/error.h"
#include "mrs/monitored/gtid_functions.h"
#include "mrs/monitored/query_retry_on_ro.h"
#include "mrs/rest/request_context.h"
#include "mrs/router_observation_entities.h"

Namespaces
namespace	anonymous_namespace{handler_db_object_table.cc}
namespace	mrs
namespace	mrs::endpoint
namespace	mrs::endpoint::handler

Typedefs
using	anonymous_namespace{handler_db_object_table.cc}::JObject = rapidjson::Document::Object
using	anonymous_namespace{handler_db_object_table.cc}::MemberIterator = rapidjson::Document::MemberIterator
using	anonymous_namespace{handler_db_object_table.cc}::UserId = mrs::database::entry::AuthUser::UserId
using	anonymous_namespace{handler_db_object_table.cc}::RowUserOwnership = mrs::database::entry::RowUserOwnership
using	anonymous_namespace{handler_db_object_table.cc}::sqlstring = mysqlrouter::sqlstring
using	anonymous_namespace{handler_db_object_table.cc}::SqlStrings = std::vector< sqlstring >
using	anonymous_namespace{handler_db_object_table.cc}::Url = helper::http::Url
using	anonymous_namespace{handler_db_object_table.cc}::MediaType = helper::MediaType
using	anonymous_namespace{handler_db_object_table.cc}::HeaderAccept = mrs::http::HeaderAccept
using	anonymous_namespace{handler_db_object_table.cc}::Authorization = mrs::rest::Handler::Authorization
using	mrs::endpoint::handler::MysqlCacheManager = collector::MysqlCacheManager
using	mrs::endpoint::handler::MySQLConnection = collector::MySQLConnection
using	mrs::endpoint::handler::MediaType = helper::MediaType

Functions
MediaType	anonymous_namespace{handler_db_object_table.cc}::validate_content_type_encoding (HeaderAccept *accepts)
mysqlrouter::sqlstring	anonymous_namespace{handler_db_object_table.cc}::rest_param_to_sql_value (const mrs::database::entry::Column &col, const std::string &value)
std::string	anonymous_namespace{handler_db_object_table.cc}::get_path_after_object_name (const http::base::Uri &base_uri, const http::base::Uri &requests_uri)
std::string	anonymous_namespace{handler_db_object_table.cc}::get_rest_query_parameter (const http::base::Uri &requests_uri)
mrs::database::PrimaryKeyColumnValues	anonymous_namespace{handler_db_object_table.cc}::get_rest_pk_parameter (std::shared_ptr< mrs::database::entry::Object > object, const ::http::base::Uri &base_uri, const ::http::base::Uri &requests_uri)
mrs::database::entry::RowUserOwnership	anonymous_namespace{handler_db_object_table.cc}::get_user_ownership (const std::string &obj_name, const std::shared_ptr< mrs::database::entry::Object > &obj)
std::vector< std::string >	anonymous_namespace{handler_db_object_table.cc}::regex_path_for_db_object (std::weak_ptr< mrs::endpoint::DbObjectEndpoint > endpoint)
template<typename F >
void	anonymous_namespace{handler_db_object_table.cc}::execute_and_handle_timeout (F fn)