Skip to main content

MongoDB

Download MongoDB from https://www.mongodb.com/what-is-mongodb 

Install MongoDb nuget package: MongoDB.Driver (Author: rstam.craigwilson)


Service 

______________________________________________________________________
public interface IMongoService
    {
         Employee CreateEmployee(Employee employee);
        void Delete(string id);
        Employee GetEmployeeById(string id);
        List<Employee> GetEmployees();
        Employee Update(Employee employee);
    }

public class MongoService : IMongoService
    {
        IMongoCollection<Employee> _mongoCollection;
        public MongoService(IOptions<EmpDatabaseSettings> options)
        {
            Options = options;
            var client = new MongoClient(options.Value.ConnectionString);
            var database = client.GetDatabase(options.Value.DatabaseName);

            _mongoCollection = database.GetCollection<Employee>(options.Value.EmpCollectionName);
        }

        public IOptions<EmpDatabaseSettings> Options { get; }

        public List<Employee> GetEmployees()
        {
            return _mongoCollection.Find(i => true).ToList();
        }

        public Employee GetEmployeeById(string id)
        {
            return _mongoCollection.Find(i => i.Id.Equals(id)).FirstOrDefault();
        }

        public Employee CreateEmployee(Employee employee)
        {
            _mongoCollection.InsertOne(employee);
            return employee;
        }

        public Employee Update(Employee employee)
        {
            _mongoCollection.ReplaceOne(i => i.Id.Equals(employee.Id), employee);
            return employee;
        }

        public void Delete(string id)
        {
            _mongoCollection.DeleteOne(i => i.Id.Equals(id));
        }

__________________________________________________________________

Controller


[Route("api/Employee")]
    [ApiController]
    public class ValuesController : ControllerBase
    {
        public IMongoService MongoService { get; }

        public ValuesController(IMongoService mongoService)
        {
            MongoService = mongoService;
        }

        [HttpGet()]
        public IActionResult GetAllEmployees()
        {
            try
            {
                return Ok(this.MongoService.GetEmployees());
            }
            catch (Exception ex)
            {
                return BadRequest(ex.Message);
            }

        }

        [HttpGet("{id}")]
        public IActionResult GetEmployeeById(string id)
        {
            try
            {
                return Ok(this.MongoService.GetEmployeeById(id));
            }
            catch (Exception ex)
            {
                return BadRequest(ex.Message);
            }
        }

        [HttpPost()]
        public IActionResult CreateEmployee([FromBody]Employee employee)
        {
            try
            {
                return Ok(this.MongoService.CreateEmployee(employee));
            }
            catch (Exception ex)
            {
                return BadRequest(ex.Message);
            }
        }

        [HttpPut()]
        public IActionResult UpdateEmployee([FromBody]Employee employee)
        {
            try
            {
                return Ok(this.MongoService.Update(employee));
            }
            catch (Exception ex)
            {
                return BadRequest(ex.Message);
            }
        }

        [HttpDelete("{id}")]
        public IActionResult DeleteEmployee(string id)
        {
            try
            {
                this.MongoService.Delete(id);
                return Ok();
            }
            catch (Exception ex)
            {
                return BadRequest(ex.Message);
            }
        }


    }
__________________________________________________________________

classes

 public class Employee
    {
        [BsonId]
        [BsonRepresentation(BsonType.ObjectId)]
        public string Id { get; set; }
        public string Name { get; set; }
        public int Age { get; set; }
        public Details Details { get; set; }
    }

    public class Details
    {
        public string City { get; set; }

        public string Address { get; set; }
    }

___________________________________________________________

Appsettings.json

 "EmpDatabaseSettings": {
    "EmpCollectionName": "Employee",
    "ConnectionString": "mongodb://localhost:27017",
    "DatabaseName": "EmployeeDB"
  },


  public class EmpDatabaseSettings
    {
        public string EmpCollectionName { get; set; }
        public string ConnectionString { get; set; }
        public string DatabaseName { get; set; }
    }

____________________________________________________________________

Strartup.cs 

Inside ConfigureServices (Register these dependencies)

 services.Configure<EmpDatabaseSettings>(this.Configuration.GetSection(nameof(EmpDatabaseSettings)));
           
 services.AddTransient<IMongoService, MongoService>();

Comments

Post a Comment

Popular posts from this blog

Service Endpoints --

 1. Create a VNET with 2 subnets 2. Create a service endpoint policy. That enables us to specify which particular storage account to connect to. This is currently enabled for storage accounts alone. Otherwise as part of service endpoints we can specify the resource provider alone and not a specific resource. We can specify this service endpoint policy while creating a service endpoint. Only storage account allow service endpoint policies as of now. If we notice then selecting cosmos db or any other service other than storage will not have the ability to accept service endpoint policies. As mentioned microsoft.storage allows us to add service endpoint policies. Thus we can specify a particular resource within a provider This is 1 way of enabling service endpoints. Or we can directly go to the storage account and from the networking tab select Sub1. This will automatically configure service endpoints and will add a service endpoint policy that enables the resource to connect to the s...
Post a Comment
Read more

Function APP and KV integration

 Create a function App and enable system assigned identity Create  a Keyvault and add a secret (Name in my case) Configure Access policies for the function app in keyvault Create an  access policy in Key Vault   for the application identity you created earlier. Enable the "Get" secret permission on this policy. Do not configure the "authorized application" or   applicationId   settings, as this is not compatible with a managed identity. https://docs.microsoft.com/en-us/azure/app-service/app-service-key-vault-references Key Vault references currently only support system-assigned managed identities. User-assigned identities cannot be used. We are granting our function app permissions to get and list all the secrets in this keyvault. Add Key Vault secrets reference in the Function App configuration Go to the keyvault and click on the secret we just created. Copy the secret identifier. We need to add this value to the function app configuration.  @Microsof...
Post a Comment
Read more

Azure AD Authentication And Authorization

ROLE BASED AUTHORIZATION Step1:   Setup  API. 1. Create an app registration and create an app role. Make sure that the app role is assigned to user and applications. We add it to both user groups and applications as this role can be then assigned to both users and applications. Scopes can only be assigned to apps. Now we can have only users with this role access our application. This app role behind the scenes adds an approles section to the manifest.json. We can directly add it to the manifest file also. Step 2:  Setup an app registration for the UI/ WEB App. . We will grant this app the read role created in the API app (shown above). Go to Azure AD and select the UI app registration. When we register an application 2 elements get created. 1. App registration  2. Enterprise Application -- service principal that get created for the app Adding roles to applications Go to the App registration => API Persmissions => Add a Permission => My API's The My Api's sec...
Post a Comment
Read more