Friday, March 24, 2023

How to implement async CRUD methods for an Employee model using Dapper with MySQL

 

using System.Collections.Generic;
using System.Data;
using System.Threading.Tasks;
using MySql.Data.MySqlClient;
using Dapper;

public class EmployeeRepository
{
    private readonly string _connectionString;

    public EmployeeRepository(string connectionString)
    {
        _connectionString = connectionString;
    }

    public async Task<int> CreateEmployeeAsync(Employee employee)
    {
        using (IDbConnection connection = new MySqlConnection(_connectionString))
        {
            string query = "INSERT INTO Employees (FirstName, LastName, Email, PhoneNumber) " +
                           "VALUES (@FirstName, @LastName, @Email, @PhoneNumber);" +
                           "SELECT LAST_INSERT_ID()";

            return await connection.ExecuteScalarAsync<int>(query, employee);
        }
    }

    public async Task<IEnumerable<Employee>> GetEmployeesAsync()
    {
        using (IDbConnection connection = new MySqlConnection(_connectionString))
        {
            string query = "SELECT * FROM Employees";

            return await connection.QueryAsync<Employee>(query);
        }
    }

    public async Task<Employee> GetEmployeeByIdAsync(int id)
    {
        using (IDbConnection connection = new MySqlConnection(_connectionString))
        {
            string query = "SELECT * FROM Employees WHERE Id = @id";

            return await connection.QuerySingleOrDefaultAsync<Employee>(query, new { id });
        }
    }

    public async Task<bool> UpdateEmployeeAsync(Employee employee)
    {
        using (IDbConnection connection = new MySqlConnection(_connectionString))
        {
            string query = "UPDATE Employees SET FirstName = @FirstName, LastName = @LastName, " +
                           "Email = @Email, PhoneNumber = @PhoneNumber WHERE Id = @Id";

            int rowsAffected = await connection.ExecuteAsync(query, employee);

            return rowsAffected > 0;
        }
    }

    public async Task<bool> DeleteEmployeeAsync(int id)
    {
        using (IDbConnection connection = new MySqlConnection(_connectionString))
        {
            string query = "DELETE FROM Employees WHERE Id = @id";

            int rowsAffected = await connection.ExecuteAsync(query, new { id });

            return rowsAffected > 0;
        }
    }
}


 

How to implement async CRUD methods for an Employee model using Dapper with PostgreSQL

 You will need to install and add reference to the Npgsql package to communicate with PostgreSQL database.

using System.Collections.Generic;
using System.Data;
using System.Threading.Tasks;
using Npgsql;
using Dapper;

public class EmployeeRepository
{
    private readonly string _connectionString;

    public EmployeeRepository(string connectionString)
    {
        _connectionString = connectionString;
    }

    public async Task<int> CreateEmployeeAsync(Employee employee)
    {
        using (IDbConnection connection = new NpgsqlConnection(_connectionString))
        {
            string query = "INSERT INTO Employees (FirstName, LastName, Email, PhoneNumber) " +
                           "VALUES (@FirstName, @LastName, @Email, @PhoneNumber);" +
                           "SELECT CAST(CURRENT_VAL('employees_id_seq') AS INTEGER)";

            return await connection.ExecuteScalarAsync<int>(query, employee);
        }
    }

    public async Task<IEnumerable<Employee>> GetEmployeesAsync()
    {
        using (IDbConnection connection = new NpgsqlConnection(_connectionString))
        {
            string query = "SELECT * FROM Employees";

            return await connection.QueryAsync<Employee>(query);
        }
    }

    public async Task<Employee> GetEmployeeByIdAsync(int id)
    {
        using (IDbConnection connection = new NpgsqlConnection(_connectionString))
        {
            string query = "SELECT * FROM Employees WHERE Id = @id";

            return await connection.QuerySingleOrDefaultAsync<Employee>(query, new { id });
        }
    }

