我在存储过程中使用参数时遇到问题。我认为我没有用C#正确地传递参数。
我的代码大致相当于:
public static string GetCustomer(string storedProcedure, string connectionString)
{
DataTable dt = new DataTable();
using (MySqlConnection con = new MySqlConnection(connectionString))
{
using (MySqlCommand cmd = new MySqlCommand(storedProcedure, con))
{
cmd.Parameters.AddWithValue("_table1", "table1");
cmd.Parameters.AddWithValue("_table2", "table2");
con.Open();
MySqlDataAdapter da = new MySqlDataAdapter(cmd);
IDataParameter[] temp = da.GetFillParameters();//returns 2 parameters
da.Fill(dt);//Breaks here with the error below
//Irrelevant code
}
}
return "";
}
PROCEDURE tspos.get_customer的参数数量不正确;预期2,得到0
DROP PROCEDURE IF EXISTS get_customer;
DELIMITER //
CREATE PROCEDURE get_customer
(
IN _table1 VARCHAR(25),
IN _table2 VARCHAR(25)
)
BEGIN
SET @t1 = CONCAT('SELECT a.*, b.* FROM ', _table1, ' a, ', _table2, ' b');
PREPARE statement FROM @t1;
EXECUTE statement;
DEALLOCATE PREPARE statement;
END //
DELIMITER ;
下面的调用按预期工作,所以我想我的问题在C#中
CALL get_customer('table1', 'table2');
CALL get_customer('table3', 'table4');
我认为参数的名称应该以@
符号为前缀:
cmd.Parameters.AddWithValue("@_table1", "table1");
cmd.Parameters.AddWithValue("@_table2", "table2");
此外,请确保正确设置命令类型:
using (MySqlConnection con = new MySqlConnection(connectionString))
{
using (MySqlCommand cmd = new MySqlCommand(storedProcedure, con))
{
//Set command type
cmd.CommandType = CommandType.StoredProcedure;
con.Open();
MySqlDataAdapter da = new MySqlDataAdapter(cmd);
cmd.Parameters.AddWithValue("@_table1", "table1");
cmd.Parameters.AddWithValue("@_table2", "table2");
IDataParameter[] temp = da.GetFillParameters();//returns 2 parameters
da.Fill(dt);
//Irrelevant code
}
}
由于您使用了MySqlDataAdapter
,最好使用SqlDataAdapter.SelectCommand Property
指定参数,也不要忘记,您需要在参数名称之前添加一个@
,类似于以下内容:
da.SelectCommand.Parameters.AddWithValue("@_table1", "table1");
虽然直接指定类型并使用Value属性比AddWithValue
更好。
我们可以停止使用AddWithValue((吗?
作为另一点,您需要使用以下代码指定要存储的命令的类型:
cmd.CommandType = CommandType.StoredProcedure;