C#调用MySQL存储过程,函数的最佳方法

Question

你好我写了我的DAL调用存储过程,但我仍然不知道是否应该使用ExecuteScalar,NonQuery或Reader进行某些过程.

例如,我写了这个我想调用的函数

CREATE FUNCTION `retornarIdArea`(cod longtext) RETURNS int(11)
BEGIN
DECLARE id int;
    select AreaId into id FROM area where Codigo = cod;
    return id;
END

这个程序应该返回一个数据集

CREATE PROCEDURE `consultar_n_asunto`(in asun longtext, in est int)
BEGIN
    select * from notas where Asunto LIKE CONCAT('%',CONCAT(asun,'%')) AND Estado = est;
END$$

最后一个插入一些数据的过程,我使用输出参数选择验证.

CREATE PROCEDURE `registrar_dest`(in nomb longtext,
in dir longtext, in inst int, in mail longtext, in tel longtext,
in act int, out res tinyint(1))
BEGIN
    -- verificar que no exista el destinatario
    select count(*) into res from destinatario WHERE Nombre = nomb AND 
    Direccion = dir AND Email = mail AND Telefono = tel AND Activo = act;

    IF res = 0 THEN
        INSERT INTO destinatario (Nombre, Direccion, InstitucionId, Email, Telefono, Activo)
        VALUES (nomb, dir, inst, mail, tel, act);
        select count(*) into res from destinatario WHERE Nombre = nomb AND 
        Direccion = dir AND Email = mail AND Telefono = tel AND Activo = act;
    ELSE 
        set res = -1;
    END IF;
END$$

现在我在C#中写这个来从FUNCTIONS返回值

    public object ejecutarFuncion()
    {
        using (MySqlConnection conn = new MySqlConnection(stringDeConexion))
        {
            using (MySqlCommand cmd = new MySqlCommand(procedimiento, conn))
            {
                cmd.CommandType = System.Data.CommandType.StoredProcedure;
                //Se abre la conexión
                conn.Open();
                //existen parámetros los recorremos y agregamos.
                foreach (KeyValuePair<string, object> pars in parametros)
                {
                    cmd.Parameters.Add(new MySqlParameter(pars.Key, pars.Value));
                }
                //Se crea la variable de retorno
                cmd.Parameters.Add(new MySqlParameter(nombreOut, tipoParOut));
                cmd.Parameters[nombreOut].Direction = System.Data.ParameterDirection.ReturnValue;
                cmd.ExecuteNonQuery();
                // Cerramos conexión
                conn.Close();
                return cmd.Parameters[nombreOut].Value;
            }
        }
    }

如果你看到我在这里做一个ExecuteNonQuery(),但我应该使用Execute Scalar吗？或者只使用parms的返回值？

然后我写了这个方法来执行带有输出值的程序(其中一些做更新,插入)操作,我使用输出值来检查操作是否正确完成.

public object ejecutarProcedimientoConOutput()
{
    using (MySqlConnection conn = new MySqlConnection(stringDeConexion))
    {
        using (MySqlCommand cmd = new MySqlCommand(procedimiento, conn))
        {
            cmd.CommandType = System.Data.CommandType.StoredProcedure;
            //Se abre la conexión
            conn.Open();
            //verificamos si se mando la lista de parámetros
            if (parametros.Count > 0)
            {
                //existen parámetros los recorremos y agregamos.
                foreach (KeyValuePair<string, object> pars in parametros)
                {
                    cmd.Parameters.Add(new MySqlParameter(pars.Key, pars.Value));
                    cmd.Parameters[pars.Key].Direction = System.Data.ParameterDirection.Input;
                }
            }
            cmd.Parameters.Add(new MySqlParameter(nombreOut, tipoParOut));
            cmd.Parameters[nombreOut].Direction = System.Data.ParameterDirection.Output;
            cmd.ExecuteNonQuery();
            conn.Close();
            return cmd.Parameters[nombreOut].Value;
        }
    }
}

再次,如果我正在进行更新或插入操作,但我使用输出参数来检查它是否已完成,您可以检查插入存储过程我应该使用ExecuteNonQuery还是ExecuteScalar？

并且对于返回数据集的过程与我上面编写的方法相同,但没有输出参数,我使用的是executeReader,因为我只执行select而不使用output参数.

我只是想知道我是否正在为这些程序使用正确的执行命令.

Answer 1

• 如果要返回受查询影响的行数,请使用ExecuteNonReader().

• 如果要返回第一行的第一列,请使用 ExecuteScalar.

• 如果您需要SqlDataReader创建一个,那么您可以迭代结果然后使用ExecuteReader.

因此,您可以使用ExecuteScalar您的函数,retornarIdArea因为您只返回一列和一行(id),因此此函数适合上下文.

对于您的过程,consultar_n_asunto您可以ExecuteReader在选择多行时使用,并期望返回结果集.