Estoy desarrollando una tarea que básicamente ejecuta un una serie de procedimientos almacenados para cada sucursal que existe en nuestra empresa, para ello utilizo el task que viene en el .net framework 4.0 pero cuando ejecuta 50 veces el procedimiento lanza una excepcion en el catch y es referente a la conexión:
System.InvalidOperationException: ExecuteNonQuery requiere una Connection abierta y disponible. El estado actual de la conexión es abierta.
Yo mantengo siempre abierta la conexion la idea es que al terminar de ejecutar todos los Store procedures la conexion se cierre pero no encuentro la forma de hacerlo, ya que solo ejecuta un aproximado de 50 SP y ocurre el error
Método principal:
public static void Main(string[] args)
{
Console.WriteLine("--INICIO DEL PROCESO. {0:dd-MM-yyyy HH:mm}", HORA_INICIAL);
Console.WriteLine("---------------------------------------");
Console.WriteLine();
DateTime inicio = DateTime.Now;
DataSet dsTiendas = getTiendas();
DataSet dsProcedures = getProcedimientos();
int sizeT = dsTiendas.Tables["Tienda"].Rows.Count;
int sizeP = dsProcedures.Tables["Procedure"].Rows.Count;
int i;
string serverDb, procedure, tienda = "";
if (sizeT > 0 && sizeP > 0)
{
OpenConnection(true);
for (i = 0; i < sizeT; i++)
{
serverDb = dsTiendas.Tables["Tienda"].Rows[i]["SERVERDB"].ToString();
tienda = dsTiendas.Tables["Tienda"].Rows[i]["U_TIENDA"].ToString() + ": " + dsTiendas.Tables["Tienda"].Rows[i]["NOMBRE"].ToString();
Console.WriteLine("Incio de Ejecucion de procesos Tienda: " + tienda);
Console.WriteLine("IP: " + dsTiendas.Tables["Tienda"].Rows[i]["DIRECCIONIP"].ToString());
for (int j = 0; j < sizeP; j++)
{
procedure = dsProcedures.Tables["Procedure"].Rows[j]["NOMBRE"].ToString();
Console.WriteLine("Procedimiento: " + procedure);
Console.WriteLine("--Inicio del proceso. {0:dd-MM-yyyy HH:mm}", DateTime.Now);
Task t = Task.Factory.StartNew(() => ejecutarNonQuery("EXEC " + procedure + " '" + serverDb + "'"));
Console.WriteLine("--Fin del proceso. {0:dd-MM-yyyy HH:mm}", DateTime.Now);
}
}
Console.WriteLine("Fin de la tarea " + tienda);
Console.WriteLine("--Hora finalizada. {0:dd-MM-yyyy HH:mm}", HORA_INICIAL);
}
CloseConnection(true);
System.Threading.Thread.Sleep(30);
}
Métodos para abrir/cerrar conexión:
private static void OpenConnection(bool pMantenerConexionAbierta = false)
{
InitDB();
if (!(con.State == ConnectionState.Open))
{
con.Open();
MantenerConexionAbierta = pMantenerConexionAbierta;
}
}
public static void CloseConnection(bool FinalizarConexionAbierta = false)
{
if (FinalizarConexionAbierta)
{
MantenerConexionAbierta = false;
}
if (con.State == ConnectionState.Open & !MantenerConexionAbierta)
{
con.Close();
}
}
Método para ejecutar consultas
static public void ejecutarNonQuery(object dbQuerys)
{
string dbQuery = dbQuerys.ToString();
//bool respuesta = false;
if (dbQuery.Trim().Length == 0)
{
return;
}
using (SqlCommand cmd = getCommand(dbQuery, false))
{
try
{
cmd.ExecuteNonQuery();
//respuesta = true;
}
catch (Exception ex)
{
LogError(dbQuery, ex.ToString(), ex.StackTrace);
//respuesta = false;
}
finally
{
}
}
//return respuesta;
}