Estou desenvolvendo uma camada MVC pra um sistema ASP.NET escrito inicialmente em WebForms. Ele não usa EntityFramework, então uma boa parte do sistema eu tive que elaborar uma solução caseira.
Pra eu poder usar os métodos assíncronos do Ajax com os Controllers do MVC5, escrevi como exemplo o seguinte método:
[Authorize]
public async Task<JsonResult> IndexAsync()
{
var pessoas = new Pessoas(GeneralSettings.DataBaseConnection)
.Selecionar()
.Select(p => new { NOME = p.Nome, CPF = p.Cpf, FONE = p.TelefoneResidencial, CELULAR = p.TelefoneCelular, DEPARTAMENTO = "Teste", EMAIL = p.Email })
.Take(10);
return Json(pessoas, JsonRequestBehavior.AllowGet);
}
Este método não é assíncrono porque return Json(...
executa de modo síncrono. A seguinte mensagem aparece:
This async method lacks 'await' operators and will run synchronously. Consider using the 'await' operator to await non-blocking API calls, or 'await Task.Run(...)' to do CPU-bound work on a background thread.
Como devo alterar o método para que a execução seja assíncrona?
EDIT
O @dcastro pediu o método Selecionar()
, que está reproduzido abaixo:
public override IEnumerable<Pessoa> Selecionar(IEnumerable<Operador> operadores)
{
using (var obj = new Database())
{
var sSql =
"select p.ID_PESSOA, p.NOME_COMPLETO, p.APELIDO, p.EMAIL_PESSOAL, p.NOME_PAI, p.NOME_MAE, p.SEXO, p.CPF, p.RG, p.ORGAO_RG, " +
" p.EMISSAO_RG, p.DATA_NASC, p.LOCAL_NASC, p.ENDERECO, p.NUMERO, p.COMPLEMENTO, p.BAIRRO, p.CIDADE, p.ESTADO, p.DDD_FONE_RES, " +
" p.FONE_RES, p.DDD_FONE_CEL, p.CELULAR, p.ID_BANCO_TALENTOS, p.ESTADO_CIVIL, p.ID_NACIONALIDADE, p.DEFICIENTE, p.TAMANHO_SAPATO, " +
" p.TAMANHO_CAMISETA, p.ALERGIA, p.NOME_CONJUGE, p.DDD_TEL_EMERGENCIA, p.TEL_EMERGENCIA, p.DDD_CEL_EMERGENCIA, p.CEL_EMERGENCIA, " +
" p.CONTATO_EMERGENCIA, p.ID_FORMACAO_ACADEMICA, p.PARENTESCO, p.FOTO_PESSOA, p.RI, p.TITULO_ELEITOR, p.ZONA, p.SECAO, " +
" p.CART_TRABALHO, p.SERIE, p.PIS, p.CPF_CONJUGE, p.LINKEDIN, p.FACEBOOK, p.TWITTER, p.ID_ETNIA, p.CEP " +
" from PESSOAS p ";
foreach (var operador in operadores)
{
sSql += WhereOuAnd + " p." + operador;
}
var parametros = operadores.Where(o => o.GetType().IsAssignableFrom(typeof(Igual))).Select(o2 => ((Igual)o2).ParametroOracle).ToList();
var dataTable = obj.ConsultarSQl(ConexaoBancoDados, sSql, parametros);
foreach (DataRow linha in dataTable.Rows)
{
yield return new Pessoa
{
PessoaId = Convert.ToInt32(linha["ID_PESSOA"].ToString()),
Nome = linha["NOME_COMPLETO"].ToString(),
Apelido = linha["APELIDO"].ToString(),
Email = linha["EMAIL_PESSOAL"].ToString(),
NomePai = linha["NOME_PAI"].ToString(),
NomeMae = linha["NOME_MAE"].ToString(),
Sexo = linha["SEXO"].ToString(),
Cpf = linha["CPF"].ToString(),
Rg = linha["RG"].ToString(),
OrgaoEmissorRg = linha["ORGAO_RG"].ToString(),
DataEmissaoRg = (!String.IsNullOrEmpty(linha["EMISSAO_RG"].ToString())) ? Convert.ToDateTime(linha["EMISSAO_RG"].ToString()) : DateTime.MinValue,
Nascimento = (!String.IsNullOrEmpty(linha["DATA_NASC"].ToString())) ? Convert.ToDateTime(linha["DATA_NASC"].ToString()) : DateTime.MinValue,
LocalNascimento = linha["LOCAL_NASC"].ToString(),
Endereco = linha["ENDERECO"].ToString(),
Numero = linha["NUMERO"].ToString(),
Complemento = linha["COMPLEMENTO"].ToString(),
Bairro = linha["BAIRRO"].ToString(),
Cidade = linha["CIDADE"].ToString(),
Estado = linha["ESTADO"].ToString(),
DddTelefoneResidencial = (!String.IsNullOrEmpty(linha["DDD_FONE_RES"].ToString())) ? Convert.ToInt32(linha["DDD_FONE_RES"].ToString()) : Int32.MinValue,
TelefoneResidencial = (!String.IsNullOrEmpty(linha["FONE_RES"].ToString())) ? Convert.ToInt32(linha["FONE_RES"].ToString()) : Int32.MinValue,
DddCelular = (!String.IsNullOrEmpty(linha["DDD_FONE_CEL"].ToString())) ? Convert.ToInt32(linha["DDD_FONE_CEL"].ToString()) : Int32.MinValue,
TelefoneCelular = (!String.IsNullOrEmpty(linha["CELULAR"].ToString())) ? Convert.ToInt32(linha["CELULAR"].ToString()) : Int32.MinValue,
BancoTalentosId = linha["ID_BANCO_TALENTOS"].ToString(),
EstadoCivil = linha["ESTADO_CIVIL"].ToString(),
NacionalidadeId = (!String.IsNullOrEmpty(linha["ID_NACIONALIDADE"].ToString())) ? Convert.ToInt32(linha["ID_NACIONALIDADE"].ToString()) : Int32.MinValue,
Deficiente = linha["DEFICIENTE"].ToString(),
TamanhoSapato = (!String.IsNullOrEmpty(linha["TAMANHO_SAPATO"].ToString())) ? Convert.ToInt32(linha["TAMANHO_SAPATO"].ToString()) : Int32.MinValue,
TamanhoCamiseta = linha["TAMANHO_CAMISETA"].ToString(),
Alergia = linha["ALERGIA"].ToString(),
NomeConjuge = linha["NOME_CONJUGE"].ToString(),
DddTelefoneEmergencia = (!String.IsNullOrEmpty(linha["DDD_TEL_EMERGENCIA"].ToString())) ? Convert.ToInt32(linha["DDD_TEL_EMERGENCIA"].ToString()) : Int32.MinValue,
TelefoneEmergencia = (!String.IsNullOrEmpty(linha["TEL_EMERGENCIA"].ToString())) ? Convert.ToInt32(linha["TEL_EMERGENCIA"].ToString()) : Int32.MinValue,
DddCelularEmergencia = (!String.IsNullOrEmpty(linha["DDD_CEL_EMERGENCIA"].ToString())) ? Convert.ToInt32(linha["DDD_CEL_EMERGENCIA"].ToString()) : Int32.MinValue,
CelularEmergencia = (!String.IsNullOrEmpty(linha["CEL_EMERGENCIA"].ToString())) ? Convert.ToInt32(linha["CEL_EMERGENCIA"].ToString()) : Int32.MinValue,
ContatoEmergencia = linha["CONTATO_EMERGENCIA"].ToString(),
FormacaoAcademicaId = (!String.IsNullOrEmpty(linha["ID_FORMACAO_ACADEMICA"].ToString())) ? Convert.ToInt32(linha["ID_FORMACAO_ACADEMICA"].ToString()) : Int32.MinValue,
Parentesco = linha["PARENTESCO"].ToString(),
FotoPessoa = (linha["FOTO_PESSOA"].ToString() != "") ? (Byte[])linha["FOTO_PESSOA"] : new byte[0],
RI = linha["RI"].ToString(),
TituloEleitor = linha["TITULO_ELEITOR"].ToString(),
Zona = linha["ZONA"].ToString(),
Secao = linha["SECAO"].ToString(),
CarteiraTrabalho = linha["SECAO"].ToString(),
Serie = linha["SECAO"].ToString(),
Pis = linha["PIS"].ToString(),
CpfConjuge = linha["CPF_CONJUGE"].ToString(),
Linkedin = linha["LINKEDIN"].ToString(),
Facebook = linha["FACEBOOK"].ToString(),
Twitter = linha["TWITTER"].ToString(),
EtniaId = (!String.IsNullOrEmpty(linha["ID_ETNIA"].ToString())) ? Convert.ToInt32(linha["ID_ETNIA"].ToString()) : Int32.MinValue,
Cep = linha["CEP"].ToString()
};
}
}
}
Método ConsultarSql
(eu não escrevi este código. Ele faz parte do esquema de acesso a dados que já existia):
/// <summary>
/// Método utilizado para a execução de pesquisas no banco de dados com o envio de uma coleção de parametros.
/// </summary>
/// <param name="pStringConexao">String de conexão com o banco de dados.</param>
/// <param name="pSQL">Enviar o comando SQL que será executado.</param>
/// <param name="pParams">Coleção de parametros esperados no comeando SQL.</param>
/// <returns>Retorna um DataTable com o resultado da pesquisa.</returns>
public DataTable ConsultarSQl(string pStringConexao, string pSQL, List<OracleParameter> pParams)
{
#region Abre a Conexão
OracleConnection cn = new OracleConnection();
try
{
cn = GetConnection(pStringConexao);
cn.Open();
}
catch (Exception ex)
{
cn.Dispose();
throw ex;
}
#endregion
OracleCommand dbCommand = new OracleCommand(pSQL, cn);
dbCommand.CommandType = CommandType.Text;
foreach (OracleParameter param in pParams)
{
if (param.Value != null)
dbCommand.Parameters.Add(param);
}
OracleDataAdapter oAdp = new OracleDataAdapter(dbCommand);
DataSet ds = new DataSet();
try
{
oAdp.Fill(ds);
}
catch (Exception ex)
{
if (cn.State == ConnectionState.Open)
{
cn.Close();
}
dbCommand.Dispose();
cn.Dispose();
throw ex;
}
finally
{
if (cn.State == ConnectionState.Open)
{
cn.Close();
}
dbCommand.Dispose();
cn.Dispose();
}
return ds.Tables[0];
}
Se houver necessidade de colocar mais códigos, só pedir via comentários.
var pessoas = new Pessoas(GeneralSettings.DataBaseConnection) .Selecionar() .Select(p => new { NOME = p.Nome, CPF = p.Cpf, FONE = p.TelefoneResidencial, CELULAR = p.TelefoneCelular, DEPARTAMENTO = "Teste", EMAIL = p.Email }) .Take(10);
. Este métodoSelecionar
faz o acesso ao banco..Selecionar()
? Esse codigo pode chamar outros metodos, e esses podem chamar outros metodos, etc, mas eu preciso de saber qual e' a linha de codigo que efectivamente comunica directamente com a API da base de dados. E qual a biblioteca que esta' a ser usada para isso.Selecionar()
.ConsultarSQl()
num objecto do tipoDatabase
... Nao sabes qual e' a tecnologia que esta a ser usada? Disseste que nao e' Entity Framework, entao qual e'? ADO.NET? Sqlite-net? Peco desculpa se a minha pergunta nao foi clara.