206

如何执行插入数据库并使用 Dapper 返回插入的身份？

我试过这样的事情：

string sql = "DECLARE @ID int; " +
             "INSERT INTO [MyTable] ([Stuff]) VALUES (@Stuff); " +
             "SELECT @ID = SCOPE_IDENTITY()";

var id = connection.Query<int>(sql, new { Stuff = mystuff}).First();

但它没有用。

@Marc Gravell 谢谢您的回复。我已经尝试过您的解决方案，但是下面仍然是相同的异常跟踪

System.InvalidCastException: Specified cast is not valid

at Dapper.SqlMapper.<QueryInternal>d__a`1.MoveNext() in (snip)\Dapper\SqlMapper.cs:line 610
at System.Collections.Generic.List`1..ctor(IEnumerable`1 collection)
at System.Linq.Enumerable.ToList[TSource](IEnumerable`1 source)
at Dapper.SqlMapper.Query[T](IDbConnection cnn, String sql, Object param, IDbTransaction transaction, Boolean buffered, Nullable`1 commandTimeout, Nullable`1 commandType) in (snip)\Dapper\SqlMapper.cs:line 538
at Dapper.SqlMapper.Query[T](IDbConnection cnn, String sql, Object param) in (snip)\Dapper\SqlMapper.cs:line 456
4

9 回答 9

356

如果您使用 ，它确实支持输入/输出参数（包括RETURN值）DynamicParameters，但在这种情况下，更简单的选项很简单：

