20057586828

Committed 09 Dec 2025 08:56AM UTC coverage: 57.193% (-0.2%) from 57.422%

Build # 20057586828

Build Type

Pull #2182

github

Committed by

JFriel

Commit Message

Merge branch 'develop' of https://github.com/HicServices/RDMP into task/RDMP-33-dataset-integration-interface

Pull Request Pull Request #2182: [Datasets] Task/rdmp 33 dataset integration interface

Run Details

11510 of 21615 branches covered (53.25%)

Branch coverage included in aggregate %.

1226 of 2024 new or added lines in 85 files covered. (60.57%)

35 existing lines in 15 files now uncovered.

32654 of 55604 relevant lines covered (58.73%)

8854.02 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/Rdmp.Core/DataLoad/Modules/Mutilators/RemoteServerSQLExecution.cs

﻿using FAnsi.Discovery;
using Rdmp.Core.Curation.Data;
using Rdmp.Core.Curation.Data.DataLoad;
using Rdmp.Core.DataLoad.Engine.Job;
using Rdmp.Core.DataLoad.Engine.Mutilators;
using Rdmp.Core.ReusableLibraryCode.Checks;
using Rdmp.Core.ReusableLibraryCode.Progress;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Rdmp.Core.DataLoad.Modules.Mutilators
{
    internal class RemoteServerSQLExecution : IPluginMutilateDataTables
    {

        [DemandsInitialization("The Remote Database server to run this sql on")]
        public ExternalDatabaseServer RemoteServer { get; set; }

        [DemandsInitialization("Run the following SQL when this component is run in the DLE", DemandType = DemandType.SQL,
    Mandatory = true)]
        public string Sql { get; set; }

        public void Check(ICheckNotifier notifier)
        {
            if (!RemoteServer.Exists())
            {
                notifier.OnCheckPerformed(new CheckEventArgs("Remote Server unavailable", CheckResult.Fail));
            }
        }

        public void Initialize(DiscoveredDatabase dbInfo, LoadStage loadStage)
        {
        }

        public void LoadCompletedSoDispose(ExitCodeType exitCode, IDataLoadEventListener postLoadEventsListener)
        {
        }

        public ExitCodeType Mutilate(IDataLoadJob job)
        {
            var db = RemoteServer.Discover(ReusableLibraryCode.DataAccess.DataAccessContext.DataLoad);
            try
            {
                using (var conn = db.Server.GetConnection())
                {
                    conn.Open();
                    var cmd = db.Server.GetCommand(Sql, conn);
                    cmd.ExecuteNonQuery();
                }
            }
            catch (Exception e)
            {
                job.OnNotify(this, new NotifyEventArgs(ProgressEventType.Error, e.Message));
                return ExitCodeType.Error;
            }
            return ExitCodeType.Success;
        }
    }
}

1	using FAnsi.Discovery;
2	using Rdmp.Core.Curation.Data;
3	using Rdmp.Core.Curation.Data.DataLoad;
4	using Rdmp.Core.DataLoad.Engine.Job;
5	using Rdmp.Core.DataLoad.Engine.Mutilators;
6	using Rdmp.Core.ReusableLibraryCode.Checks;
7	using Rdmp.Core.ReusableLibraryCode.Progress;
8	using System;
9	using System.Collections.Generic;
10	using System.Linq;
11	using System.Text;
12	using System.Threading.Tasks;
13
14	namespace Rdmp.Core.DataLoad.Modules.Mutilators
15	{
16	internal class RemoteServerSQLExecution : IPluginMutilateDataTables
17	{
18
19	[DemandsInitialization("The Remote Database server to run this sql on")]
NEW 20	public ExternalDatabaseServer RemoteServer { get; set; }	×
21
22	[DemandsInitialization("Run the following SQL when this component is run in the DLE", DemandType = DemandType.SQL,
23	Mandatory = true)]
NEW 24	public string Sql { get; set; }	×
25
26	public void Check(ICheckNotifier notifier)
27	{
NEW 28	if (!RemoteServer.Exists())	×
29	{
NEW 30	notifier.OnCheckPerformed(new CheckEventArgs("Remote Server unavailable", CheckResult.Fail));	×
31	}
NEW 32	}	×
33
34	public void Initialize(DiscoveredDatabase dbInfo, LoadStage loadStage)
35	{
NEW 36	}	×
37
38	public void LoadCompletedSoDispose(ExitCodeType exitCode, IDataLoadEventListener postLoadEventsListener)
39	{
NEW 40	}	×
41
42	public ExitCodeType Mutilate(IDataLoadJob job)
43	{
NEW 44	var db = RemoteServer.Discover(ReusableLibraryCode.DataAccess.DataAccessContext.DataLoad);	×
45	try
46	{
NEW 47	using (var conn = db.Server.GetConnection())	×
48	{
NEW 49	conn.Open();	×
NEW 50	var cmd = db.Server.GetCommand(Sql, conn);	×
NEW 51	cmd.ExecuteNonQuery();	×
NEW 52	}	×
NEW 53	}	×
NEW 54	catch (Exception e)	×
55	{
NEW 56	job.OnNotify(this, new NotifyEventArgs(ProgressEventType.Error, e.Message));	×
NEW 57	return ExitCodeType.Error;	×
58	}
NEW 59	return ExitCodeType.Success;	×
NEW 60	}	×
61	}
62	}

HicServices / RDMP / 20057586828

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous