DataPortalSelector.cs

Go to the documentation of this file.

//-----------------------------------------------------------------------
// <copyright file="DataPortalSelector.cs" company="Marimer LLC">
//     Copyright (c) Marimer LLC. All rights reserved.
//     Website: https://cslanet.com
// </copyright>
// <summary>Selects the appropriate data portal implementation</summary>
//-----------------------------------------------------------------------
using System;
using Csla.Configuration;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Csla.Properties;
using System.Threading.Tasks;
 
namespace Csla.Server
{
  public class DataPortalSelector : IDataPortalServer
  {
    public async Task<DataPortalResult> Create(Type objectType, object criteria, DataPortalContext context, bool isSync)
    {
      try
      {
        context.FactoryInfo = ObjectFactoryAttribute.GetObjectFactoryAttribute(objectType);
        if (context.FactoryInfo == null)
        {
          var dp = new SimpleDataPortal();
          return await dp.Create(objectType, criteria, context, isSync).ConfigureAwait(false);
        }
        else
        {
          var dp = new FactoryDataPortal();
          return await dp.Create(objectType, criteria, context, isSync).ConfigureAwait(false);
        }
      }
      catch (DataPortalException)
      {
        throw;
      }
      catch (Exception ex)
      {
        throw DataPortal.NewDataPortalException(
          "DataPortal.Create " + Resources.FailedOnServer,
          ex, null);
      }
    }
 
    public async Task<DataPortalResult> Fetch(Type objectType, object criteria, DataPortalContext context, bool isSync)
    {
      try
      {
        context.FactoryInfo = ObjectFactoryAttribute.GetObjectFactoryAttribute(objectType);
        if (context.FactoryInfo == null)
        {
          var dp = new SimpleDataPortal();
          return await dp.Fetch(objectType, criteria, context, isSync).ConfigureAwait(false);
        }
        else
        {
          var dp = new FactoryDataPortal();
          return await dp.Fetch(objectType, criteria, context, isSync).ConfigureAwait(false);
        }
      }
      catch (DataPortalException)
      {
        throw;
      }
      catch (Exception ex)
      {
        throw DataPortal.NewDataPortalException(
          "DataPortal.Fetch " + Resources.FailedOnServer,
          ex, null);
      }
    }
 
    public async Task<DataPortalResult> Update(object obj, DataPortalContext context, bool isSync)
    {
      try
      {
        context.FactoryInfo = ObjectFactoryAttribute.GetObjectFactoryAttribute(obj.GetType());
        if (context.FactoryInfo == null)
        {
          var dp = new SimpleDataPortal();
          return await dp.Update(obj, context, isSync).ConfigureAwait(false);
        }
        else
        {
          var dp = new FactoryDataPortal();
          return await dp.Update(obj, context, isSync).ConfigureAwait(false);
        }
      }
      catch (DataPortalException)
      {
        throw;
      }
      catch (Exception ex)
      {
        throw DataPortal.NewDataPortalException(
          "DataPortal.Update " + Resources.FailedOnServer,
          ex, obj);
      }
    }
 
    public async Task<DataPortalResult> Delete(Type objectType, object criteria, DataPortalContext context, bool isSync)
    {
      try
      {
        context.FactoryInfo = ObjectFactoryAttribute.GetObjectFactoryAttribute(objectType);
        if (context.FactoryInfo == null)
        {
          var dp = new SimpleDataPortal();
          return await dp.Delete(objectType, criteria, context, isSync).ConfigureAwait(false);
        }
        else
        {
          var dp = new FactoryDataPortal();
          return await dp.Delete(objectType, criteria, context, isSync).ConfigureAwait(false);
        }
      }
      catch (DataPortalException)
      {
        throw;
      }
      catch (Exception ex)
      {
        throw DataPortal.NewDataPortalException(
          "DataPortal.Delete " + Resources.FailedOnServer,
          ex, null);
      }
    }
  }
}