【问题标题】:Execute Insert command and return inserted Id in Sql在Sql中执行插入命令并返回插入的Id
【发布时间】:2013-08-24 18:30:59
【问题描述】:

我在 MVC 4 中使用 C# 将一些值插入到 SQL 表中。实际上,我想插入值并返回最后插入记录的“ID”。我使用以下代码。

public class MemberBasicData
{
    public int Id { get; set; }
    public string Mem_NA { get; set; }
    public string Mem_Occ { get; set; }     
}

插入时ID在数据库中自动递增。

public int CreateNewMember(string Mem_NA, string Mem_Occ )
{
    using (SqlConnection con=new SqlConnection(Config.ConnectionString))
    {
        using(SqlCommand cmd=new SqlCommand("INSERT INTO Mem_Basic(Mem_Na,Mem_Occ) VALUES(@na,@occ)",con))
        {
            cmd.Parameters.AddWithValue("@na", Mem_NA);
            cmd.Parameters.AddWithValue("@occ", Mem_Occ);
            con.Open();

            int modified = cmd.ExecuteNonQuery();

            if (con.State == System.Data.ConnectionState.Open) con.Close();
                return modified;
        }
    }
}
   

我知道ExecuteNonQuery 表示影响行的数字。而不是我使用

int modified = (int)cmd.ExecuteScalar();

但它不起作用。请帮我解决这个问题。有没有像cmd.ExecuteInsertAndGetID() 这样的代码(不适用于我的代码)。

【问题讨论】:

标签: c# sql sql-server asp.net-mvc-4


【解决方案1】:

以下解决方案适用于 sql server 2005 及更高版本。您可以使用output 获取必填字段。代替 id 你可以写你想要返回的密钥。这样做

适用于 SQL SERVER 2005 及更高版本

    using(SqlCommand cmd=new SqlCommand("INSERT INTO Mem_Basic(Mem_Na,Mem_Occ) output INSERTED.ID VALUES(@na,@occ)",con))
    {
        cmd.Parameters.AddWithValue("@na", Mem_NA);
        cmd.Parameters.AddWithValue("@occ", Mem_Occ);
        con.Open();

        int modified =(int)cmd.ExecuteScalar();

        if (con.State == System.Data.ConnectionState.Open) 
            con.Close();

        return modified;
    }
}

对于以前的版本

    using(SqlCommand cmd=new SqlCommand("INSERT INTO Mem_Basic(Mem_Na,Mem_Occ)  VALUES(@na,@occ);SELECT SCOPE_IDENTITY();",con))
    {
        cmd.Parameters.AddWithValue("@na", Mem_NA);
        cmd.Parameters.AddWithValue("@occ", Mem_Occ);
        con.Open();

        int modified = Convert.ToInt32(cmd.ExecuteScalar());

        if (con.State == System.Data.ConnectionState.Open) con.Close();
            return modified;
    }
}

【讨论】:

  • int modified = (int)cmd.ExecuteScalar();
  • 注意列名必须与表的标识列名匹配。例如具有此标识列名称的表:select EmployeeId, * from Employees 在插入语句中需要此片段:output inserted.EmployeeId
  • 在这种情况下,您将如何检查查询是否确实进行了插入?
  • 我在尝试将 int modified = (int)cmd.ExecuteScalar(); 转换为 int 时遇到无效转换错误。我不得不使用 Convert 将其转换为 int。 int modified = Convert.ToInt32(cmd.ExecuteScalar());
  • 下面的修改对我有用。 INSERT INTO Mem_Basic(Mem_Na,Mem_Occ) 输出 INSERTED.ID VALUES(?, ?)
【解决方案2】:

将查询更改为

"INSERT INTO Mem_Basic(Mem_Na,Mem_Occ) VALUES(@na,@occ); SELECT SCOPE_IDENTITY()"

这将返回最后插入的 ID,然后您可以使用 ExecuteScalar 获得该 ID

【讨论】:

  • 这显示错误“InValidCast Exception was unhandled by user code”
  • @neel,这是因为 scope_identity() 返回数字数据类型,您只能针对十进制 .net 数据类型进行转换。另一种方法是使用 Convert.To() 系列函数来避免强制转换问题。
  • 这个答案更好,因为您不必输入要插入的表的 ID 列。
  • SELECT SCOPE_IDENTITY() 对我不起作用,但输出 INSERTED.ID 是。
  • @TiggerToo:您使用的是什么版本的 SQL Server?微软可能最终弃用了SCOPE_IDENTITY()OUTPUT INSERTED 出现在 IIRC SQL Server 2008 中,自此成为首选方式
【解决方案3】:

SQL Server 存储过程:

CREATE PROCEDURE [dbo].[INS_MEM_BASIC]
    @na varchar(50),
    @occ varchar(50),
    @New_MEM_BASIC_ID int OUTPUT
AS
BEGIN
    SET NOCOUNT ON;

    INSERT INTO Mem_Basic
    VALUES (@na, @occ)

    SELECT @New_MEM_BASIC_ID = SCOPE_IDENTITY()
END

C#代码:

