Entity Framework查询,EF执行SQl

一、简介

EF 支持开放底层的 ADO.NET 框架，DbContext有三种常用方法

DbSet.SqlQuery 　　　　　　　　　　　　　　　　//查询并返回Entities
DbContext.Database.SqlQuery<T>    　　     //执行某一个查询，并可以将返回集转换为某一对象
DbContext.Database.ExecuteSqlCommand    　 //执行某一并无返回集的SQL 命令，例如UPDATE，DELETE操作

二、用法

1、DbSet.SqlQuery用法

            var list = db.admins.SqlQuery("select * from admin");
            foreach (var item in list)
            {
                Response.Write(item.username);
                Response.Write("<br>");
            }

2.使用SqlQuery在已知的实体上执行存储过程

 

1 2 3 4

using (var context = new MyDBContext()) {     var posts = context.Posts.SqlQuery("dbo.spGetTopPosts").ToList(); }

这里的Posts必须是程序项目或者引用中已声明的实体类，ToList()是必须的，否则SQL查询将不会被执行。以上代码将执行存储过程: spGetTopPosts

2、DbContext.Database.SqlQuery<T>用法

            var list = db.Database.SqlQuery<admin>("select * from admin").ToList();
            foreach (var item in list)
            {
                Response.Write(item.username);
                Response.Write("<br>");
            }

3、DbContext.Database.ExecuteSqlCommand用法

var res=db.Database.ExecuteSqlCommand("update admin set password='123456'");
            Response.Write(res);

说明：1和2的结果一样

5.使用SqlQuery执行带参数的SQL查询语句

这是一种相比更安全的，可避免SQL注入攻击的执行原始SQL查询语句的方式

 

1 2 3 4 5

using (var context = new MyDBContext()) {      var userSuppliedAuthor = new SqlParameter("@author", "Adi");      context.Database.SqlQuery(typeof(Post), "SELECT * FROM dbo.Posts WHERE Author = @author", userSuppliedAuthor); }

这里的SQL语句将查询Posts表，所以用到了typeof(Post)。如果JOIN语句来查询不同的两张表的话，就需要写一个内部类来返回SQL语句的查询结果。

以下则是一个使用JOIN连接查询的具体实例。

假如有Posts,Category,Posts_Category这三张表。Posts_Category是Post表中Post Id列以及Category表中Category Id列的映射表。如果我们执行如下的JOIN连接SQL查询：

 

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15

internal class MappingData {   public string CategoryTitle { get; set; }   public string PostTitle { get; set; }   public long? MappingId { get; set; } }   using (var context = new MyDBContext()) { var userSuppliedId = new SqlParameter("@PostId", PostID); string sqlQuery = @"select c.Name CategoryTitle, pcm.Id MappingId, p.Title PostTitle from Posts_Categories pcm                                 join Categories c on pcm.CategoryId = c.Id                                 join Posts p on pcm.PostId = p.Id where pcm.PostId =@PostId"; var Results = db.Database.SqlQuery<MappingData>(sqlQuery,userSuppliedId).ToList(); }

查询结果将是所有给定Post的Categories列表。

三、总结

原生SQL执行查询：

需要返回实体模型，使用DbSet.SqlQuery （context会跟踪，等效于LINQ方式）

需要返回其他类型，使用Database.SqlQuery

原生SQL执行更新：

使用Database.ExecuteSqlCommand

你可能要问，我用EF不就为了避免写SQL吗？如果要写SQL我不如直接用ADO.NET得了。话虽然这么说没错，可有些时候使用EF操作数据还是有一些不方便，例如让你根据条件删除一组记录，如果按照正常的流程来走，你就得先把这些数据查出来，然后再一条一条地删除它们，这样不仅麻烦而且性能也比较低。这种情况下SQL就显示出它的威力了。

而使用EF执行SQL又比ADO.NET方便，特别是在执行查询语句的时候，EF会把查询到的数据自动保存到数据实体中，省去了使用DataReader的麻烦。同时查询出来的数据还会进行跟踪，如果你修改了查询出的值，之后就可以很方便的使用.SaveChanges()直接更新到数据库了。

ExecuteSqlCommand与SqlQuery

在数据上下文DBModel的实例中有个Database属性，其中有两组方法.ExecuteSqlCommand()和.SqlQuery()。它们都可以执行SQL语句，只不过.ExecuteSqlCommand()是不返回结果的，只返回受影响的行数，所以.ExecuteSqlCommand()更适合执行创建、更新、删除操作。.SqlQuery()则会返回查询到的结果，并将结果保存在数据实体中，所以更适合执行查询操作。

使用.ExecuteSqlCommand()实现创建、更新、删除

.ExecuteSqlCommand()的使用方法也很简单，直接传入SQL语句就可以了，执行完成后会返回受影响的行数。

