Как правильно организовать класс по работе с БД - C#

Узнай цену своей работы

Формулировка задачи:

Здравствуйте. У меня есть проект каталогизатора. Изначально писал основываясь на MSSQL CE. Потом захотел добавить возможность использования MSSQL Server. И начал сочинять)) Написал фабрику возвращающую класс по работе с конкретной СУБД
Листинг программы 
  1. public static class DbProviderFactory
  2. {
  3.      public static DatabaseProvider GetProvider(DBType dbType, string ConnectStr)
  4.      {
  5.          DatabaseProvider provider = null;
  6.         switch (dbType)
  7.          {
  8.              case DBType.MSSQL:
  9.                  provider = new SqlDbProvider(ConnectStr);
  10.                  break;
  11.              case DBType.MSSQLCE:
  12.                  provider = new SqlCeDbProvider(ConnectStr);
  13.                  break;
  14.              default:
  15.                  throw new ArgumentException("Wrong database type!");
  16.          }
  17.          return provider;
  18.      }
  19. }
где DBType - перечисление с вариантами СУБД
Листинг программы 
  1. public enum DBType
  2. {
  3.     None,
  4.     MSSQL,
  5.     MSSQLCE
  6. }
Написал абстрактный класс по работе с СУБД где перечислил абстрактные классы по работе с таблицами в БД
Листинг программы 
  1. public abstract class DatabaseProvider
  2. {
  3.     protected string CONNECT_STR = string.Empty;
  4.     protected IDbConnection CNN = null;
  5.  
  6.     public DatabaseProvider(string connectStr)
  7.     {
  8.         CONNECT_STR = connectStr;
  9.     }
  10.  
  11.     public abstract ProjectTableAbstract GetProjectTable();
  12.  
  13.     public abstract FirstUsageTableAbstract GetFirstUsageTable();
  14.  
  15.     public abstract OboznachenieTableAbstract GetOboznachenieTable();
  16.  
  17.     public abstract LiteralTableAbstract GetLiteralTable();
  18.  
  19.     public abstract IspolniteliTableAbstract GetIspolniteliTable();
  20.  
  21.     public abstract InventarNumberTableAbstract GetInventarNumberTable();
  22. }
От него унаследовал класс работы с конкретной СУБД.
Листинг программы 
  1. public class SqlCeDbProvider : DatabaseProvider // Для MSSQL CE
  2. {
  3.     public SqlCeDbProvider(string connectStr)
  4.         : base(connectStr)
  5.     {
  6.         CNN = new SqlCeConnection(CONNECT_STR);
  7.     }
  8.  
  9.     public override ProjectTableAbstract GetProjectTable()
  10.     {
  11.         return new ProjectTableSqlCe(CNN);
  12.     }
  13.  
  14.     public override FirstUsageTableAbstract GetFirstUsageTable()
  15.     {
  16.         return new FirstUsageTableSqlCe(CNN);
  17.     }
  18.  
  19.     public override OboznachenieTableAbstract GetOboznachenieTable()
  20.     {
  21.         return new OboznachenieTableSqlCe(CNN);
  22.     }
  23.  
  24.     public override LiteralTableAbstract GetLiteralTable()
  25.     {
  26.         return new LiteralTableSqlCe(CNN);
  27.     }
  28.  
  29.     public override IspolniteliTableAbstract GetIspolniteliTable()
  30.     {
  31.         return new IspolniteliTableSqlCe(CNN);
  32.     }
  33.  
  34.     public override InventarNumberTableAbstract GetInventarNumberTable()
  35.     {
  36.         return new InventarNumberTableSqlCe(CNN);
  37.     }
  38. }
  39.  
  40. class SqlDbProvider : DatabaseProvider // Для MSSQL Server
  41. {
  42.     public SqlDbProvider(string connectStr)
  43.         : base(connectStr)
  44.     {
  45.         CNN = new SqlConnection(CONNECT_STR);
  46.     }
  47.  
  48.     public override OboznachenieTableAbstract GetOboznachenieTable()
  49.     {
  50.         throw new NotImplementedException();
  51.     }
  52.  
  53.     public override FirstUsageTableAbstract GetFirstUsageTable()
  54.     {
  55.         throw new NotImplementedException();
  56.     }
  57.  
  58.     public override ProjectTableAbstract GetProjectTable()
  59.     {
  60.         throw new NotImplementedException();
  61.     }
  62.  
  63.     public override LiteralTableAbstract GetLiteralTable()
  64.     {
  65.         throw new NotImplementedException();
  66.     }
  67.  
  68.     public override IspolniteliTableAbstract GetIspolniteliTable()
  69.     {
  70.         throw new NotImplementedException();
  71.     }
  72.  
  73.     public override InventarNumberTableAbstract GetInventarNumberTable()
  74.     {
  75.         throw new NotImplementedException();
  76.     }
  77. }