    public async Task<bool> UpdateEmployeeAsync(Employee employee)
    {
        using (IDbConnection connection = new NpgsqlConnection(_connectionString))
        {
            string query = "UPDATE Employees SET FirstName = @FirstName, LastName = @LastName, " +
                           "Email = @Email, PhoneNumber = @PhoneNumber WHERE Id = @Id";

            int rowsAffected = await connection.ExecuteAsync(query, employee);

            return rowsAffected > 0;
        }
    }

    public async Task<bool> DeleteEmployeeAsync(int id)
    {
        using (IDbConnection connection = new NpgsqlConnection(_connectionString))
        {
            string query = "DELETE FROM Employees WHERE Id = @id";

            int rowsAffected = await connection.ExecuteAsync(query, new { id });

            return rowsAffected > 0;
        }
    }
}


Thursday, March 23, 2023

How to read data in .net from Oracle using Dapper

Following is an async C# method, that use the OracleConnection class to create a connection to the Oracle database. The QueryAsync method is called on the connection object to execute the query asynchronously and retrieve the Employee objects already mapped to the data returned by the SQL query. The AsList method is called on the result of the query to convert it to a list of Employee objects.

Note that you will need to add the reference to the Oracle.ManagedDataAccess.Client package.

 

using System.Collections.Generic;
using System.Data;
using System.Threading.Tasks;
using Dapper;
using Oracle.ManagedDataAccess.Client;

public class Employee
{
    public int Id { get; set; }
    public string Name { get; set; }
    public string Department { get; set; }
    public decimal Salary { get; set; }
}

public async Task<List<Employee>> GetEmployeeListFromOracleAsync()
{
    List<Employee> employees;
    string connectionString = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)
(HOST=hostName)(PORT=portNumber))(CONNECT_DATA=(SERVER=DEDICATED)
(SERVICE_NAME=serviceName)));User Id=userName;Password=password;";
 
    using (IDbConnection connection = new OracleConnection(connectionString))
    {
        employees = (await connection.QueryAsync<Employee>("SELECT * FROM Employee")).AsList();
    }
   
    return employees;
}
 

Different ways to write a method that reads list of entities from SQL Server in C# language

There are different ways we can do same work. With evolution of .net technologies we have found different technologies to perform data operations. Here we will look at different ways of getting a list of employees from SQL Server database using different data access technologies.

Method-1: using ADO.NET

This method retrieves the employee list from the "Employee" table in the SQL Server database using a SELECT query, and maps the data to a list of Employee objects. Note that in this example, the Employee class has properties for the Id, Name, Department, and Salary fields in the database, and the SqlDataReader's Get methods are used to retrieve the values for each field from each record.

using System.Data.SqlClient;
using System.Collections.Generic;

public class Employee
{
    public int Id { get; set; }
    public string Name { get; set; }
    public string Department { get; set; }
    public decimal Salary { get; set; }
}

public List<Employee> GetEmployeeListFromSqlServer()
{
    List<Employee> employees = new List<Employee>();
   
    string connectionString = "Data Source=serverName;Initial Catalog=databaseName;
User ID=userName;Password=password";
    string query = "SELECT Id, Name, Department, Salary FROM Employee";
   
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        SqlCommand command = new SqlCommand(query, connection);
        connection.Open();
        SqlDataReader reader = command.ExecuteReader();
       
        while (reader.Read())
        {
            Employee employee = new Employee();
            employee.Id = reader.GetInt32(0);
            employee.Name = reader.GetString(1);
            employee.Department = reader.GetString(2);
            employee.Salary = reader.GetDecimal(3);
           
            employees.Add(employee);
        }
       
        reader.Close();
    }
   
    return employees;
}



Method-2: using ADO.NET async

In this async version of the method, the SqlConnection is opened asynchronously using await connection.OpenAsync(), and the SqlDataReader is created and executed asynchronously using await command.ExecuteReaderAsync(). The while loop that reads the data is also made asynchronous using await reader.ReadAsync(). Note that the using statements are still used to ensure proper disposal of resources.


