ClickHouse/programs/disks/CommandRead.cpp

81 lines
2.3 KiB
C++
Raw Normal View History

#pragma once
#include "ICommand.h"
2022-07-20 20:30:16 +00:00
#include <Interpreters/Context.h>
namespace DB
{
namespace ErrorCodes
{
extern const int BAD_ARGUMENTS;
}
class CommandRead : public ICommand
{
public:
CommandRead()
{
command_name = "read";
2022-06-16 17:38:33 +00:00
command_option_description.emplace(createOptionsDescription("Allowed options", getTerminalWidth()));
description = "read File `from_path` to `to_path` or to stdout\nPath should be in format './' or './path' or 'path'";
2022-06-16 17:38:33 +00:00
usage = "read [OPTION]... <FROM_PATH> <TO_PATH>\nor\nread [OPTION]... <FROM_PATH>";
command_option_description->add_options()
("output", po::value<String>(), "set path to file to which we are read")
;
}
void processOptions(
Poco::Util::LayeredConfiguration & config,
po::variables_map & options) const override
{
if (options.count("output"))
config.setString("output", options["output"].as<String>());
}
2022-06-16 17:38:33 +00:00
void execute(
const std::vector<String> & command_arguments,
DB::ContextMutablePtr & global_context,
Poco::Util::LayeredConfiguration & config) override
{
2022-06-16 17:38:33 +00:00
if (command_arguments.size() != 1)
{
printHelpMessage();
throw DB::Exception("Bad Arguments", DB::ErrorCodes::BAD_ARGUMENTS);
}
String disk_name = config.getString("disk", "default");
2022-06-16 17:38:33 +00:00
String path = command_arguments[0];
DiskPtr disk = global_context->getDisk(disk_name);
String full_path = fullPathWithValidate(disk, path);
2022-06-02 18:24:13 +00:00
String path_output = config.getString("output", "");
2022-06-02 18:24:13 +00:00
if (!path_output.empty())
{
2022-06-02 17:58:58 +00:00
String full_path_output = fullPathWithValidate(disk, path_output);
auto in = disk->readFile(full_path);
auto out = disk->writeFile(full_path_output);
copyData(*in, *out);
out->finalize();
return;
}
else
{
2022-06-02 17:58:58 +00:00
auto in = disk->readFile(full_path);
std::unique_ptr<WriteBufferFromFileBase> out = std::make_unique<WriteBufferFromFileDescriptor>(STDOUT_FILENO);
copyData(*in, *out);
}
}
};
}
std::unique_ptr <DB::ICommand> makeCommandRead()
{
return std::make_unique<DB::CommandRead>();
}