UpsertEntityAsync throwing error after i migrate from Microsoft.Azure.Cosmos.Table to Azure.Data.Tables

UpsertEntityAsync throwing error after i migrate from Microsoft.Azure.Cosmos.Table to Azure.Data.Tables

tableEntity and entity are different, where tableEntity is a flexible container for the properties of an entity in Azure Table Storage and entity is a variable used in code to represent an instance of a table entity.

As the Azure Data Table doesn't support storing arrays it throws an error. Try with the below code for storing arrays in Azure Data Table. It Converts the array into a JSON string using a serializer JsonSerializer.Serialize, this allows the array to be stored as a single property in Azure Table Storage. Now deserialize using JsonSerializer.Deserialize so the JSON string is deserialized into an array.

class TableStorageArray
{
    private const string storageAccountName = "<accName>";  
    private const string storageAccountKey = "<primaryKey>";  
    private const string tableName = "TableB";

    private async Task InsertOrMergeAsync(TableClient tableClient, Azure.Data.Tables.TableEntity record)
    {
        await tableClient.UpsertEntityAsync(record, TableUpdateMode.Merge);
    }

    private async Task InsertOrMergeAsync(CosmosTable.CloudTable table, CosmosTable.DynamicTableEntity record)
    {
        var operation = CosmosTable.TableOperation.InsertOrMerge(record);
        await table.ExecuteAsync(operation);
    }

    private async Task StorageAsync()
    {
        string connectionString = $"DefaultEndpointsProtocol=https;AccountName={storageAccountName};AccountKey={storageAccountKey};EndpointSuffix=core.windows.net";

        var tableClient = new TableServiceClient(connectionString).GetTableClient(tableName);
        await tableClient.CreateIfNotExistsAsync();

        var storageAccount = CosmosTable.CloudStorageAccount.Parse(connectionString);
        var table = storageAccount.CreateCloudTableClient().GetTableReference(tableName);
        await table.CreateIfNotExistsAsync();

        Console.WriteLine("Table connected or created.");

        var partitionKey = "1";
        var rowKey = "1";
        var arrayField = new[] { "Value1", "Value6", "Value9" };
        var arrayAsJson = JsonSerializer.Serialize(arrayField);

        var recordForTableClient = new Azure.Data.Tables.TableEntity(partitionKey, rowKey)
        {
            { "Name", "Sai Paul" },
            { "ArrayField", arrayAsJson }
        };

        var recordForCloudTable = new CosmosTable.DynamicTableEntity(partitionKey, rowKey)
        {
            Properties = {
                { "Name", new CosmosTable.EntityProperty("Sai Paul") },
                { "ArrayField", new CosmosTable.EntityProperty(arrayAsJson) }
            }
        };

        await InsertOrMergeAsync(tableClient, recordForTableClient);

        await InsertOrMergeAsync(table, recordForCloudTable);

        var retrievedEntity = await tableClient.GetEntityAsync<Azure.Data.Tables.TableEntity>(partitionKey, rowKey);
        string retrievedJson = retrievedEntity.Value.GetString("ArrayField");
        var deserializedArray = JsonSerializer.Deserialize<string[]>(retrievedJson);

        Console.WriteLine("Deserialized Array:");
        foreach (var item in deserializedArray)
        {
            Console.WriteLine(item);
        }
    }

    static async Task Main(string[] args)
    {
        try
        {
            var example = new TableStorageArray();
            await example.StorageAsync();
        }
        catch (Exception ex)
        {
            Console.WriteLine($"Error: {ex.Message}");
        }
    }
}

Output:

Table connected or created.
Deserialized Array:
Value1
Value6
Value9