var id = connection.QuerySingle<int>( @"
INSERT INTO [MyTable] ([Stuff]) VALUES (@Stuff);
SELECT CAST(SCOPE_IDENTITY() as int)", new { Stuff = mystuff});

请注意，在较新版本的 SQL Server (2005+) 上，您可以使用以下OUTPUT子句：

var id = connection.QuerySingle<int>( @"
INSERT INTO [MyTable] ([Stuff])
OUTPUT INSERTED.Id
VALUES (@Stuff);", new { Stuff = mystuff});
于 2011-11-25T14:07:03.813 回答
56

KB:2019779，“在使用 SCOPE_IDENTITY() 和 @@IDENTITY 时，您可能会收到不正确的值”，OUTPUT 子句是最安全的机制：

string sql = @"
DECLARE @InsertedRows AS TABLE (Id int);
INSERT INTO [MyTable] ([Stuff]) OUTPUT Inserted.Id INTO @InsertedRows
VALUES (@Stuff);
SELECT Id FROM @InsertedRows";

var id = connection.Query<int>(sql, new { Stuff = mystuff}).Single();
于 2012-09-27T10:31:14.840 回答
54

一个迟到的答案，但这是我们最终使用的答案的替代方案： OUTPUT INSERTEDSCOPE_IDENTITY()

仅返回插入对象的 ID：

它允许您获取插入行的全部或部分属性：

string insertUserSql = @"INSERT INTO dbo.[User](Username, Phone, Email)
                        OUTPUT INSERTED.[Id]
                        VALUES(@Username, @Phone, @Email);";

int newUserId = conn.QuerySingle<int>(
                                insertUserSql,
                                new
                                {
                                    Username = "lorem ipsum",
                                    Phone = "555-123",
                                    Email = "lorem ipsum"
                                },
                                tran);

返回带有 ID 的插入对象：

Phone如果您愿意，您可以获得Email甚至整个插入的行：

string insertUserSql = @"INSERT INTO dbo.[User](Username, Phone, Email)
                        OUTPUT INSERTED.*
                        VALUES(@Username, @Phone, @Email);";

User newUser = conn.QuerySingle<User>(
                                insertUserSql,
                                new
                                {
                                    Username = "lorem ipsum",
                                    Phone = "555-123",
                                    Email = "lorem ipsum"
                                },
                                tran);

此外，您还可以返回已删除或更新行的数据。如果您使用触发器，请小心，因为（来自前面提到的链接）：

从 OUTPUT 返回的列反映了在 INSERT、UPDATE 或 DELETE 语句完成之后但在触发器执行之前的数据。

对于 INSTEAD OF 触发器，返回的结果就像 INSERT、UPDATE 或 DELETE 实际发生一样生成，即使触发器操作的结果没有发生任何修改。如果在触发器的主体内使用包含 OUTPUT 子句的语句，则必须使用表别名来引用触发器插入和删除的表，以避免与与 OUTPUT 关联的 INSERTED 和 DELETED 表重复列引用。

更多关于它的文档：链接

于 2017-11-04T11:51:52.690 回答
7

您得到的 InvalidCastException 是由于 SCOPE_IDENTITY 是Decimal(38,0)。

您可以通过将其转换为 int 来返回它，如下所示：

string sql = @"
INSERT INTO [MyTable] ([Stuff]) VALUES (@Stuff);
SELECT CAST(SCOPE_IDENTITY() AS INT)";

int id = connection.Query<int>(sql, new { Stuff = mystuff}).Single();
于 2012-06-28T20:24:11.487 回答
4

不确定是不是因为我正在使用 SQL 2000，但我必须这样做才能让它工作。

string sql = "DECLARE @ID int; " +
             "INSERT INTO [MyTable] ([Stuff]) VALUES (@Stuff); " +
             "SET @ID = SCOPE_IDENTITY(); " +
             "SELECT @ID";

var id = connection.Query<int>(sql, new { Stuff = mystuff}).Single();
于 2012-04-18T21:01:07.057 回答
1

有一个很棒的库可以让你的生活更轻松 Dapper.Contrib.Extensions。包括这个之后，你可以写： 

public int Add(Transaction transaction)
{
        using (IDbConnection db = Connection)
        {
                return (int)db.Insert(transaction);
        }
}
于 2019-02-12T11:53:47.433 回答
1

我看到了 sql server 的答案，这里是使用事务的 MySql


    Dim sql As String = "INSERT INTO Empleado (nombres, apepaterno, apematerno, direccion, colonia, cp, municipio, estado, tel, cel, correo, idrol, relojchecadorid, relojchecadorid2, `activo`,`extras`,`rfc`,`nss`,`curp`,`imagen`,sueldoXHra, IMSSCotiza, thumb) VALUES (@nombres, @apepaterno, @apematerno, @direccion, @colonia, @cp, @municipio, @estado, @tel, @cel, @correo, @idrol, @relojchecadorid, @relojchecadorid2, @activo, @extras, @rfc, @nss, @curp, @imagen,@sueldoXHra,@IMSSCotiza, @thumb)"
    
            Using connection As IDbConnection = New MySqlConnection(getConnectionString())
                connection.Open()
                Using transaction = connection.BeginTransaction
                    Dim res = connection.Execute(sql, New With {reg.nombres, reg.apepaterno, reg.apematerno, reg.direccion, reg.colonia, reg.cp, reg.municipio, reg.estado, reg.tel, reg.cel, reg.correo, reg.idrol, reg.relojchecadorid, reg.relojchecadorid2, reg.activo, reg.extras, reg.rfc, reg.nss, reg.curp, reg.imagen, reg.thumb, reg.sueldoXHra, reg.IMSSCotiza}, commandTimeout:=180, transaction:=transaction)
                    lastInsertedId = connection.ExecuteScalar("SELECT LAST_INSERT_ID();", transaction:=transaction)
                    If res > 0 Then 
transaction.Commit()
return true
end if
                    
                End Using
            End Using
于 2020-11-23T20:27:23.527 回答
0

如果您使用 Dapper.SimpleSave：

 //no safety checks
 public static int Create<T>(object param)
    {
        using (SqlConnection conn = new SqlConnection(GetConnectionString()))
        {
            conn.Open();
            conn.Create<T>((T)param);
            return (int) (((T)param).GetType().GetProperties().Where(
                    x => x.CustomAttributes.Where(
                        y=>y.AttributeType.GetType() == typeof(Dapper.SimpleSave.PrimaryKeyAttribute).GetType()).Count()==1).First().GetValue(param));
        }
    }
于 2016-08-22T11:22:32.307 回答
0

我使用 .net core 3.1 和 postgres 12.3。基于 Tadija Bagarić 的回答，我最终得到：

using (var connection = new NpgsqlConnection(AppConfig.CommentFilesConnection))
        {

            string insertUserSql = @"INSERT INTO mytable(comment_id,filename,content)
                    VALUES( @commentId, @filename, @content) returning id;";

            int newUserId = connection.QuerySingle<int>(
                                            insertUserSql,
                                            new
                                            {
                                                commentId = 1,
                                                filename = "foobar!",
                                                content = "content"
                                            }
                                            );

          


        }

其中 AppConfig 是我自己的类，它只是为我的连接详细信息设置一个字符串。这是在 Startup.cs ConfigureServices 方法中设置的。

于 2021-02-06T09:59:32.937 回答