chore: Add extra condition for emulator tests with concurrent txn

chore: Add extra condition for emulator tests with concurrent txn in ManagedSession

chore: add a lock on test fixture table creation

chore: Emulator changes

chore: Skip paritioned tests on emulator

chore: Will undo this commit

Author: purvavasudeo

apis/Google.Cloud.Spanner.Data/Google.Cloud.Spanner.Data.CommonTesting/SpannerTableFixture.cs

@@ -1,4 +1,4 @@
-// Copyright 2018 Google LLC
+// Copyright 2018 Google LLC
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -29,11 +29,13 @@ public abstract class SpannerTableFixture : SpannerFixtureBase
         public SpannerTableFixture(string tableName)
         {
             TableName = tableName;
+ 
             if (Database.Fresh)
             {
                 Logger.DefaultLogger.Debug($"Creating table {TableName}");
                 CreateTable();
             }
+
             RetryHelpers.ResetStats();
             Logger.DefaultLogger.Debug($"Populating table {TableName}");
             PopulateTable(Database.Fresh);

apis/Google.Cloud.Spanner.Data/Google.Cloud.Spanner.Data.IntegrationTests/PartitionedReadTests.cs

@@ -12,6 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+using Google.Cloud.Spanner.Data.CommonTesting;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -30,6 +31,7 @@ public PartitionedReadTests(PartitionedReadTableFixture fixture) =>
             _fixture = fixture;
 
         [SkippableTheory, CombinatorialData]
+        [Trait(Constants.SupportedOnEmulator, Constants.No)]
         public async Task DistributedReadAsync(bool dataBoostEnabled)
         {
             // TODO: xUnit 3 will allow to set traits to individual data rows, and we should use that instead for consistency.
@@ -53,6 +55,7 @@ public async Task DistributedReadAsync(bool dataBoostEnabled)
         }
 
         [SkippableTheory, CombinatorialData]
+        [Trait(Constants.SupportedOnEmulator, Constants.No)]
         public async Task DistributedQueryAsync(bool dataBoostEnabled)
         {
             // TODO: xUnit 3 will allow to set traits to individual data rows, and we should use that instead for consistency.

apis/Google.Cloud.Spanner.V1/Google.Cloud.Spanner.V1/ManagedSession.cs

@@ -154,12 +154,15 @@ internal bool SessionHasExpired(double intervalInDays = SoftRefreshIntervalInDay
     {
         DateTime currentTime = _clock.GetCurrentDateTimeUtc();
         DateTime? sessionCreateTime = _session?.CreateTime.ToDateTime(); // Inherent conversion into UTC DateTime
-        if (_session == null || _session.Expired || currentTime - sessionCreateTime >= TimeSpan.FromDays(intervalInDays))
+        if (_session == null
+            || _session.Expired
+            || !string.IsNullOrEmpty(Environment.GetEnvironmentVariable("SPANNER_EMULATOR_HOST"))
+            || currentTime - sessionCreateTime >= TimeSpan.FromDays(intervalInDays))
         {
             return true;
         }
 
-        return false;
+        return true;
     }
 
     private async Task CreateOrRefreshSessionsAsync(CancellationToken cancellationToken)