Yo tengo este código para ejecutar procedimientos almacenados:
public System.Data.DataTable ExecuteSP(string procedimiento, params MySqlParameter[] datos)
{
try
{
using (MySqlConnection connection = ...)
{
using (MySqlCommand command = new MySqlCommand(procedimiento, connection))
{
command.CommandType = CommandType.StoredProcedure;
command.Parameters.AddRange(datos);
connection.Open();
DataTable dt = new DataTable();
dt.Load(command.ExecuteReader());
return dt;
}
}
}
catch (MySqlException e)
{
...
}
}
Para ser ejecutado:
DataTable datos = claseDeConexion.ExecuteSP("P_TraeDatos",
new MySqlParameter("paramA", parametroA),
new MySqlParameter("paramB", parametroB),
new MySqlParameter("paramC", parametroC)...);
Ese método retornará una tabla de resultados. También se puede hacer con un DataSet
:
connection.Open();
using (SqlDataAdapter da = new MySqlDataAdapter(command))
{
DataSet ds = new DataSet();
connection.Close();
da.Fill(ds);
return ds;
}
O con un object
(un solo valor):
object dbResult = DBNull.Value;
using (MySqlConnection connection = ...)
{
using (MySqlCommand command = new MySqlCommand(procedimiento, connection))
{
command.CommandType = CommandType.StoredProcedure;
command.Parameters.AddRange(datos);
connection.Open();
dbResult = cmnd.ExecuteScalar();
}
}
return dbResult;
¿Cómo ocuparlo?
Suponiendo que quieras obtener un int
a partir del procedimiento almacenado, yo te recomendaría usar el último método que escribí arriba, pero para que quede más claro lo pondré completo:
public object ExecuteScalarSP(string procedimiento, params MySqlParameter[] datos)
{
try
{
using (MySqlConnection connection = ...)
{
object dbResult = DBNull.Value;
using (MySqlCommand command = new MySqlCommand(procedimiento, connection))
{
command.CommandType = CommandType.StoredProcedure;
command.Parameters.AddRange(datos);
connection.Open();
dbResult = cmnd.ExecuteScalar();
}
return dbResult;
}
}
catch (MySqlException e)
{
...
}
}
Devuelve un object
ya que no lo sabe interpretar directamente.
Para invocarlo como indicas en el comentario, sería así:
int result = Convert.ToInt32(objConsultas.ExecuteScalarSP("P_Procedimiento",
new MySqlParameter("paramA", variableA),
new MySqlParameter("paramB", variableB),
new MySqlParameter("paramC", variableC),
new MySqlParameter("paramD", variableD),
new MySqlParameter("paramE", variableE)));
Yo lo usaría en conjunto con un método para convertir objects
en int
(para cuando sea por consulta) y evitar que cree una excepción si es null
:
public static int GetDbInt32(object DbResult)
{
return DBNull.Value.Equals(DbResult) ? 0 : Convert.ToInt32(DbResult);
}
Y quedaría así:
int result = GetDbInt32(objConsultas.ExecuteScalarSP("P_Procedimiento",
new MySqlParameter("paramA", variableA),
new MySqlParameter("paramB", variableB),
new MySqlParameter("paramC", variableC),
new MySqlParameter("paramD", variableD),
new MySqlParameter("paramE", variableE)));
Con parámetro de salida
Para definir la dirección del parámetro, puedes utilizarlo de la siguiente manera:
public IDictionary<string, object> ExecuteOutputSP(string procedimiento, params MySqlParameter[] datos)
{
try
{
using (MySqlConnection connection = ...)
{
using (MySqlCommand command = new MySqlCommand(procedimiento, connection))
{
command.CommandType = CommandType.StoredProcedure;
command.Parameters.AddRange(datos);
connection.Open();
command.ExecuteNonQuery();
IDictionary<string, object> dictionary = new Dictionary<string, object>();
foreach (MySqlParameter p in command.Parameters)
if (p.Direction != ParameterDirection.Input) dictionary.Add(p.ParameterName, p.Value);
return dictionary;
}
}
}
catch (MySqlException e)
{
...
}
}
int result = GetDbInt32(objConsultas.ExecuteOutputSP("P_Procedimiento",
new MySqlParameter("paramA", variableA),
new MySqlParameter("paramB", variableB),
new MySqlParameter("paramC", variableC),
new MySqlParameter("paramD", variableD),
new MySqlParameter("paramE", variableE),
new MySqlParameter("paramF", variableF){ Direction = ParameterDirection.Output })["paramF"]);