aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Visual_Studio/PPC/Tango.PPC.Common/SQL
diff options
context:
space:
mode:
Diffstat (limited to 'Software/Visual_Studio/PPC/Tango.PPC.Common/SQL')
-rw-r--r--Software/Visual_Studio/PPC/Tango.PPC.Common/SQL/DefaultRemoteSqlService.cs59
-rw-r--r--Software/Visual_Studio/PPC/Tango.PPC.Common/SQL/IRemoteSqlService.cs13
2 files changed, 0 insertions, 72 deletions
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)
- {
-
- }
- }
-}
diff --git a/Software/Visual_Studio/PPC/Tango.PPC.Common/SQL/IRemoteSqlService.cs b/Software/Visual_Studio/PPC/Tango.PPC.Common/SQL/IRemoteSqlService.cs
deleted file mode 100644
index f70589090..000000000
--- a/Software/Visual_Studio/PPC/Tango.PPC.Common/SQL/IRemoteSqlService.cs
+++ /dev/null
@@ -1,13 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace Tango.PPC.Common.SQL
-{
- public interface IRemoteSqlService : IPPCService
- {
-
- }
-}