From 00a491d93733d4625ad329b2ba8237f445364b3f Mon Sep 17 00:00:00 2001 From: Mirta Date: Wed, 30 Dec 2020 16:39:52 +0200 Subject: merge --- .../SQL/DefaultRemoteSqlService.cs | 59 ---------------------- 1 file changed, 59 deletions(-) delete mode 100644 Software/Visual_Studio/PPC/Tango.PPC.Common/SQL/DefaultRemoteSqlService.cs (limited to 'Software/Visual_Studio/PPC/Tango.PPC.Common/SQL/DefaultRemoteSqlService.cs') diff --git a/Software/Visual_Studio/PPC/Tango.PPC.Common/SQL/DefaultRemoteSqlService.cs b/Software/Visual_Studio/PPC/Tango.PPC.Common/SQL/DefaultRemoteSqlService.cs deleted file mode 100644 index e5ac43d3f..000000000 --- a/Software/Visual_Studio/PPC/Tango.PPC.Common/SQL/DefaultRemoteSqlService.cs +++ /dev/null @@ -1,59 +0,0 @@ -using System; -using System.Collections.Generic; -using System.Data.SqlClient; -using System.Linq; -using System.Text; -using System.Threading.Tasks; -using Tango.BL; -using Tango.Core.DI; -using Tango.Integration.ExternalBridge; -using Tango.PPC.Common.ExternalBridge; -using Tango.PPC.Shared.SQL; - -namespace Tango.PPC.Common.SQL -{ - [TangoCreateWhenRegistered] - public class DefaultRemoteSqlService : IRemoteSqlService, IExternalBridgeRequestHandler - { - public bool Enabled { get; set; } = true; - - public DefaultRemoteSqlService(IPPCExternalBridgeService externalBridge) - { - externalBridge.RegisterRequestHandler(this); - } - - [ExternalBridgeRequestHandlerMethod(typeof(ExecuteSqlRequest), RequestHandlerLoggingMode.LogRequestNameAndContent)] - public async Task OnExecuteSqlRequest(ExecuteSqlRequest request, String token, ExternalBridgeReceiver receiver) - { - this.ThrowIfDisabled(); - - RemoteSqlDataSet dataSet = new RemoteSqlDataSet(); - int affected = 0; - - using (ObservablesContext db = ObservablesContext.CreateDefault()) - { - using (SqlConnection connection = new SqlConnection(db.Database.Connection.ConnectionString)) - { - SqlCommand command = new SqlCommand(request.SQL, connection); - connection.Open(); - - SqlDataReader reader = command.ExecuteReader(); - affected = reader.RecordsAffected; - - dataSet = await RemoteSqlDataSet.Load(reader); - } - } - - await receiver.SendGenericResponse(new ExecuteSqlResponse() - { - DataSet = dataSet, - AffectedRecords = affected - }, token); - } - - public void OnReceiverDisconnected(ExternalBridgeReceiver receiver) - { - - } - } -} -- cgit v1.3.1