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);
}
}
}