in src/cartservice/src/cartstore/SpannerCartStore.cs [145:170]
public async Task EmptyCartAsync(string userId)
{
Console.WriteLine($"EmptyCartAsync called for userId={userId}");
try
{
using SpannerConnection spannerConnection = new(databaseString);
await Task.Run(() =>
{
var cmd = spannerConnection.CreateDmlCommand(
$"DELETE FROM {TableName} WHERE userId = @userId",
new SpannerParameterCollection
{
{ "userId", SpannerDbType.String }
});
cmd.Parameters["userId"].Value = userId;
return cmd.ExecuteNonQueryAsync();
});
}
catch (Exception ex)
{
throw new RpcException(
new Status(StatusCode.FailedPrecondition, $"Can't access cart storage at {databaseString}. {ex}"));
}
}