CosmosDB Implementation

dotnet/DotNetStandardClasses.sln

@@ -224,6 +224,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "GeneXus.OpenTelemetry.AWS.A
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "GeneXus.OpenTelemetry", "src\dotnetcore\Providers\OpenTelemetry\OpenTelemetry\GeneXus.OpenTelemetry.csproj", "{00B1FA38-7D0B-47E4-860C-23490249A4D6}"
 EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DynService.CosmosDB", "src\dotnetcore\DynService\Cosmos\DynService.CosmosDB.csproj", "{52DC6C43-58ED-4310-996B-06E95105F848}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -542,6 +544,10 @@ Global
 		{00B1FA38-7D0B-47E4-860C-23490249A4D6}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{00B1FA38-7D0B-47E4-860C-23490249A4D6}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{00B1FA38-7D0B-47E4-860C-23490249A4D6}.Release|Any CPU.Build.0 = Release|Any CPU
+		{52DC6C43-58ED-4310-996B-06E95105F848}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{52DC6C43-58ED-4310-996B-06E95105F848}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{52DC6C43-58ED-4310-996B-06E95105F848}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{52DC6C43-58ED-4310-996B-06E95105F848}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -650,6 +656,7 @@ Global
 		{27D54041-BDD5-428E-8CA6-C96D519F5451} = {BBE020D4-C0FF-41A9-9EB1-D1EE12CC4BB8}
 		{B5A9DEA7-67EC-49E4-924E-4729C34286EC} = {BBE020D4-C0FF-41A9-9EB1-D1EE12CC4BB8}
 		{00B1FA38-7D0B-47E4-860C-23490249A4D6} = {BBE020D4-C0FF-41A9-9EB1-D1EE12CC4BB8}
+		{52DC6C43-58ED-4310-996B-06E95105F848} = {79C9ECC6-2935-4C43-BF32-94698547F584}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {E18684C9-7D76-45CD-BF24-E3944B7F174C}

dotnet/src/dotnetcommon/DynService.Core/DynServiceCommon.cs

@@ -79,6 +79,19 @@ public Query AddConst(GXType gxType, object parm)
 			mVarValues.Add(new VarValue($":const{ mVarValues.Count + 1 }", gxType, parm));
 			return this;
 		}
+
+		public virtual Query SetKey(string key)
+		{
+			return null;
+		}
+		public virtual Query KeyFilter(string[] filters)
+		{
+			return null;
+		}
+		public virtual Query OrderBy(string index)
+		{
+			return null;
+		}
 	}
 
 	public class VarValue

dotnet/src/dotnetcommon/DynService.Dynamo/DynamoDBConnection.cs

@@ -75,7 +75,6 @@ private void Initialize()
 		{
 			InitializeDBConnection();
 			State = ConnectionState.Executing;
-
 			mDynamoDB = new AmazonDynamoDBClient(mCredentials, mConfig);
 		}
 

dotnet/src/dotnetcommon/DynService.Dynamo/DynamoDBDataStoreHelper.cs

@@ -55,22 +55,6 @@ public object empty(GXType gxtype)
 			}
 		}
 	}
-
-	public static class DynamoFluentExtensions
-	{
-		public static Query OrderBy(this Query dynamoQuery, string index)
-		{
-			return (dynamoQuery as DynamoQuery)?.OrderBy(index);
-		}
-		public static Query SetKey(this Query dynamoQuery, string partitionKey)
-		{
-			return (dynamoQuery as DynamoQuery)?.SetKey(partitionKey);
-		}
-		public static Query KeyFilter(this Query dynamoQuery, string[] filters)
-		{
-			return (dynamoQuery as DynamoQuery)?.KeyFilter(filters);
-		}
-	}
 
 	public class DynamoQuery : Query
 	{
@@ -79,7 +63,7 @@ public class DynamoQuery : Query
 		private const string RANGE_KEY_INDEX = "RangeKey";
 		private static readonly char[] indexTrimChars = new char[] { '(', ')' };
 
-		public DynamoQuery OrderBy(string index)
+		public override Query OrderBy(string index)
 		{
 			if(index.StartsWith("(", StringComparison.InvariantCulture))
 			{
@@ -92,18 +76,17 @@ public DynamoQuery OrderBy(string index)
 		}
 
 		public string PartitionKey { get; private set; }
-		public DynamoQuery SetKey(string partitionKey)
+		public override Query SetKey(string partitionKey)
 		{
 			PartitionKey = partitionKey;
 			return this;
 		}
 		internal IEnumerable<string> KeyFilters { get; set; } = Array.Empty<string>();
-		public DynamoQuery KeyFilter(string[] filters)
+		public override Query KeyFilter(string[] filters)
 		{
 			KeyFilters = filters;
 			return this;
 		}
-
 		public DynamoQuery(DynamoDBDataStoreHelper dataStoreHelper) : base(dataStoreHelper) { }
 	}
 }