0

Tenho 2 métodos Async que fazer um Insert em um banco de dados na nuvem..

Por motivos de internet, pode ocorrer falha na transação para tratar esse problema, estou utilizando Commit e RollBack, ate ai blz.

Porém, preciso executar um 3 método, mas este so pode ser executado, caso esses dois métodos Async tenham sido concluído com sucesso.

Poderia fazer um loop e ficar testando uma condição de retorno, mas não acho isso muito correto, e sei que existe um método chamado CallBack.

Mas como implementar o CallBack?

Abaixo meus métodos Async:

  class Upload_RaWeb
{
    Conexao_bd consql = new Conexao_bd();

    async public void Details_Upload(int id, string cod_item_Crm, int cod_cli, string razao_social, string data_rec, string data_anal, string n_Crm, string n_Nf
                            , string OF_anterior, string modelo, string material, string arranjo, string diam, string tipo, string inicio_op
                            , string fim_op, string motivo, string tag, string fabric_bomba, string mod_bomba, string prod_fluido, string temp_fluido
                            , string rpm, string api, string pres_suc, string pres_desc, string diag_falha, string analise, string conclusao
                            , string recomend, int nivel)
    {
        consql.bd_string_nuvem();

        SqlConnection sqlconn = new SqlConnection(consql.sqlconn);

        try
        {
            consql._sql = @"INSERT INTO[dbo].[DetailsRaWeb]
                                       ([id]
                                       ,[cod_item_Crm]
                                       ,[cod_cli]
                                       ,[razao_social]
                                       ,[data_rec]
                                       ,[data_anal]
                                       ,[n_Crm]
                                       ,[n_Nf]
                                       ,[OF_anterior]
                                       ,[modelo]
                                       ,[material]
                                       ,[arranjo]
                                       ,[diam]
                                       ,[tipo]
                                       ,[inicio_op]
                                       ,[fim_op]
                                       ,[motivo]
                                       ,[tag]
                                       ,[fabric_bomba]
                                       ,[mod_bomba]
                                       ,[prod_fluido]
                                       ,[temp_fluido]
                                       ,[rpm]
                                       ,[api]
                                       ,[pres_suc]
                                       ,[pres_desc]
                                       ,[diag_falha]
                                       ,[analise]
                                       ,[conclusao]
                                       ,[recomend]
                                       ,[nivel])
                                 VALUES
                                       (@id
                                       ,@cod_item_Crm
                                       ,@cod_cli
                                       ,@razao_social
                                       ,@data_rec
                                       ,@data_anal
                                       ,@n_Crm
                                       ,@n_Nf
                                       ,@OF_anterior
                                       ,@modelo
                                       ,@material
                                       ,@arranjo
                                       ,@diam
                                       ,@tipo
                                       ,@inicio_op
                                       ,@fim_op
                                       ,@motivo
                                       ,@tag
                                       ,@fabric_bomba
                                       ,@mod_bomba
                                       ,@prod_fluido
                                       ,@temp_fluido
                                       ,@rpm
                                       ,@api
                                       ,@pres_suc
                                       ,@pres_desc
                                       ,@diag_falha
                                       ,@analise
                                       ,@conclusao
                                       ,@recomend
                                       ,@nivel)";

            SqlCommand cmd = new SqlCommand(consql._sql, sqlconn);

            cmd.Parameters.Add("@id", SqlDbType.Int).Value = id;
            cmd.Parameters.Add("@cod_item_Crm", SqlDbType.VarChar).Value = cod_item_Crm;
            cmd.Parameters.Add("@cod_cli", SqlDbType.Int).Value = cod_cli;
            cmd.Parameters.Add("@razao_social", SqlDbType.VarChar).Value = razao_social;
            cmd.Parameters.Add("@data_rec", SqlDbType.VarChar).Value = data_rec;
            cmd.Parameters.Add("@data_anal", SqlDbType.VarChar).Value = data_anal;
            cmd.Parameters.Add("@n_Crm", SqlDbType.VarChar).Value = n_Crm;
            cmd.Parameters.Add("@n_Nf", SqlDbType.VarChar).Value = n_Nf;
            cmd.Parameters.Add("@OF_anterior", SqlDbType.VarChar).Value = OF_anterior;
            cmd.Parameters.Add("@modelo", SqlDbType.VarChar).Value = modelo;
            cmd.Parameters.Add("@material", SqlDbType.VarChar).Value = material;
            cmd.Parameters.Add("@arranjo", SqlDbType.VarChar).Value = arranjo;
            cmd.Parameters.Add("@diam", SqlDbType.VarChar).Value = diam;
            cmd.Parameters.Add("@tipo", SqlDbType.VarChar).Value = tipo;
            cmd.Parameters.Add("@inicio_op", SqlDbType.VarChar).Value = inicio_op;
            cmd.Parameters.Add("@fim_op", SqlDbType.VarChar).Value = fim_op;
            cmd.Parameters.Add("@motivo", SqlDbType.VarChar).Value = motivo;
            cmd.Parameters.Add("@tag", SqlDbType.VarChar).Value = tag;
            cmd.Parameters.Add("@fabric_bomba", SqlDbType.VarChar).Value = fabric_bomba;
            cmd.Parameters.Add("@mod_bomba", SqlDbType.VarChar).Value = mod_bomba;
            cmd.Parameters.Add("@prod_fluido", SqlDbType.VarChar).Value = prod_fluido;
            cmd.Parameters.Add("@temp_fluido", SqlDbType.VarChar).Value = temp_fluido;
            cmd.Parameters.Add("@rpm", SqlDbType.VarChar).Value = rpm;
            cmd.Parameters.Add("@api", SqlDbType.VarChar).Value = api;
            cmd.Parameters.Add("@pres_suc", SqlDbType.VarChar).Value = pres_suc;
            cmd.Parameters.Add("@pres_desc", SqlDbType.VarChar).Value = pres_desc;
            cmd.Parameters.Add("@diag_falha", SqlDbType.VarChar).Value = diag_falha;
            cmd.Parameters.Add("@analise", SqlDbType.VarChar).Value = analise;
            cmd.Parameters.Add("@conclusao", SqlDbType.VarChar).Value = conclusao;
            cmd.Parameters.Add("@recomend", SqlDbType.VarChar).Value = recomend;
            cmd.Parameters.Add("@nivel", SqlDbType.VarChar).Value = nivel;

            await sqlconn.OpenAsync();

            await cmd.ExecuteNonQueryAsync();
        }
        catch (Exception error)
        {
            MessageBox.Show("erro" + error);
        }
        finally
        {
            sqlconn.Close();
        }
    }

