75 lines
2.1 KiB
C++
75 lines
2.1 KiB
C++
// Copyright (c) Microsoft Corporation.
|
|
// Licensed under the MIT License.
|
|
|
|
#include <azure/data/tables.hpp>
|
|
|
|
#include <cstdio>
|
|
#include <iostream>
|
|
#include <stdexcept>
|
|
#include <thread>
|
|
|
|
using namespace Azure::Data::Tables;
|
|
using namespace Azure::Data::Tables::Models;
|
|
|
|
const std::string TableName = "transactions2";
|
|
|
|
std::string GetConnectionString()
|
|
{
|
|
const static std::string ConnectionString = "";
|
|
|
|
if (!ConnectionString.empty())
|
|
{
|
|
return ConnectionString;
|
|
}
|
|
const static std::string envConnectionString = std::getenv("STANDARD_STORAGE_CONNECTION_STRING");
|
|
if (!envConnectionString.empty())
|
|
{
|
|
return envConnectionString;
|
|
}
|
|
throw std::runtime_error("Cannot find connection string.");
|
|
}
|
|
|
|
int main()
|
|
{
|
|
// Get the service client
|
|
auto tableServiceClient = TableServiceClient::CreateFromConnectionString(GetConnectionString());
|
|
// create table
|
|
tableServiceClient.CreateTable(TableName);
|
|
// get table client from table service client
|
|
auto tableClient = tableServiceClient.GetTableClient(TableName);
|
|
|
|
// Create two table entities
|
|
TableEntity entity;
|
|
TableEntity entity2;
|
|
entity.SetPartitionKey("P1");
|
|
entity.SetRowKey("R1");
|
|
entity.Properties["Name"] = TableEntityProperty("Azure");
|
|
entity.Properties["Product"] = TableEntityProperty("Tables");
|
|
entity2.SetPartitionKey("P1");
|
|
entity2.SetRowKey("R1");
|
|
entity2.Properties["Name"] = TableEntityProperty("Azure2");
|
|
entity2.Properties["Product"] = TableEntityProperty("Tables2");
|
|
|
|
// Create a transaction with two steps
|
|
std::vector<TransactionStep> steps;
|
|
steps.emplace_back(TransactionStep{TransactionActionType::Add, entity});
|
|
steps.emplace_back(TransactionStep{TransactionActionType::Add, entity2});
|
|
|
|
// Submit the transaction
|
|
auto response = tableClient.SubmitTransaction(steps);
|
|
|
|
// Check the response
|
|
if (!response.Value.Error.HasValue())
|
|
{
|
|
std::cout << "Transaction completed successfully." << std::endl;
|
|
}
|
|
else
|
|
{
|
|
std::cout << "Transaction failed with error: " << response.Value.Error.Value().Message
|
|
<< std::endl;
|
|
}
|
|
// delete existing table
|
|
tableServiceClient.DeleteTable(TableName);
|
|
return 0;
|
|
}
|