200字范文,内容丰富有趣,生活中的好帮手!
200字范文 > c# 调用mysql存储过程 返回值_C#调用MySQL存储过程 函数的最佳方法

c# 调用mysql存储过程 返回值_C#调用MySQL存储过程 函数的最佳方法

时间:2019-09-24 04:35:58

相关推荐

c# 调用mysql存储过程 返回值_C#调用MySQL存储过程 函数的最佳方法

您好,我写了我的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))

{

mandType = mandType.StoredProcedure;

//Se abre la conexión

conn.Open();

//existen parámetros los recorremos y agregamos.

foreach (KeyValuePair 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;

}

}

}

If you see I do a ExecuteNonQuery() here, but should I used Execute Scalar? or just use the return value from parms?

然后,我编写了此方法以使用输出值(其中一些进行更新,插入)操作来执行Procedures,然后使用输出值来检查操作是否正确完成。

public object ejecutarProcedimientoConOutput()

{

using (MySqlConnection conn = new MySqlConnection(stringDeConexion))

{

using (MySqlCommand cmd = new MySqlCommand(procedimiento, conn))

{

mandType = mandType.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 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,因为我仅执行选择操作而不使用输出参数。

我只想知道我是否对这些过程使用了正确的执行命令。

如果要返回受查询影响的行数

然后使用ExecuteNonReader()。

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

ExecuteScalar。

如果您需要创建SqlDataReader以便进行迭代

在结果上使用ExecuteReader。

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

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

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。