using System.Data.SqlClient;
using System.Collections.Generic;
using System.Threading.Tasks;

public class Employee
{
    public int Id { get; set; }
    public string Name { get; set; }
    public string Department { get; set; }
    public decimal Salary { get; set; }
}

public async Task<List<Employee>> GetEmployeeListFromSqlServerAsync()
{
    List<Employee> employees = new List<Employee>();
   
    string connectionString = "Data Source=serverName;Initial Catalog=databaseName;
User ID=userName;Password=password";
    string query = "SELECT Id, Name, Department, Salary FROM Employee";
   
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        await connection.OpenAsync();
       
        using (SqlCommand command = new SqlCommand(query, connection))
        using (SqlDataReader reader = await command.ExecuteReaderAsync())
        {
            while (await reader.ReadAsync())
            {
                Employee employee = new Employee();
                employee.Id = reader.GetInt32(0);
                employee.Name = reader.GetString(1);
                employee.Department = reader.GetString(2);
                employee.Salary = reader.GetDecimal(3);
               
                employees.Add(employee);
            }
        }
    }
   
    return employees;
}



Method-3: using Dapper

In this async version of the method, the SqlConnection is opened asynchronously using await connection.OpenAsync(). The query is then executed asynchronously using Dapper's QueryAsync method, which returns a list of Employee objects already mapped to the data returned by the SQL query. The using statement is still used to ensure proper disposal of resources.

using System.Data.SqlClient;
using System.Collections.Generic;
using System.Threading.Tasks;
using Dapper;

public class Employee
{
    public int Id { get; set; }
    public string Name { get; set; }
    public string Department { get; set; }
    public decimal Salary { get; set; }
}

public async Task<List<Employee>> GetEmployeeListFromSqlServerAsync()
{
    List<Employee> employees;
   
    string connectionString = "Data Source=serverName;Initial Catalog=databaseName;
User ID=userName;Password=password";
    string query = "SELECT Id, Name, Department, Salary FROM Employee";
   
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        await connection.OpenAsync();
        employees = (await connection.QueryAsync<Employee>(query)).AsList();
    }
   
    return employees;
}


Method-4: using EF Core

In this async version of the method, a DbContextOptionsBuilder is used to configure the connection string and then used to create a new DbContext instance. The Set method is used to retrieve the DbSet<Employee>, and then the ToListAsync method is called to execute the query asynchronously and retrieve the Employee objects already mapped to the data returned by the SQL query. The using statement is still used to ensure proper disposal of resources. Note that you will need to add the appropriate NuGet packages and configure EF Core for your specific database provider.

 

using System.Collections.Generic;
using System.Threading.Tasks;
using Microsoft.EntityFrameworkCore;

public class Employee
{
    public int Id { get; set; }
    public string Name { get; set; }
    public string Department { get; set; }
    public decimal Salary { get; set; }
}

public async Task<List<Employee>> GetEmployeeListFromSqlServerAsync()
{
    List<Employee> employees;
   
    string connectionString = "Data Source=serverName;Initial Catalog=databaseName;
User ID=userName;Password=password";
   
    DbContextOptionsBuilder dbContextOptionsBuilder = new DbContextOptionsBuilder();
    dbContextOptionsBuilder.UseSqlServer(connectionString);
    using (var dbContext = new DbContext(dbContextOptionsBuilder.Options))
    {
        employees = await dbContext.Set<Employee>().ToListAsync();
    }
   
    return employees;
}
 


Method-5: LINQ to SQL:

In this async version of the method, a DataContext is used to connect to the database and a Table<Employee> is used to retrieve the table of Employee objects. The ToListAsync method is called on the Table<Employee> to execute the query asynchronously and retrieve the Employee objects already mapped to the data returned by the SQL query. Note that you will need to add the appropriate references to System.Data.Linq and configure the DataContext for your specific database provider. The using statement is still used to ensure proper disposal of resources.

using System.Data.Linq;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Linq;

public class Employee
{
    public int Id { get; set; }
    public string Name { get; set; }
    public string Department { get; set; }
    public decimal Salary { get; set; }
}

