Skip to content

Automatically building OData APIs (Dynamic data context)

Maxim edited this page Jul 17, 2019 · 15 revisions

For create server from only connection string, add reference to project \source\OdataToEntity.EfCore.DynamicDataContext

  • Sql Server
public void Configure(IApplicationBuilder app)
{
    var optionsBuilder = new DbContextOptionsBuilder<DynamicDbContext>();
    optionsBuilder = optionsBuilder.UseSqlServer("Server=.\\sqlexpress;Initial Catalog=OdataToEntity;Trusted_Connection=Yes;");
    using (ProviderSpecificSchema providerSchema = new SqlServerSchema(optionsBuilder.Options))
        app.DynamicMiddleware("/api", providerSchema, null);
}
  • PostgreSql
public void Configure(IApplicationBuilder app)
{
    var optionsBuilder = new DbContextOptionsBuilder<DynamicDbContext>();
    optionsBuilder = optionsBuilder.UseNpgsql("Host=localhost;Port=5432;Database=OdataToEntity;Pooling=true;User Id=mvoronov");
    using (ProviderSpecificSchema providerSchema = new PostgreSqlSchema(optionsBuilder.Options))
        app.DynamicMiddleware("/api", providerSchema, null);
}
  • MySql
public void Configure(IApplicationBuilder app)
{
    var optionsBuilder = new DbContextOptionsBuilder<DynamicDbContext>();
    optionsBuilder = optionsBuilder.UseMySql("server=localhost;database=dbo;user=root;password=123456");
    using (ProviderSpecificSchema providerSchema = new MySqlSchema(optionsBuilder.Options))
        app.DynamicMiddleware("/api", providerSchema, null);
}

Solution file - \sln\OdataToEntity.Test.DynamicDataContext.sln
Example implementation http server - \test\OdataToEntity.Test.DynamicDataContext.AspServer.
Http server configuration is done through the appsettings.json file.

  "OdataToEntity": {
    "BasePath" :  "api",
    "Provider": "sqlserver",
    "ConnectionString": "Server=.\\sqlexpress;Initial Catalog=OdataToEntity;Trusted_Connection=Yes;",
    "UseRelationalNulls": true,
    "InformationSchemaMappingFileName": "InformationSchemaMapping.json"
  }

"BasePath" - base path in the server URL.
"Provider" - database type, possible values mysql, postgresql, sqlserver.
"ConnectionString" - connection string to the database.
"UseRelationalNulls" - indicates whether or not to use relational database semantics when comparing null values.
"InformationSchemaMappingFileName" - custom mapping the database to the OData schema.

For additional customization of tables and foreign keys names, used InformationSchemaMapping.json file is a serialized class InformationSchemaMapping.

An example for use in your code

//Load our schema mappings (optional)
InformationSchemaMapping informationSchemaMapping = GetMappings();

//Configure context
var optionsBuilder = new DbContextOptionsBuilder<DynamicDbContext>();
optionsBuilder = optionsBuilder.UseSqlServer("Server=.\\sqlexpress;Initial Catalog=OdataToEntity;Trusted_Connection=Yes;");

IEdmModel dynamicEdmModel;
//create database schema
using (ProviderSpecificSchema providerSchema = new SqlServerSchema(optionsBuilder.Options))
using (var metadataProvider = providerSchema.CreateMetadataProvider(informationSchemaMapping))
{
    //create ef entity types manager
    DynamicTypeDefinitionManager typeDefinitionManager = DynamicTypeDefinitionManager.Create(metadataProvider);
    //Create adapter data access
    var dataAdapter = new DynamicDataAdapter(typeDefinitionManager);
    //Build OData edm model
    dynamicEdmModel = dataAdapter.BuildEdmModel(metadataProvider);
}

//Create query parser
var parser = new OeParser(new Uri("http://dummy"), dynamicEdmModel);
//Query
var uri = new Uri("http://dummy/Orders?$expand=Customer,Items&$orderby=Id");
//The result of the query
var stream = new MemoryStream();
//Execute query
await parser.ExecuteGetAsync(uri, OeRequestHeaders.JsonDefault, stream, CancellationToken.None);
stream.Position = 0;
//Get result as string
Console.WriteLine(new StreamReader(stream).ReadToEnd());