thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-13 09:52:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

Updated creating container using connection string

Browse Source
This commit is contained in:
Smita Kulkarni 2023-06-26 16:35:16 +02:00
parent 56c73cab0d
commit 8dafd66c8d
1 changed files with 24 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/Storages/StorageAzureBlob.cpp
View File

@ -315,7 +315,31 @@ AzureClientPtr StorageAzureBlob::createClient(StorageAzureBlob::Configuration co
if (configuration.is_connection_string) if (configuration.is_connection_string)
{ {
std::unique_ptr<BlobServiceClient> blob_service_client = std::make_unique<BlobServiceClient>(BlobServiceClient::CreateFromConnectionString(configuration.connection_url));
Azure::Storage::Blobs::ListBlobContainersOptions options;
options.Prefix = configuration.container;
options.PageSizeHint = 1;
auto containers_list_response = blob_service_client->ListBlobContainers(options);
auto containers_list = containers_list_response.BlobContainers;
bool container_exists = false;
for (const auto & container : containers_list)
{
if (configuration.container == container.Name)
{
container_exists = true;
break;
}
}
result = std::make_unique<BlobContainerClient>(BlobContainerClient::CreateFromConnectionString(configuration.connection_url, configuration.container)); result = std::make_unique<BlobContainerClient>(BlobContainerClient::CreateFromConnectionString(configuration.connection_url, configuration.container));
if (!container_exists)
{
result->CreateIfNotExists();
}
} }
else else
{ {