AQueryMaker is a C# library designed to simplify database operations by providing a streamlined interface for executing SQL queries and managing database connections. It supports MSSQL, MySQL, and Oracle databases, and seamlessly integrates with Entity Framework Core.

• Simplified interface for executing SQL queries
• Support for asynchronous database operations
• Streamlined database connection management
• Integration with Entity Framework Core for seamless usage
• Compatibility with MSSQL, MySQL, and Oracle databases
• Streaming data retrieval capability for large datasets

To install AQueryMaker via NuGet Package Manager, run the following command:

dotnet add package AQueryMaker

To use AQueryMaker in your project, follow these steps:

Initialize the QueryManager by passing an instance of IDatabaseManager.

IDatabaseManager manager = new SqlServerManager(new SqlConnection(connectionString));
var queryManager = new QueryManager(manager);

or

IDatabaseManager manager = new MySqlServerManager(new MySqlConnection(connectionString));
var queryManager = new QueryManager(manager);

or

IDatabaseManager manager = new OraclelServerManager(new OracleConnection(connectionString));
var queryManager = new QueryManager(manager);

Use the methods provided by QueryManager to execute queries.

var result = await queryManager.QueryAsync("SELECT * FROM TableName");

Use the methods provided by QueryManager to execute queries. (Not supported in Oracle Db)

 // Define the stored procedure name and parameters
        string storedProcedureName = "YourStoredProcedureName";
            var parameters = new[]
      {
        new KeyValuePair<string, object>("@Parameter1", 1),
        new KeyValuePair<string, object>("@Parameter2", 2)
    };

        // Call the stored procedure using QueryAsync method with CommandType.StoredProcedure
        var result = await Db.Manager().QueryAsync(storedProcedureName,CommandType.StoredProcedure, parameters);

AQueryMaker seamlessly integrates with Entity Framework Core to simplify database operations.

Initialize the QueryManager using Entity Framework's database connection.

var dbContext = new YourDbContext();
var queryManager = dbContext.Manager(); //Gets connection based on

alternatively you can explicitly call dbContext.SqlManager() or dbContext.MySqlManager() or dbContext.OracleManager()

Use the methods provided by QueryManager to execute queries.

var result = await queryManager.QueryAsync("SELECT * FROM TableName");

To stream data from the database, use the StreamAsync method provided by QueryManager. Please note that in order to use the stream mode, the query must contain an ORDER BY clause.

await foreach (var data in Db.Manager().StreamAsync("SELECT * FROM USERS OrderBy 1",10)) // 10 is batch size, items per page
{
    yield return data;
}

var model = new Dictionary<string, object>
{
    { "ColumnName", value }
};

var result = await queryManager.InsertAsync("TableName", model);

var model = new Dictionary<string, object>
{
    { "ColumnName", value }
};

var result = await queryManager.UpdateAsync("TableName", model);

var model = new Dictionary<string, object>
{
    { "ColumnName", value }
};

var result = await queryManager.DeleteAsync("TableName", model);

var result = await queryManager.QueryAsync("SELECT * FROM TableName WHERE ColumnName = @Value", new KeyValuePair<string, object>("Value", value));

If you prefer to work with strongly-typed models, you can use the Adapt<List>() method to adapt the result to a list of objects of type T.

var result = await queryManager.QueryAsync<TModel>("SELECT * FROM TableName", queryData.parameters);
var adaptedResult = result.Adapt<List<TModel>>();

For more flexibility in data retrieval, you can use the QueryReaderAsync method to get a DbDataReader object and fetch data as needed.

var reader = await queryManager.QueryReaderAsync("SELECT * FROM TableName", queryData.parameters);
while (await reader.ReadAsync())
{
    // Process each row here
}

Similarly, you can use the StreamReaderAsync method to get an IAsyncEnumerable for streaming data retrieval.

var dataStream = queryManager.StreamReaderAsync("SELECT * FROM TableName", queryData.parameters);
await foreach (var dataReader in dataStream)
{
    // Process each row here
}

AQueryMaker supports the following databases:

• MSSQL
• MySQL
• Oracle (Note: CRUD operations are not supported)

Contributions to AQueryMaker are welcome! If you encounter any issues or have suggestions for improvements, feel free to open an issue or submit a pull request.

This project is licensed under the MIT License.

For any inquiries or support, please contact me.