0

Criei um classe de conexão com banco de dados que pretendo usar a Thread para tornar as consultas mais rápidas.

Nas funções ExecutarSelect e ExecutarSQLPiece eu tenho retornos, mas não consegui obter esses retornos através da thread.

Dei uma pesquisada mas não consegui obter a solução, alguém ai saberia me dar uma ajuda?

Desde já muito obrigado!

// Instanciamento e chamada da execução thread

        ThreadBD thBD = new ThreadBD();
        thBD.comandoSQL = "SELECT acessoRapido FROM dbo.parametrosUsuario";
        Thread th = new Thread(thBD.executarSQLPiece);
        th.Start();

// Classe de conexao com o bando de dados

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;
using System.Threading;

namespace H7Transporte
{

    class ConexaoBD
    {
        //string connection;
        DataTable tabela = new DataTable();
        string retorno;
        public ConexaoBD()
        {
        }

        public void ExecutarQuery(string comandoString)
        {
            string connectionString = "Data Source=.\\SQLServer;Initial Catalog=H7Transporte;Integrated Security=True";
            SqlConnection cnn = new SqlConnection(connectionString);
            try
            {
                cnn.Open();
                SqlCommand comando = new SqlCommand(comandoString, cnn);
                comando.ExecuteNonQuery();
            }
            catch (Exception)
            {
                MessageBox.Show("Não foi possivel executar seu comando. O Query pode estar errado ou o retorno é nulo ");

            }
            finally
            {
                cnn.Close();
            }
        }

        public DataTable ExecutarSelect(string comandoString)
        {
            string connectionString = "Data Source=.\\SQLEXPRESS;Initial Catalog=teste2;Integrated Security=True";
            SqlConnection cnn = new SqlConnection(connectionString);

            try
            {
                cnn.Open();
                SqlDataAdapter Preencher = new SqlDataAdapter(comandoString, cnn);
                Preencher.Fill(tabela);
            }
            catch (Exception)
            {
                MessageBox.Show("Nenhuma informação foi encontrada. Seu Query pode estar errado ou o retorno é nulo ");
            }
            finally
            {
                cnn.Close();
            }
            return tabela;

        }

        public string sqlPiece(string comandoString)
        {
            string connectionString = "Data Source=.\\SQLServer;Initial Catalog=H7Transporte;Integrated Security=True";
            SqlConnection cnn = new SqlConnection(connectionString);

            try
            {
                cnn.Open();
                SqlCommand comando = new SqlCommand(comandoString, cnn);
                SqlDataReader sqlReader = comando.ExecuteReader();

                sqlReader.Read();
                retorno = sqlReader.GetValue(0).ToString();

            }
            catch (Exception)
            {
                MessageBox.Show("Nenhuma informação foi encontrada. Seu Query pode estar errado ou o retorno é nulo");
            }
            finally
            {
                cnn.Close();
            }

            return retorno;
        }
    }

    class ThreadBD
    {
        public string comandoSQL { get; set; }
        public string retorno { get; set; }

        public void executarQuery()
        {
            ConexaoBD conecta = new ConexaoBD();
            conecta.sqlPiece(comandoSQL);
        }

        public void executarSelect()
        {
            ConexaoBD conecta = new ConexaoBD();
            conecta.sqlPiece(comandoSQL);
        }

        public void executarSQLPiece()
        {
            ConexaoBD conecta = new ConexaoBD();
            conecta.sqlPiece(comandoSQL);
        }
    }
}

1 Resposta 1

3

Criei um classe de conexão com banco de dados que pretendo usar a Thread para tornar as consultas mais rápidas.

Isto não torna as consultas mais rápidas. Apenas permite que você execute consultas em paralelo, e o modo que você usa se aproxima facilmente de más práticas porque:

  • Não há proteção das regiões críticas (variáveis de retorno e conexão);
  • Não há análise das condições de corrida;
  • Sua ideia do porquê usar threads neste caso está equivocada.

Nas funções ExecutarSelect e ExecutarSQLPiece eu tenho retornos, mas não consegui obter esses retornos através da thread.

A maneira correta de fazer isso é declarando uma variável de retorno fora da Thread e fazendo ela receber o valor através de um delegate passado como argumento:

object retorno = null;
var thread = new Thread(
    () =>
    {
        retorno = thBD.executarSQLPiece();
    });
thread.Start();
thread.Join();
// Utilize o valor de 'retorno' aqui

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 .