thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 23:52:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Proper passing of query parameters in initiate multipart upload.

Browse Source
This commit is contained in:
Vladimir Chebotarev 2019-09-19 10:15:59 +00:00
parent 283e09d2a5
commit a88d795f0f
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
dbms/src/IO/WriteBufferFromS3.cpp
View File

@ -90,14 +90,18 @@ WriteBufferFromS3::~WriteBufferFromS3()
void WriteBufferFromS3::initiate()
{
// https://docs.aws.amazon.com/AmazonS3/latest/API/mpUploadInitiate.html
// See https://docs.aws.amazon.com/AmazonS3/latest/API/mpUploadInitiate.html
Poco::Net::HTTPResponse response;
std::unique_ptr<Poco::Net::HTTPRequest> request;
HTTPSessionPtr session;
std::istream * istr = nullptr; /// owned by session
Poco::URI initiate_uri = uri;
initiate_uri.setRawQuery("uploads");
initiate_uri.setQueryParameters(uri.getQueryParameters());
auto params = uri.getQueryParameters();
for (QueryParameters::const_iterator it = params.begin(); it != params.end(); ++it)
{
initiate_uri.addQueryParameter(it->first, it->second);
}
for (int i = 0; i < DEFAULT_S3_MAX_FOLLOW_PUT_REDIRECT; ++i)
{
@ -148,7 +152,7 @@ void WriteBufferFromS3::initiate()
void WriteBufferFromS3::writePart(const String & data)
{
// https://docs.aws.amazon.com/AmazonS3/latest/API/mpUploadUploadPart.html
// See https://docs.aws.amazon.com/AmazonS3/latest/API/mpUploadUploadPart.html
Poco::Net::HTTPResponse response;
std::unique_ptr<Poco::Net::HTTPRequest> request;
HTTPSessionPtr session;
@ -211,7 +215,7 @@ void WriteBufferFromS3::writePart(const String & data)
void WriteBufferFromS3::complete()
{
// https://docs.aws.amazon.com/AmazonS3/latest/API/mpUploadComplete.html
// See https://docs.aws.amazon.com/AmazonS3/latest/API/mpUploadComplete.html
Poco::Net::HTTPResponse response;
std::unique_ptr<Poco::Net::HTTPRequest> request;
HTTPSessionPtr session;