Multiple-create: Schema generation

src/Cli.Tests/ModuleInitializer.cs

@@ -31,6 +31,8 @@ public static void Init()
         VerifierSettings.IgnoreMember<RuntimeOptions>(options => options.IsCachingEnabled);
         // Ignore the entity IsCachingEnabled as that's unimportant from a test standpoint.
         VerifierSettings.IgnoreMember<Entity>(entity => entity.IsCachingEnabled);
+        // Ignore the entity IsLinkingEntity as that's unimportant from a test standpoint.
+        VerifierSettings.IgnoreMember<Entity>(entity => entity.IsLinkingEntity);
         // Ignore the UserProvidedTtlOptions. They aren't serialized to our config file, enforced by EntityCacheOptionsConverter.
         VerifierSettings.IgnoreMember<EntityCacheOptions>(cacheOptions => cacheOptions.UserProvidedTtlOptions);
         // Ignore the IsRequestBodyStrict as that's unimportant from a test standpoint.

src/Config/ObjectModel/Entity.cs

@@ -32,6 +32,9 @@ public record Entity
     public Dictionary<string, EntityRelationship>? Relationships { get; init; }
     public EntityCacheOptions? Cache { get; init; }
 
+    [JsonIgnore]
+    public bool IsLinkingEntity { get; init; }
+
     [JsonConstructor]
     public Entity(
         EntitySource Source,
@@ -40,7 +43,8 @@ public Entity(
         EntityPermission[] Permissions,
         Dictionary<string, string>? Mappings,
         Dictionary<string, EntityRelationship>? Relationships,
-        EntityCacheOptions? Cache = null)
+        EntityCacheOptions? Cache = null,
+        bool IsLinkingEntity = false)
     {
         this.Source = Source;
         this.GraphQL = GraphQL;
@@ -49,6 +53,7 @@ public Entity(
         this.Mappings = Mappings;
         this.Relationships = Relationships;
         this.Cache = Cache;
+        this.IsLinkingEntity = IsLinkingEntity;
     }
 
     /// <summary>

src/Core/Parsers/EdmModelBuilder.cs

@@ -47,8 +47,16 @@ private EdmModelBuilder BuildEntityTypes(ISqlMetadataProvider sqlMetadataProvide
             // since we allow for aliases to be used in place of the names of the actual
             // columns of the database object (such as table's columns), we need to
             // account for these potential aliases in our EDM Model.
+            IReadOnlyDictionary<string, Entity> linkingEntities = sqlMetadataProvider.GetLinkingEntities();
             foreach (KeyValuePair<string, DatabaseObject> entityAndDbObject in sqlMetadataProvider.GetEntityNamesAndDbObjects())
             {
+                if (linkingEntities.ContainsKey(entityAndDbObject.Key))
+                {
+                    // No need to create entity types for linking entity because the linking entity is not exposed for REST and GraphQL.
+                    // Hence, there is no possibility of having a `filter` operation against it.
+                    continue;
+                }
+
                 // Do not add stored procedures, which do not have table definitions or conventional columns, to edm model
                 // As of now, no ODataFilterParsing will be supported for stored procedure result sets
                 if (entityAndDbObject.Value.SourceType is not EntitySourceType.StoredProcedure)
@@ -109,12 +117,19 @@ private EdmModelBuilder BuildEntitySets(ISqlMetadataProvider sqlMetadataProvider
 
             // Entity set is a collection of the same entity, if we think of an entity as a row of data
             // that has a key, then an entity set can be thought of as a table made up of those rows.
-            foreach (KeyValuePair<string, DatabaseObject> entityAndDbObject in sqlMetadataProvider.GetEntityNamesAndDbObjects())
+            IReadOnlyDictionary<string, Entity> linkingEntities = sqlMetadataProvider.GetLinkingEntities();
+            foreach ((string entityName, DatabaseObject dbObject) in sqlMetadataProvider.GetEntityNamesAndDbObjects())
             {
-                if (entityAndDbObject.Value.SourceType != EntitySourceType.StoredProcedure)
+                if (linkingEntities.ContainsKey(entityName))
+                {
+                    // No need to create entity set for linking entity.
+                    continue;
+                }
+
+                if (dbObject.SourceType != EntitySourceType.StoredProcedure)
                 {
-                    string entityName = $"{entityAndDbObject.Value.FullName}";
-                    container.AddEntitySet(name: $"{entityAndDbObject.Key}.{entityName}", _entities[$"{entityAndDbObject.Key}.{entityName}"]);
+                    string fullSourceName = $"{dbObject.FullName}";
+                    container.AddEntitySet(name: $"{entityName}.{fullSourceName}", _entities[$"{entityName}.{fullSourceName}"]);
                 }
             }
 

src/Core/Resolvers/CosmosMutationEngine.cs

@@ -104,7 +104,7 @@ public void AuthorizeMutationFields(
             List<string> inputArgumentKeys;
             if (mutationOperation != EntityActionOperation.Delete)
             {
-                inputArgumentKeys = BaseSqlQueryStructure.GetSubArgumentNamesFromGQLMutArguments(MutationBuilder.INPUT_ARGUMENT_NAME, parameters);
+                inputArgumentKeys = BaseSqlQueryStructure.GetSubArgumentNamesFromGQLMutArguments(MutationBuilder.ITEM_INPUT_ARGUMENT_NAME, parameters);
             }
             else
             {
@@ -165,7 +165,7 @@ private static async Task<ItemResponse<JObject>> HandleDeleteAsync(IDictionary<s
 
         private static async Task<ItemResponse<JObject>> HandleCreateAsync(IDictionary<string, object?> queryArgs, Container container)
         {
-            object? item = queryArgs[CreateMutationBuilder.INPUT_ARGUMENT_NAME];
+            object? item = queryArgs[MutationBuilder.ITEM_INPUT_ARGUMENT_NAME];
 
             JObject? input;
             // Variables were provided to the mutation
@@ -212,7 +212,7 @@ private static async Task<ItemResponse<JObject>> HandleUpdateAsync(IDictionary<s
                 throw new InvalidDataException("Partition Key field is mandatory");
             }
 
-            object? item = queryArgs[CreateMutationBuilder.INPUT_ARGUMENT_NAME];
+            object? item = queryArgs[MutationBuilder.ITEM_INPUT_ARGUMENT_NAME];
 
             JObject? input;
             // Variables were provided to the mutation

src/Core/Resolvers/Sql Query Structures/SqlInsertQueryStructure.cs

@@ -47,7 +47,7 @@ HttpContext httpContext
             sqlMetadataProvider,
             authorizationResolver,
             gQLFilterParser,
-            GQLMutArgumentToDictParams(context, CreateMutationBuilder.INPUT_ARGUMENT_NAME, mutationParams),
+            GQLMutArgumentToDictParams(context, MutationBuilder.ITEM_INPUT_ARGUMENT_NAME, mutationParams),
             httpContext)
         { }
 

src/Core/Resolvers/SqlMutationEngine.cs

@@ -1068,7 +1068,7 @@ public void AuthorizeMutationFields(
             List<string> inputArgumentKeys;
             if (mutationOperation != EntityActionOperation.Delete)
             {
-                inputArgumentKeys = BaseSqlQueryStructure.GetSubArgumentNamesFromGQLMutArguments(MutationBuilder.INPUT_ARGUMENT_NAME, parameters);
+                inputArgumentKeys = BaseSqlQueryStructure.GetSubArgumentNamesFromGQLMutArguments(MutationBuilder.ITEM_INPUT_ARGUMENT_NAME, parameters);
             }
             else
             {