Techjrstar.MySqlDbHelper 1.1.1

Techjrstar.MySqlDbHelper

Techjrstar.MySqlDbHelper is a library that simplifies the execution of stored procedures in MySQL databases using C#.

Installation

You can install this library via NuGet:

Usage

Here's how you can use the library to execute a stored procedure:

using Techjrstar.MySqlDbHelper;

// Create a DbHelper instance 
var connectionString = "Server=myServer;Database=myDB;User=myUser;Password=myPassword;";
var dbHelper = new DbHelper(connectionString);

// Define stored procedure parameters
var parameters = new Dictionary<string, object>
{
    { "@_param1", "value1" },
    { "@_param2", 123 },
   
};

// Execute the store procedute
var result = await dbHelper.ExecuteProcedureAsync("procedure_name", parameters);

// process the results

foreach (var row in result)
{
    Console.WriteLine($"Field1: {row["Field1"]}, Field2: {row["Field2"]}");
}

// Execute query

var dbHelper = new DbHelper(connectionString);
var query = "SELECT * FROM vw_view_name";
var result = await dbHelper.ExecuteQueryAsync(query);

// Execute QueryNoAsync

string insertQuery = $"INSERT INTO {tableName} (nombre, edad) VALUES ('Juan', 30)";
int rowsAffected = await dbHelper.ExecuteNonQueryAsync(insertQuery);

if (rowsAffected > 0)
{
    Console.WriteLine("Successful Operation");
}
else
{
    Console.WriteLine("No rows were affected.");
}

// With Parameters

string query = "UPDATE products SET price = @price WHERE id = @id";

var parameters = new Dictionary<string, object>
{
    { "@price", 19.99 },
    { "@id", 5 }
};

int rowsAffected = await ExecuteNonQueryAsync(query, parameters);

Console.WriteLine($"Rows affected: {rowsAffected}");

// With CancellationToken

using CancellationTokenSource cts = new CancellationTokenSource();
CancellationToken token = cts.Token;

string query = "INSERT INTO orders (customer_id, total) VALUES (@customerId, @total)";

var parameters = new Dictionary<string, object>
{
    { "@customerId", 123 },
    { "@total", 150.75 }
};

// Start a task in another thread to cancel after 1 second (example)
Task.Run(async () =>
{
    await Task.Delay(1000);
    cts.Cancel(); // Cancel the operation
});

try
{
    int result = await ExecuteNonQueryAsync(query, parameters, token);
    Console.WriteLine($"Rows inserted: {result}");
}
catch (OperationCanceledException)
{
    Console.WriteLine("The operation was canceled.");
}

New function added ExecuteProcedureWithTypedParametersAsync