CosmosDBClientSingleton.cs 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. using Microsoft.Azure.Documents.Client;
  2. using System;
  3. namespace TEAMModelOS.SDK.Module.AzureCosmosDB.Configuration
  4. {
  5. public sealed class CosmosDBClientSingleton
  6. {
  7. private static string _connectionUrl;
  8. private static string _connectionKey;
  9. private DocumentClient CosmosClient;
  10. private CosmosDBClientSingleton() { }
  11. public DocumentClient GetCosmosDBClient()
  12. {
  13. if (CosmosClient != null)
  14. {
  15. return CosmosClient;
  16. }
  17. else
  18. {
  19. getInstance(_connectionUrl, _connectionKey);
  20. return CosmosClient;
  21. }
  22. }
  23. public static CosmosDBClientSingleton getInstance(string connectionUrl, string connectionKey)
  24. {
  25. _connectionUrl = connectionUrl;
  26. _connectionKey = connectionKey;
  27. return SingletonInstance.instance;
  28. }
  29. private static class SingletonInstance
  30. {
  31. public static CosmosDBClientSingleton instance = new CosmosDBClientSingleton()
  32. {
  33. CosmosClient = new DocumentClient(new Uri(_connectionUrl), _connectionKey, ConnectionPolicy)
  34. };
  35. private static readonly ConnectionPolicy ConnectionPolicy = new ConnectionPolicy
  36. {
  37. ConnectionMode = ConnectionMode.Direct,
  38. ConnectionProtocol = Protocol.Tcp
  39. };
  40. }
  41. }
  42. }