Method parseArguments

src/TableFunctions/TableFunctionRedis.cpp:76–115

}

void TableFunctionRedis::parseArguments(const ASTPtr & ast_function, ContextPtr context)
{
    const auto & func_args = ast_function->as<ASTFunction &>();
    if (!func_args.arguments)
        throw Exception(ErrorCodes::BAD_ARGUMENTS, "Table function 'redis' must have arguments.");

    ASTs & args = func_args.arguments->children;

    if (args.size() < 3)
        throw Exception(ErrorCodes::BAD_ARGUMENTS, "Bad arguments count when creating Redis table function");

    for (auto & arg : args)
        arg = evaluateConstantExpressionOrIdentifierAsLiteral(arg, context);

    auto parsed_host_port = parseAddress(checkAndGetLiteralArgument<String>(args[0], "host:port"), 6379);
    configuration.host = parsed_host_port.first;
    configuration.port = parsed_host_port.second;

    primary_key = checkAndGetLiteralArgument<String>(args[1], "key");
    structure = checkAndGetLiteralArgument<String>(args[2], "structure");

    if (args.size() > 3)
        configuration.db_index = static_cast<uint32_t>(checkAndGetLiteralArgument<UInt64>(args[3], "db_index"));
    else
        configuration.db_index = DEFAULT_REDIS_DB_INDEX;
    if (args.size() > 4)
        configuration.password = checkAndGetLiteralArgument<String>(args[4], "password");
    else
        configuration.password = DEFAULT_REDIS_PASSWORD;
    if (args.size() > 5)
        configuration.pool_size = static_cast<uint32_t>(checkAndGetLiteralArgument<UInt64>(args[5], "pool_size"));
    else
        configuration.pool_size = DEFAULT_REDIS_POOL_SIZE;

    context->getRemoteHostFilter().checkHostAndPort(configuration.host, toString(configuration.port));

    auto columns = parseColumnsListFromString(structure, context);
    if (!columns.has(primary_key))
        throw Exception(ErrorCodes::BAD_ARGUMENTS, "Bad arguments redis table function structure should contains key.");
}

}