public async Task<List<Employee>> GetEmployeeListFromSqlServerAsync()
{
    List<Employee> employees;
   
    string connectionString = "Data Source=serverName;Initial Catalog=databaseName;
User ID=userName;Password=password";
   
    DataContext dataContext = new DataContext(connectionString);
    Table<Employee> employeeTable = dataContext.GetTable<Employee>();
   
    employees = await employeeTable.ToListAsync();
   
    return employees;
}



 


Thursday, July 7, 2022

What is Interface in C#? What are the benefits of using Interface?

 

Interface

Interface: An interface contains definitions for a group of related functionalities that a non-abstract class or a struct must implement.

Interfaces can contain instance methods, properties, events, indexers, or any combination of those four member types. Interfaces may contain static constructors, fields, constants, or operators.

Benefits: Interface helps us to implement all of Object Oriented Programming concepts. There are several benefits of using interfaces in .NET, including:

1. Loose Coupling:  Interface allows us developing very loosely coupled system. An interface defines a contract that a class must follow. By using an interface, you can ensure that the class implementing it adheres to a specific set of rules and functionality.

2. Abstraction: Interface helps us developing secured system by implementing abstraction. It is a contract that contains properties and method signatures and implementation is done in inherited class. Thus it helps hiding implementation of internal business logic from external systems.

3. Inheritance: Interface in C# helps to achieve multiple inheritance. C# does not allow multiple class inheritance, but a class can implement multiple interfaces. This allows you to create objects with functionality from multiple sources, without the complications that can arise from multiple inheritance.

4. Polymorphism: Interfaces allow us to define polymorphism in a declarative way, unrelated to implementation. Two elements are polymorphic with respect to a set of behaviors if they realize the same interfaces.

5. Plug and Play: Interfaces are the key to the "plug-and-play" ability of an architecture.

6. Testing: Interfaces enable mocking objects which makes easier and better unit testing.

7. Dependency Injection: Interfaces are great for implementing Inversion of Control or Dependency Injection.

8. Extensibility: We can satisfy extensibility using the interfaces in C#.

9. Parallel Programming: Interfaces enable parallel application development.

10. Code Re usability: An interface can be implemented in multiple classes that enables greater code reuse. This can reduce the amount of code you need to write, and make it easier to modify or update existing code.

In conclusion we can say that using interfaces can help to create more modular, maintainable, and reusable code, while also enabling polymorphism and simplifying testing.

 

* Beginning with C# 8.0, an interface may define a default implementation for members.

Friday, December 10, 2021

How to split a comma separated string into multiple records using T-SQL function?

 Let's say you have a comma separated string like: 

split,a,comma,separated,string

 

Now you need to convert the string to follow rows:

split
a
comma
separated
string

 

Solution:

You can create a user defined UDF like the one shown below. Then, just pass in the comma separated list from another query and it will return a table with each value in a separate row. The function used here is a table valued function.

 

CREATE FUNCTION [dbo].[fnSplitStringToTable]
(
    @input nvarchar(MAX),
    @delimiter char(1) = ','
)
RETURNS
@Result TABLE
(
    Value nvarchar(MAX)
)
AS
BEGIN
    DECLARE @chIndex int
    DECLARE @item nvarchar(MAX)

    WHILE CHARINDEX(@delimiter, @input, 0) <> 0
    BEGIN
        SET @chIndex = CHARINDEX(@delimiter, @input, 0)
        SELECT @item = SUBSTRING(@input, 1, @chIndex - 1)

        IF LEN(@item) > 0
        BEGIN
            INSERT INTO @Result(Value)
            VALUES (@item)
        END
        SELECT @input = SUBSTRING(@input, @chIndex + 1, LEN(@input))
    END
    IF LEN(@input) > 0
    BEGIN
        INSERT INTO @Result(Value)
        VALUES (@input)
    END
    RETURN
END

 

Here is how you can execute the function and produce results as expected: