当前位置：首页 > news >正文

EF Core 执行原生SQL语句

news 来源：原创 2025/5/24 12:40:31

文章目录

前言
一、执行查询（返回数据）
- 1）使用 FromSqlRaw或 FromSqlInterpolated 方法，适用于 DbSet<T>，返回实体集合。
- 2）结合 LINQ 查询
二、执行非查询操作（增删改）
- 1）使用 ExecuteSqlRaw() 或 ExecuteSqlInterpolated() 、ExecuteSqlInterpolatedAsync()方法，返回受影响的行数。
三、调用存储过程
- 1）执行查询存储过程
- 2）执行非查询存储过程
四、事务处理
- 1）确保多个 SQL 操作原子性
五、原生 SQL 查询的注意事项
总结

前言

为什么要写原生SQL语句？

尽管EF Core已经非常强大，但是任然存在着无法被写成标准EF Core调用方法的SQL语句，少数情况下任然需要写原生SQL。
存在问题：可能无法跨数据库操作。

一、执行查询（返回数据）

1）使用 FromSqlRaw或 FromSqlInterpolated 方法，适用于 DbSet，返回实体集合。

示例：查询数据（建议使用FromSqlInterpolated，防止SQL注入）

var blogs = context.Blogs
    .FromSqlRaw("SELECT * FROM Blogs WHERE Rating > {0}", 3)
    .ToList();

// 或使用插值字符串（参数化，防注入）
var rating = 3;
var blogsSafe = context.Blogs
    .FromSqlInterpolated($"SELECT * FROM Blogs WHERE Rating > {rating}")
    .ToList();

2）结合 LINQ 查询

var filteredBlogs = context.Blogs
    .FromSqlInterpolated("SELECT * FROM Blogs")
    .Where(b => b.Url.Contains("dotnet"))
    .OrderBy(b => b.Rating)
    .ToList();

二、执行非查询操作（增删改）

1）使用 ExecuteSqlRaw() 或 ExecuteSqlInterpolated() 、ExecuteSqlInterpolatedAsync()方法，返回受影响的行数。

示例：更新数据

var rowsAffected = context.Database.ExecuteSqlRaw(
    "UPDATE Blogs SET Rating = 5 WHERE Name LIKE '%EF Core%'");

// 参数化示例
var minRating = 3;
var rowsSafe = await context.Database.ExecuteSqlInterpolatedAsync(
    $"DELETE FROM Blogs WHERE Rating < {minRating}");

三、调用存储过程

1）执行查询存储过程

var blogs = context.Blogs
    .FromSqlRaw("EXEC GetTopRatedBlogs @p0", 5)
    .ToList();

2）执行非查询存储过程

context.Database.ExecuteSqlRaw("EXEC ArchiveOldBlogs @p0", DateTime.Now.AddYears(-1));

四、事务处理

1）确保多个 SQL 操作原子性

using (var transaction = context.Database.BeginTransaction())
{
    try
    {
        context.Database.ExecuteSqlRaw("UPDATE Blogs SET Rating = 5 WHERE BlogId = 1");
        context.Database.ExecuteSqlRaw("DELETE FROM Blogs WHERE BlogId = 2");
        transaction.Commit();
    }
    catch
    {
        transaction.Rollback();
    }
}