O que você quer, pelo que eu entendi, é implementar seu próprio Framework com as operações CRUD. Acho que nesta primeira etapa não é necessário usar inversão de controle de injeção de dependência.
Primeiro pense como vai ser a arquitetura de dados. Você pode usar classes de negócio, como Repositórios, por exemplo, ou então implementar a camada de acesso a dados (DAL) diretamente. O ideal é que essa camada de acesso a dados seja embasada em uma interface usando um tipo genérico. Vou dar um exemplo pra ficar mais claro:
namespace MeuProjeto.Data.Interfaces
{
public interface IAcessoDados<T>
where T: class
{
List<T> Selecionar();
List<T> Selecionar(IEnumerable<Operador> operadores);
void Incluir(T objeto);
void Atualizar(T objeto);
}
}
Toda e qualquer classe de acesso a dados deve usar essa interface. Isso garante que os métodos são os mesmos para todas as classes de dados.
Repare que Selecionar
é polimórfico. Chamando sem operadores, você deve implementar um método que irá selecionar todos os elementos da sua fonte de dados (um banco de dados relacional, por exemplo). No segundo você deve implementar um método que selecione os dados de acordo com alguns parâmetros.
Você também pode implementar uma classe comum que implementa essa interface, mais ou menos assim:
namespace MeuProjeto.Data
{
public abstract class Comum<T>: IDisposable, IComum<T>
where T: class
{
#region Propriedades
protected string ConexaoBancoDados { get; set; }
private String _whereOuAnd = " WHERE ";
protected String WhereOuAnd
{
get
{
var retorno = _whereOuAnd;
_whereOuAnd = " AND ";
return retorno;
}
}
private string _virgulaOuEspaco = " ";
public String VirgulaOuEspaco {
get
{
var retorno = _virgulaOuEspaco;
_virgulaOuEspaco = ", ";
return retorno;
}
}
protected void ReiniciarWhereEVirgula()
{
_whereOuAnd = " WHERE ";
_virgulaOuEspaco = " ";
}
#endregion
#region Construtores
protected Comum() { }
protected Comum(String conexaoBancoDados)
{
ConexaoBancoDados = conexaoBancoDados;
}
#endregion
#region Métodos
/// <summary>
/// Overload que retorna uma lista com todos os objetos do tipo T.
/// </summary>
/// <returns>
/// Lista com objetos do tipo Job.
/// </returns>
public virtual List<T> Selecionar()
{
return Selecionar(new List<Operador>());
}
/// <summary>
/// Método selecionar padrão. Recebe uma lista de operadores para selecionar do banco e devolver uma lista
/// </summary>
/// <param name="operadores"></param>
/// <returns></returns>
/// <remarks>Deve ser implementado em cada classe derivada.</remarks>
public abstract List<T> Selecionar(IEnumerable<Operador> operadores);
public abstract void Incluir(T objeto);
public abstract void Atualizar(T objeto);
#endregion
public void Dispose()
{
}
}
}
Se suas classes de dados herdarem desta classe Comum
, automaticamente o C# obriga você a implementar o método Selecionar(IEnumerable<Operador> operadores)
(por ser abstract) e sua classe de acesso a dados já ganha um método chamado Selecionar()
sem parâmetros. Aí você pode implementar sua classe como essa de um projeto meu:
namespace MeuProjeto.Data
{
public class AtividadesComentarios : Comum<AtividadesComentario>, IDisposable
{
public AtividadesComentarios() { }
public AtividadesComentarios(String conexaoBancoDados) : base(conexaoBancoDados) { }
/// <summary>
///
/// </summary>
/// <param name="parametros"></param>
/// <returns></returns>
public override List<AtividadesComentario> Selecionar(IEnumerable<Operadores.Operador> operadores)
{
using (var obj = new Common.Database())
{
var sSql =
"select ac.ID_COMENTARIO, ac.ID_ATIVIDADE, ac.TEXTO, ac.DATA, ac.ID_USUARIO, ac.HISTORICO_ANTIGO " +
" from ATIVIDADES_COMENTARIOS ac ";
foreach (var operador in operadores)
{
sSql += WhereOuAnd + " ac." + operador;
}
var parametros = operadores.Where(o => o.GetType().IsAssignableFrom(typeof(Igual))).Select(o2 => ((Igual)o2).ParametroOracle).ToList();
var retorno = new List<AtividadesComentario>();
OracleConnection connection;
using (OracleDataReader reader = obj.ConsultarSqlReader(ConexaoBancoDados, sSql, parametros, out connection))
{
while (reader.Read())
{
retorno.Add(new AtividadesComentario
{
AtividadesComentarioId = reader.GetInt32(reader.GetOrdinal("ID_COMENTARIO")),
AtividadeId = reader.GetInt32(reader.GetOrdinal("ID_ATIVIDADE")),
UsuarioId = reader.GetInt32(reader.GetOrdinal("ID_USUARIO")),
HistoricoAntigoId = reader.GetInt32(reader.GetOrdinal("HISTORICO_ANTIGO")),
Texto = reader.GetOracleClob(reader.GetOrdinal("TEXTO")).Value,
Data = reader.GetDateTime(reader.GetOrdinal("DATA"))
});
}
reader.Close();
connection.Close();
}
return retorno;
}
}
/// <summary>
/// Inclui um novo comentário na atividade.
/// </summary>
/// <param name="objeto">O objeto a ser inserido.</param>
public override void Incluir(AtividadesComentario objeto)
{
try
{
var oDataBase = new Database();
objeto.AtividadesComentarioId = oDataBase.RecuperaIDSequence(ConexaoBancoDados, "SEQ_ID_COMENTARIO_ATIVIDADE");
const string sSql = "INSERT INTO ATIVIDADES_COMENTARIOS (ID_COMENTARIO, ID_ATIVIDADE, TEXTO, DATA, ID_USUARIO, HISTORICO_ANTIGO) " +
" VALUES (:ID_COMENTARIO, :ID_ATIVIDADE, :TEXTO, :DATA, :ID_USUARIO, :HISTORICO_ANTIGO)";
var oParams = ExtrairParametros(objeto);
oDataBase.ExecutaComandoNonQuery(ConexaoBancoDados, sSql, oParams.ToList());
}
catch (Exception ex)
{
throw ex;
}
}
public override void Atualizar(AtividadesComentario objeto)
{
throw new NotImplementedException();
}
}
}
Aquele objeto oDatabase
é um objeto que comunica com a tecnologia específica do seu banco de dados (no meu caso, um banco Oracle). Repare que eu ainda não deixei muito genérico, mas se você for melhorando esse padrão (por exemplo, fazendo o método Inserir
da classe Comum
ler as propriedades de um objeto de dados e montar um SQL dinâmico), acredito que você possa chegar num resultado bem legal sem usar muito código específico.
Vou dar mais algumas dicas de métodos que construí pra ler objetos de dados via Reflection:
Extrair Chaves Primárias de um Objeto de Dados
/// <summary>
/// Extrai a chave primária de um objeto (property decorada com o atributo [Key]).
/// </summary>
/// <param name="objeto">Um objeto pertencente ao Namespace Metadata.</param>
/// <returns></returns>
protected IEnumerable<OracleParameter> ExtrairChavesPrimarias(Object objeto)
{
var type = objeto.GetType();
var properties =
type.GetProperties(BindingFlags.Instance | BindingFlags.Static | BindingFlags.Public |
BindingFlags.NonPublic | BindingFlags.FlattenHierarchy);
foreach (var property in properties)
{
var keyAttribute = Attribute.GetCustomAttribute(property, typeof (KeyAttribute)) as KeyAttribute;
if (keyAttribute != null)
{
var columnAttribute = (ColumnAttribute)property.GetCustomAttributes(typeof(ColumnAttribute), true).FirstOrDefault();
if (columnAttribute != null)
{
yield return new OracleParameter
{
ParameterName = columnAttribute.Name,
Value = property.GetValue(objeto, null)
};
}
else
{
yield return new OracleParameter
{
ParameterName = property.Name,
Value = property.GetValue(objeto, null)
};
}
}
}
}
Extrair Parâmetros de um Objeto de Dados
/// <summary>
/// Método selecionar padrão. Recebe uma lista de operadores para selecionar do banco e devolver uma lista
/// </summary>
/// <param name="operadores"></param>
/// <returns></returns>
/// <remarks>Deve ser implementado em cada classe derivada.</remarks>
public abstract List<T> Selecionar(IEnumerable<Operador> operadores);
private IEnumerable<PropertyInfo> ExtrairPropertiesDeObjeto(Object objeto)
{
return objeto.GetType().GetProperties(BindingFlags.Instance | BindingFlags.Static | BindingFlags.Public |
BindingFlags.NonPublic | BindingFlags.FlattenHierarchy);
}
/// <summary>
/// Monta uma lista de parâmetros por Reflection. Um parâmetro é uma property decorada com o atributo [Column].
/// </summary>
/// <param name="objeto"></param>
/// <returns></returns>
protected IEnumerable<OracleParameter> ExtrairParametros(Object objeto)
{
foreach (var propertyInfo in ExtrairPropertiesDeObjeto(objeto))
{
var columnAttribute = (ColumnAttribute)propertyInfo.GetCustomAttributes(typeof(ColumnAttribute), true).FirstOrDefault();
if (columnAttribute != null)
{
yield return new OracleParameter
{
ParameterName = columnAttribute.Name,
Value = propertyInfo.GetValue(objeto, null)
};
}
else
{
yield return new OracleParameter
{
ParameterName = propertyInfo.Name,
Value = propertyInfo.GetValue(objeto, null)
};
}
}
}
Se precisar que eu detalhe a resposta em mais algum ponto, só falar.