OracleSPExecuteWrapper 1.0.0

You need to declare these settings in your appsettings.json file. The following is an example of the appsettings.json file:

{
  "OracleCS": "Data Source=****;USER ID=****;password=****;Connection Timeout=40;Min Pool Size=5; Incr Pool Size=10;Connection Lifetime=600;Max Pool Size=200;",

  "CustomPooling": {
	"OracleCS": "Data Source=****;USER ID=****;password=****;Connection Timeout=60;Connection Lifetime=30;Pooling=false;",
	"MillisecondsToTriggerCleaning": "30000"
  }

}

Usage

Below is an example of how to use the OracleConnectionPool class:

using DB;
using DB.APIs.Queries;
using DB.ManageQueries;
using DB.ManageQueries.Interfaces;
using DB.ManageQueries.IRepository;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

namespace test
{
    internal class Program
    {
        static void Main(string[] args)
        {

            var host = Host.CreateDefaultBuilder()
                .ConfigureAppConfiguration((hostingContext, configuration) =>
                {

                    configuration.AddJsonFile("appSettings.json", optional: true, reloadOnChange: true);

                })
                .ConfigureServices((context, services) =>
                { 
                services.AddOracleSPExecutionWrapper();
                }).Build();

            IServiceProvider serviceProvider = host.Services;

            IHandleQuery _handleQuery=serviceProvider.GetRequiredService<IHandleQuery>();
            Console.WriteLine("Hello, World!");

            requestIt req = new requestIt();
            serviceIt<requestIt, responseIt> service = new();
            
            var data= _handleQuery.executeQuery<serviceIt<requestIt, responseIt>, responseIt, requestIt>(service, req);

        }




    }

    public class responseIt
    {
        public string message { get; set; }

    }

    public class requestIt
    {
        public string message { get; set; }
    }

    public class serviceIt<TREQUEST, TRESPONSE> : IQuery,
                                        IQueryRequirement<TREQUEST>,
                                        IPostAction<TRESPONSE, TREQUEST>,
                                        IPreAction<TREQUEST>,
                                        IPostAction_InBackground<TRESPONSE, TRESPONSE, TREQUEST>,
                                        DB.ManageQueries.Interfaces.IExceptionHandler<TREQUEST>
        where TREQUEST : class, new()
        where TRESPONSE : class, new()

    {
        public string getStoredProcedure()
        {
            return "GetProducts"; //Name of the stored procedure
        }

        public bool HandleException(Exception ex, TREQUEST input)
        {
            throw ex;
        }

        public bool IsAllowedToBeExecuted(TREQUEST d)
        {
            return true;
        }

        public List<TRESPONSE> PerformPostAction(List<TRESPONSE> output, TREQUEST input)
        {
            return output;
        }

        public void PerformPostAction_InBackground(List<TRESPONSE> outputInitial, List<TRESPONSE> outputFinal, TREQUEST input)
        {
            
        }

        public TREQUEST PerformPreAction(TREQUEST input)
        {
            return input;
        }
    }
}