public int CreateNewMember(string Mem_NA, string Mem_Occ )
{
    // values 0 --> -99 are SQL reserved.
    int new_MEM_BASIC_ID = -1971;   
    SqlConnection SQLconn = new SqlConnection(Config.ConnectionString);
    SqlCommand cmd = new SqlCommand("INS_MEM_BASIC", SQLconn);

    cmd.CommandType = CommandType.StoredProcedure;

    SqlParameter outPutVal = new SqlParameter("@New_MEM_BASIC_ID", SqlDbType.Int);

    outPutVal.Direction = ParameterDirection.Output;
    cmd.Parameters.Add(outPutVal);
    cmd.Parameters.Add("@na", SqlDbType.Int).Value = Mem_NA;
    cmd.Parameters.Add("@occ", SqlDbType.Int).Value = Mem_Occ;

    SQLconn.Open();
    cmd.ExecuteNonQuery();
    SQLconn.Close();

    if (outPutVal.Value != DBNull.Value) new_MEM_BASIC_ID = Convert.ToInt32(outPutVal.Value);
        return new_MEM_BASIC_ID;
}

希望这些对你有帮助....

如果你愿意,你也可以使用它...

public int CreateNewMember(string Mem_NA, string Mem_Occ )
{
    using (SqlConnection con=new SqlConnection(Config.ConnectionString))
    {
        int newID;
        var cmd = "INSERT INTO Mem_Basic(Mem_Na,Mem_Occ) VALUES(@na,@occ);SELECT CAST(scope_identity() AS int)";

        using(SqlCommand cmd=new SqlCommand(cmd, con))
        {
            cmd.Parameters.AddWithValue("@na", Mem_NA);
            cmd.Parameters.AddWithValue("@occ", Mem_Occ);

            con.Open();
            newID = (int)insertCommand.ExecuteScalar();

            if (con.State == System.Data.ConnectionState.Open) con.Close();
                return newID;
        }
    }
}

【讨论】:

    【解决方案4】:
    USE AdventureWorks2012;
    GO
    IF OBJECT_ID(N't6', N'U') IS NOT NULL 
        DROP TABLE t6;
    GO
    IF OBJECT_ID(N't7', N'U') IS NOT NULL 
        DROP TABLE t7;
    GO
    CREATE TABLE t6(id int IDENTITY);
    CREATE TABLE t7(id int IDENTITY(100,1));
    GO
    CREATE TRIGGER t6ins ON t6 FOR INSERT 
    AS
    BEGIN
       INSERT t7 DEFAULT VALUES
    END;
    GO
    --End of trigger definition
    
    SELECT id FROM t6;
    --IDs empty.
    
    SELECT id FROM t7;
    --ID is empty.
    
    --Do the following in Session 1
    INSERT t6 DEFAULT VALUES;
    SELECT @@IDENTITY;
    /*Returns the value 100. This was inserted by the trigger.*/
    
    SELECT SCOPE_IDENTITY();
    /* Returns the value 1. This was inserted by the 
    INSERT statement two statements before this query.*/
    
    SELECT IDENT_CURRENT('t7');
    /* Returns value inserted into t7, that is in the trigger.*/
    
    SELECT IDENT_CURRENT('t6');
    /* Returns value inserted into t6. This was the INSERT statement four statements before this query.*/
    
    -- Do the following in Session 2.
    SELECT @@IDENTITY;
    /* Returns NULL because there has been no INSERT action 
    up to this point in this session.*/
    
    SELECT SCOPE_IDENTITY();
    /* Returns NULL because there has been no INSERT action 
    up to this point in this scope in this session.*/
    
    SELECT IDENT_CURRENT('t7');
    /* Returns the last value inserted into t7.*/
    

    【讨论】:

      【解决方案5】:
      SELECT SCOPE_IDENTITY() AS 'Identity'
      

      这将返回仅在当前范围内插入的标识值

      SELECT @@IDENTITY AS 'Identity'; 
      

      这不限于特定范围 所以这将返回标识列的最新值,不一定是同一范围内的标识值。

      【讨论】:

        【解决方案6】:

        如果你使用 EF:

         Class Person{
         public int Id {get;set;}
         public string Name {get;set;}
        }
        

        您设置名称值:

         Person p = new Person(){
          Name = "James"
        };
        DbContext.Persons.Add(p);
        DbContext.SaveChanges();
        
        //p.Id = new Id from database
        //p.Name = James
        

        您只需保存它,您将从数据库中获取 Id。

        【讨论】:

          【解决方案7】:
          using(SqlCommand cmd=new SqlCommand("INSERT INTO Mem_Basic(Mem_Na,Mem_Occ) " +
              "VALUES(@na,@occ);SELECT SCOPE_IDENTITY();",con))
          {
              cmd.Parameters.AddWithValue("@na", Mem_NA);
              cmd.Parameters.AddWithValue("@occ", Mem_Occ);
              con.Open();
          
              int modified = cmd.ExecuteNonQuery();
          
              if (con.State == System.Data.ConnectionState.Open) con.Close();
                  return modified;
          }
          

          SCOPE_IDENTITY :返回插入到同一范围内的标识列中的最后一个标识值。更多详情http://technet.microsoft.com/en-us/library/ms190315.aspx

          【讨论】:

          猜你喜欢
          • 2017-09-13
          • 2021-04-27
          • 1970-01-01
          • 1970-01-01
          • 1970-01-01
          • 1970-01-01
          • 1970-01-01
          相关资源
          最近更新 更多