    async public void Foto_Upload(DataTableReader dtr)
    {
        consql.bd_string_nuvem();

        SqlConnection sqlconn = new SqlConnection(consql.sqlconn);

        await sqlconn.OpenAsync();

        SqlTransaction tran = sqlconn.BeginTransaction();

        try
        {
            consql._sql = @"INSERT INTO [dbo].[FotosRaWeb]
                                            ([id]
                                            ,[Bfoto]
                                            ,[item]
                                            ,[foto_seq]
                                            ,[zoom]
                                            ,[descr_foto])
                                        VALUES
                                            (@id
                                            ,@Bfoto
                                            ,@item
                                            ,@foto_seq
                                            ,@zoom
                                            ,@descr_foto)";              

            while (await dtr.ReadAsync())
            {
                SqlCommand cmd = new SqlCommand(consql._sql, sqlconn, tran);

                cmd.Parameters.Add("@id", SqlDbType.Int).Value = (int)dtr["id"];
                cmd.Parameters.Add("@Bfoto", SqlDbType.VarBinary).Value = (byte[])dtr["Bfoto"];
                cmd.Parameters.Add("@item", SqlDbType.VarChar).Value = dtr["item"].ToString();
                cmd.Parameters.Add("@foto_seq", SqlDbType.VarChar).Value = dtr["pic"].ToString();
                cmd.Parameters.Add("@zoom", SqlDbType.VarChar).Value = dtr["zoom"].ToString();
                cmd.Parameters.Add("@descr_foto", SqlDbType.VarChar).Value = dtr["descricao"].ToString();

                await cmd.ExecuteNonQueryAsync();
            } 
        }
        catch (Exception error)
        {
            tran.Rollback();
            MessageBox.Show("erro" + error);
        }
        finally
        {
            tran.Commit();
            sqlconn.Close();
        }
    }
}

1 Resposta 1

1

Utilize Task e await em seus métodos assíncronos.

É preciso adicionar a seguinte referência no topo da sua classe (using):

using System.Threading.Tasks;

Modifiquei um de seus métodos como exemplo:

public async Task<bool> Foto_Upload(DataTableReader dtr)
{
    consql.bd_string_nuvem();

    SqlConnection sqlconn = new SqlConnection(consql.sqlconn);

    await sqlconn.OpenAsync();

    SqlTransaction tran = sqlconn.BeginTransaction();

    try
    {
        consql._sql = @"INSERT INTO [dbo].[FotosRaWeb]
                                        ([id]
                                        ,[Bfoto]
                                        ,[item]
                                        ,[foto_seq]
                                        ,[zoom]
                                        ,[descr_foto])
                                    VALUES
                                        (@id
                                        ,@Bfoto
                                        ,@item
                                        ,@foto_seq
                                        ,@zoom
                                        ,@descr_foto)";              

        while (await dtr.ReadAsync())
        {
            SqlCommand cmd = new SqlCommand(consql._sql, sqlconn, tran);

            cmd.Parameters.Add("@id", SqlDbType.Int).Value = (int)dtr["id"];
            cmd.Parameters.Add("@Bfoto", SqlDbType.VarBinary).Value = (byte[])dtr["Bfoto"];
            cmd.Parameters.Add("@item", SqlDbType.VarChar).Value = dtr["item"].ToString();
            cmd.Parameters.Add("@foto_seq", SqlDbType.VarChar).Value = dtr["pic"].ToString();
            cmd.Parameters.Add("@zoom", SqlDbType.VarChar).Value = dtr["zoom"].ToString();
            cmd.Parameters.Add("@descr_foto", SqlDbType.VarChar).Value = dtr["descricao"].ToString();

            await cmd.ExecuteNonQueryAsync();
        } 

        return true; // se executar o comando acima sem erros, podemos afirmar que tudo deu certo, então retornamos TRUE
    }
    catch (Exception error)
    {
        return false; // com exceção, retornamos FALSE
    }
    finally
    {
        tran.Commit();
        sqlconn.Close();
    }
}

Adicionado Task<bool> em seu método assíncrono, conseguimos verificar se ele executou da forma que você queria, através do retorno do método. Você pode colocar qualquer tipo de retorno no seu método. Coloquei bool porque é mais fácil de entender neste exemplo.

Feito isso, utilizamos o comando await, para esperar o método assíncrono executar e retornar, no seu caso, true ou false. Com isso, você consegue esperar o método e verificar se o mesmo teve o comportamento esperado.

if(await FotoUpload(variavelDataTableReader))
{
   // caso o upload da foto tenha retornado true...
}
else 
{
   // caso tenha retornado false
}

Você deve fazer log-in para responder a esta pergunta.

Esta não é a resposta que você está procurando? Pesquise outras perguntas com a tag .