1. using (var db = new DBModel()) //创建数据库上下文
2. {
3. //同步的方式执行SQL，并返回受影响的行数
4. int result = db.Database.ExecuteSqlCommand(@"CREATE TABLE `test`.`test` (
5. `id` INT NOT NULL,
6. PRIMARY KEY(`id`)); ");
8. //使用SqlParameter传值可以避免SQL注入
9. var p_name = new SqlParameter("@name", "萝莉");
10. var p_age = new SqlParameter("@age", 13);
12. //如果使用的是MySql数据库 需要SqlParameter把替换为MySqlParameter
13. //var p_name = new MySqlParameter("@name", "萝莉");
14. //var p_age = new MySqlParameter("@age", 13);
16. //更改学生年龄
17. result = db.Database.ExecuteSqlCommand(@"UPDATE `test`.`student`
18. SET `age` = @age
19. WHERE `name` = @name;", p_age, p_name);
21. //异步的方式执行SQL，并返回受影响的行数
22. Task<int> result2 = db.Database.ExecuteSqlCommandAsync("DROP TABLE `test`.`test`;");
23. }

PS：如果需要创建或删除当前数据库，Database属性中还存在.Create() 和.Delete()方法，它们不接受参数，返回一个bool值表示执行成功或失败。

使用.SqlQuery()查询数据

从名字就看的出来.SqlQuery()是用来执行查询的。.SqlQuery()使用前需指定返回值的数据类型，比如我查询寻一条学生的完整信息，类型就可以指定为student类型。如果是统计有多少个学生，返回值是个整数，就以设置为int。

注意：不仅返回值的个数必须与传入类型中属性值的个数相同，而且名称还必须一样，不然会出错。那么如果我只想获取姓名和年龄，那就得单独定义一个类（其中包含一个string类型的name和int类型的age），来保存数据了。

 

1. class temp
2. {
3. public string name { get; set; }
5. public int age { get; set; }
6. }
8. static void Main(string[] args)
9. {
10. using (var db = new DBModel()) //创建数据库上下文
11. {
12. //查询叫萝莉的学生信息，并指定返回值类型为student
13. DbRawSqlQuery<student> result1 = db.Database.SqlQuery<student>("SELECT * FROM test.student WHERE name = '萝莉'");
14. //也可以这样指定返回值类型
15. //DbRawSqlQuery result1 = db.Database.SqlQuery(typeof(student), "SELECT * FROM test.student WHERE name = '萝莉'");
16. Console.WriteLine(result1.FirstOrDefault().name); //打印姓名
18. DbRawSqlQuery<int> result2 = db.Database.SqlQuery<int>("SELECT count(*) FROM test.student");
19. Console.WriteLine(result2.FirstOrDefault()); //打印有多少学生
21. //只查询学生的年龄与姓名
22. var result3 = db.Database.SqlQuery<temp>("SELECT `name`,`age` FROM test.student;");
23. foreach (temp item in result3)
24. {
25. Console.WriteLine(item.name + ":" + item.age);
26. }
27. }

使用DbSet<T>下的.SqlQuery()

在每个数据实体集合DbSet<T>下也有一个.SqlQuery()，功能与上面介绍的一样，只不过DbSet<T>下的.SqlQuery()只能返回DbSet<T>中包含的类型。但DbSet<T>下的.SqlQuery()在返回数据的同时还会让数据库上下文（DBModel）跟踪返回数据的状态，如果返回的数据发生了修改，就可以使用.SaveChanges()将结果直接保存回数据库。而.Database.SqlQuery()查出的结果则是做不到的。

1. using (var db = new DBModel()) //创建数据库上下文
2. {
3. //查询叫萝莉的学生信息，并修改她的年龄
4. student result1 = db.students.SqlQuery("SELECT * FROM test.student WHERE name = '萝莉'").FirstOrDefault();
5. result1.age = 13; //通过实体集合下.SqlQuery查询到的数据，修改之后是可以保存到数据库的
7. student result2 = db.Database.SqlQuery<student>("SELECT * FROM test.student WHERE name = '旺财'").FirstOrDefault();
8. result2.age = 21; //因为使用的是.Database.SqlQuery查询到的，所以这里的修改不会保存到数据库
10. //如果希望.Database.SqlQuery下查出的数据在修改后也能保存到数据库
11. student result3 = db.Database.SqlQuery<student>("SELECT * FROM test.student WHERE name = '小明'").FirstOrDefault();
12. result3.age = 36;
13. db.Entry<student>(result3).State = System.Data.Entity.EntityState.Modified; //通知数据上下文，这条记录也被修改了
15. db.SaveChanges();
16. }

四、常用查询例子

1、EF select 怎么获取最近10天的数据

DateTime now = DateTime.Now; 
var res = db.News.Where(p => System.Data.Objects.EntityFunctions.DiffDays(DateTime.Now, p.CreateTime) < 10); 
return res.ToList<News>();