在C#中使用MySql.Data执行一个Insert语句,获取新增的自增主键。
使用的commandText如下:
INSERT T_Test_Table
(
Name
)
VALUES
(
@Name -- Name - nvarchar(50)
);SET @Id = @@IDENTITY
该语句在Mysql中无论是用存储过程执行,还是直接输入参数执行,都不会报错;
在C#程序中。
设置参数化属性如下:
MySqlParameter mpName = new MySqlParameter("Name",MySqlDbType.Varchar,50,"Test");
mpName.Direction = ParameterDirection.Input;
MySqlParameter mpId = new MySqlParameter("Id",MySqlDbType.Int32);
mpId.Direction = ParameterDirection.OutPut;
代码执行后报错:
You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'NULL = @@IDENTITY' at line 1
这里不知道为什么:
SET @Id = @@IDENTITY 中 @Id被替换为 NULL;
由于未写事务的缘故,查询数据库发现数据已新增成功。
这是什么问题?应该怎么解决?求解。
数据库结构如下:
SET FOREIGN_KEY_CHECKS=0;
-- ----------------------------
-- Table structure for t_test_table
-- ----------------------------
DROP TABLE IF EXISTS `t_test_table`;
CREATE TABLE `t_test_table` (
`Id` int(11) NOT NULL AUTO_INCREMENT,
`Name` varchar(50) DEFAULT NULL,
PRIMARY KEY (`Id`)
) ENGINE=MyISAM AUTO_INCREMENT=73 DEFAULT CHARSET=utf8mb4;
附完整代码:
public static void Test()
{
try
{
string connetStr = "data source=127.0.0.1;database=Test; uid=root;pwd=root;Allow User Variables=True;";
MySqlConnection conn = new MySqlConnection(connetStr);
conn.Open();
string sql =
@"INSERT T_Test_Table
(
Name
)
VALUES
(
@Name -- Name - nvarchar(50)
);
SET @Id = @@IDENTITY";//在sql语句中定义parameter,然后再给parameter赋值
MySqlCommand cmd = new MySqlCommand(sql, conn);
MySqlParameter mpName = new MySqlParameter("Name", MySqlDbType.VarChar, 50);
mpName.Value = "Tests";
mpName.Direction = ParameterDirection.Input;
MySqlParameter mpId = new MySqlParameter("Id", MySqlDbType.Int32);
mpId.Direction = ParameterDirection.Output;
cmd.Parameters.Add(mpName);
cmd.Parameters.Add(mpId);
int iRes = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
conn.Close();
}
catch(Exception ex)
{
Console.WriteLine(ex.ToString());
throw new Exception("Mysql执行出错:\r\n" + ex.Message, ex);
}
}