test: Adding some logging for emulator testing

test: Adding some logging for emulator testing

test: Special conditioning for emulator

Author: purvavasudeo

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

@@ -185,8 +185,9 @@ public SpannerConnection GetConnection(Logger logger, bool logCommitStats = fals
 
     public async Task<ManagedSession> GetManagedSession()
     {
-        if (_multiplexSession != null)
+        if (_multiplexSession != null && GetEnvironmentVariableOrDefault("SPANNER_EMULATOR_HOST", null) == null)
         {
+            // Only return the same multiplex session if we are NOT testing on the emulator
             return _multiplexSession;
         }
 

apis/Google.Cloud.Spanner.Data/Google.Cloud.Spanner.Data/SessionPoolManager.cs

@@ -49,7 +49,7 @@ static SessionPoolManager()
         /// is specified on construction.
         /// </summary>
         public static SessionPoolManager Default { get; } =
-            new SessionPoolManager(new SessionPoolOptions(), CreateDefaultSpannerSettings(), Logger.DefaultLogger, CreateClientAsync);
+            new SessionPoolManager(new ManagedSessionOptions(), CreateDefaultSpannerSettings(), Logger.DefaultLogger, CreateClientAsync);
 
         private readonly Func<SpannerClientCreationOptions, SpannerSettings, Task<SpannerClient>> _clientFactory;
 
@@ -161,6 +161,7 @@ internal Task<ManagedSession> AcquireManagedSessionAsync(SpannerClientCreationOp
         {
             SessionPoolSegmentKey segmentKey = SessionPoolSegmentKey.Create(dbName).WithDatabaseRole(dbRole);
             GaxPreconditions.CheckNotNull(options, nameof(options));
+            Logger.Warn($"SessionPoolManager AcquireManagedSessionAsync SegmentKey {segmentKey} existing in dictionary {_targetedMuxSessions.ContainsKey((options, segmentKey))}");
             var muxSession = _targetedMuxSessions.GetOrAdd((options, segmentKey), CreateMultiplexSessionAsync());
             return muxSession;