Написал набор абстрактных классов по работе с таблицами (на примере ProjectTable)
Листинг программы 
  1. public abstract class ProjectTableAbstract
  2. {
  3.     protected IDbConnection CNN = null;
  4.  
  5.     public ProjectTableAbstract(IDbConnection Connection)
  6.     {
  7.         CNN = Connection;
  8.     }
  9.  
  10.     public abstract List<Project> GetEntities();
  11.  
  12.     public abstract bool AddToDB(string value);
  13.  
  14.     public abstract bool DeleteFromDB(string value, int id);
  15.  
  16.     public abstract bool RenameInDB(string oldValue, string newValue, int oldValueId);
  17. }
Написал набор конкретных классов по работе с таблицами (на примере ProjectTable)
Листинг программы 
  1. class ProjectTableSqlCe : ProjectTableAbstract
  2. {
  3.     static SqlCeConnection SQLCeCon;
  4.     
  5.     public ProjectTableSqlCe(IDbConnection Connection) : base(Connection)
  6.     {
  7.         SQLCeCon = (SqlCeConnection)CNN;
  8.     }
  9.  
  10.     public override List<Project> GetEntities()
  11.     {
  12.         List<Project> _lst = new List<Project>();
  13.         if (SQLCeCon.State == ConnectionState.Closed)
  14.         {
  15.             SQLCeCon.Open();
  16.         }
  17.         _lst.Clear();
  18.         SqlCeCommand ceCmd;
  19.         SqlCeDataReader ceDR;
  20.         ceCmd = new SqlCeCommand("", (SqlCeConnection)CNN);
  21.         ceDR = ceCmd.ExecuteReader();
  22.         while (ceDR.Read())
  23.         {
  24.             _lst.Add(new Project((int)ceDR[0], (string)ceDR[1]));
  25.         }
  26.         ceDR.Close();
  27.         CNN.Close();
  28.         return _lst;
  29.     }
  30.  
  31.     public override bool AddToDB(string value)
  32.     {
  33.         int i = -1;
  34.         string cmd = "";
  35.         SqlCeCommand _cmd = new SqlCeCommand();
  36.         _cmd = new SqlCeCommand(cmd, SQLCeCon);
  37.         _cmd.Parameters.Add("@prj_name", SqlDbType.NVarChar).Value = value;
  38.         i = SQLExec(_cmd);
  39.         GetEntities();
  40.         return i > 0;
  41.     }
  42.  
  43.     public override bool DeleteFromDB(string value, int id)
  44.     {
  45.         string cmd = "";
  46.         int i = -1;
  47.         SqlCeCommand _cmd = new SqlCeCommand();
  48.         _cmd = new SqlCeCommand(cmd, SQLCeCon);
  49.         _cmd.Parameters.Add("@id", SqlDbType.Int).Value = id;
  50.         try
  51.         {
  52.             i = SQLExec(_cmd);
  53.         }
  54.         catch (Exception ex)
  55.         {
  56.             if (ex is SqlCeException)
  57.             {
  58.                 ExceptionHandler.SQLEntityException exc =
  59.                 new ExceptionHandler.SQLEntityException();
  60.                 throw exc;
  61.             }
  62.             else
  63.             { throw ex; }
  64.         }
  65.         return i > 0;
  66.     }
  67.  
  68.     public override bool RenameInDB(string oldValue, string newValue, int oldValueId)
  69.     {
  70.         string cmd = "";
  71.         int i = -1;
  72.         SqlCeCommand _cmd = new SqlCeCommand();
  73.         _cmd = new SqlCeCommand(cmd, SQLCeCon);
  74.         _cmd.Parameters.Add("@id", SqlDbType.Int).Value = oldValueId;
  75.         _cmd.Parameters.Add("@name", SqlDbType.NVarChar).Value = newValue;
  76.         try
  77.         {
  78.             i = SQLExec(_cmd);
  79.         }
  80.         catch (Exception ex)
  81.         {
  82.             if (ex is SqlCeException)
  83.             {
  84.                 ExceptionHandler.SQLEntityException exc =
  85.                 new ExceptionHandler.SQLEntityException();
  86.                 throw exc;
  87.             }
  88.             else
  89.             { throw ex; }
  90.         }
  91.         GetEntities();
  92.         return i > 0;
  93.     }
  94.  
  95.     protected int SQLExec(SqlCeCommand SQLCommand)
  96.     {
  97.         int i = -1;
  98.         if (CNN.State == ConnectionState.Closed)
  99.         {
  100.             CNN.Open();
  101.         }
  102.         try
  103.         {
  104.             i = SQLCommand.ExecuteNonQuery();
  105.         }
  106.         finally
  107.         {
  108.             CNN.Close();
  109.         }
  110.         return i;
  111.     }
  112. }
Мне бы хотелось вынести метод SQLExec из каждого конкретного класса вынсти в некий класс (возможно абстактный)? Посмотрев диаграмму классов на все это "творчества", у меня возник вопрос, а не должены ли абстрактные классы наледоваться от какого-то общего класса куда можно было бы вынести общие методы как, например SQLExec? Прошу дать оценку моему певому опыту работы с фабрикой.

Решение задачи: «Как правильно организовать класс по работе с БД»

textual
Листинг программы 
  1.   public abstract class ProjectTableAbstract
  2.   {
  3.     private readonly string _connectionString;
  4.  
  5.     protected ProjectTableAbstract(string connectionString)
  6.     {
  7.       _connectionString = connectionString;
  8.     }
  9.  
  10.     public virtual List<Project> GetEntities()
  11.     {
  12.       return Query<List<Project>>("Your query");
  13.     }
  14.  
  15.     public virtual bool AddToDb(string value)
  16.     {
  17.       return SqlExecuteNonQuery("Your query") > -1;
  18.     }
  19.  
  20.     public virtual bool DeleteFromDb(string value, int id)
  21.     {
  22.       return SqlExecuteNonQuery("Your query") > -1;
  23.     }
  24.  
  25.     public virtual bool RenameInDb(string oldValue, string newValue, int oldValueId)
  26.     {
  27.       return SqlExecuteNonQuery("Your query") > -1;
  28.     }
  29.  
  30.     protected abstract IDbConnection GetConnection(string str);
  31.     protected abstract IDbCommand GetCommand(IDbConnection connection, string query);
  32.  
  33.     protected virtual int SqlExecuteNonQuery(string query)
  34.     {
  35.       using (var connection = GetConnection(_connectionString))
  36.       {
  37.         connection.Open();
  38.         using (var command = GetCommand(connection,query))
  39.         {
  40.           return command.ExecuteNonQuery();
  41.         }
  42.       }
  43.     }
  44.  
  45.     protected virtual T Query<T>(string query)
  46.     {
  47.       using (var connection = GetConnection(_connectionString))
  48.       {
  49.         connection.Open();
  50.         using (var command = GetCommand(connection, query))
  51.         {
  52.           //парсинг результата запроса и запись в модель
  53.           return default(T);
  54.         }
  55.       }
  56.     }
  57.   }
  58.  
  59.   public class ProjectTableSqlCe : ProjectTableAbstract
  60.   {
  61.     public ProjectTableSqlCe(string connectionString) : base(connectionString)
  62.     {
  63.     }
  64.  
  65.     protected override IDbConnection GetConnection(string str)
  66.     {
  67.       throw new NotImplementedException();
  68.     }
  69.  
  70.     protected override IDbCommand GetCommand(IDbConnection connection, string query)
  71.     {
  72.       throw new NotImplementedException();
  73.     }
  74.   }
  75.  
  76.   public class ProjectTableMsSql:ProjectTableAbstract
  77.   {
  78.     public ProjectTableMsSql(string connectionString) : base(connectionString)
  79.     {
  80.     }
  81.  
  82.     protected override IDbConnection GetConnection(string str)
  83.     {
  84.       throw new NotImplementedException();
  85.     }
  86.  
  87.     protected override IDbCommand GetCommand(IDbConnection connection, string query)
  88.     {
  89.       throw new NotImplementedException();
  90.     }
  91.   }
  92.  
  93.   public static class TableFactory
  94.   {
  95.     public static ProjectTableAbstract GetTable(string name,string connectionString)
  96.     {
  97.       throw new NotImplementedException();
  98.     }
  99.   }

ИИ поможет Вам:

  • решить любую задачу по программированию
  • объяснить код
  • расставить комментарии в коде
  • и т.д
Попробуйте бесплатно

Оцени полезность:

8   голосов , оценка 4.25 из 5

Нужна аналогичная работа?

Оформи быстрый заказ и узнай стоимость

Бесплатно
Оформите заказ и авторы начнут откликаться уже через 10 минут
Похожие ответы