在EntityFramework6中執行SQL語句


EntityFramework6中執行SQL語句

上一節中我介紹了如何使用EF6對數據庫實現CRDU以及事務,我們沒有寫一句SQL就完成了所有操作。這一節我來介紹一下如何使用在EF6中執行SQL語句。

你可能要問,我用EF不就為了避免寫SQL嗎?如果要寫SQL我不如直接用ADO.NET得了。話雖然這么說沒錯,可有些時候使用EF操作數據還是有一些不方便,例如讓你根據條件刪除一組記錄,如果按照正常的流程來走,你就得先把這些數據查出來,然后再一條一條地刪除它們,這樣不僅麻煩而且性能也比較低。這種情況下SQL就顯示出它的威力了。

而使用EF執行SQL又比ADO.NET方便,特別是在執行查詢語句的時候,EF會把查詢到的數據自動保存到數據實體中,省去了使用DataReader的麻煩。同時查詢出來的數據還會進行跟蹤,如果你修改了查詢出的值,之后就可以很方便的使用.SaveChanges()直接更新到數據庫了。

ExecuteSqlCommandSqlQuery

在數據上下文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`)); ");
  7. //使用SqlParameter傳值可以避免SQL注入
  8. var p_name = new SqlParameter("@name", "蘿莉");
  9. var p_age = new SqlParameter("@age", 13);
  10. //如果使用的是MySql數據庫 需要SqlParameter把替換為MySqlParameter
  11. //var p_name = new MySqlParameter("@name", "蘿莉");
  12. //var p_age = new MySqlParameter("@age", 13);
  13. //更改學生年齡
  14. result = db.Database.ExecuteSqlCommand(@"UPDATE `test`.`student`
  15. SET `age` = @age
  16. WHERE `name` = @name;", p_age, p_name);
  17. //異步的方式執行SQL,並返回受影響的行數
  18. Task<int> result2 = db.Database.ExecuteSqlCommandAsync("DROP TABLE `test`.`test`;");
  19. }

PS:如果需要創建或刪除當前數據庫,Database屬性中還存在.Create().Delete()方法,它們不接受參數,返回一個bool值表示執行成功或失敗。

使用.SqlQuery()查詢數據

從名字就看的出來.SqlQuery()是用來執行查詢的。.SqlQuery()使用前需指定返回值的數據類型,比如我查詢尋一條學生的完整信息,類型就可以指定為student類型。如果是統計有多少個學生,返回值是個整數,就以設置為int。

注意:不僅返回值的個數必須與傳入類型中屬性值的個數相同,而且名稱還必須一樣,不然會出錯。那么如果我只想獲取姓名和年齡,那就得單獨定義一個類(其中包含一個string類型的name和int類型的age),來保存數據了。

  1. class temp
  2. {
  3. public string name { get; set; }
  4. public int age { get; set; }
  5. }
  6. static void Main(string[] args)
  7. {
  8. using (var db = new DBModel()) //創建數據庫上下文
  9. {
  10. //查詢叫蘿莉的學生信息,並指定返回值類型為student
  11. DbRawSqlQuery<student> result1 = db.Database.SqlQuery<student>("SELECT * FROM test.student WHERE name = '蘿莉'");
  12. //也可以這樣指定返回值類型
  13. //DbRawSqlQuery result1 = db.Database.SqlQuery(typeof(student), "SELECT * FROM test.student WHERE name = '蘿莉'");
  14. Console.WriteLine(result1.FirstOrDefault().name); //打印姓名
  15. DbRawSqlQuery<int> result2 = db.Database.SqlQuery<int>("SELECT count(*) FROM test.student");
  16. Console.WriteLine(result2.FirstOrDefault()); //打印有多少學生
  17. //只查詢學生的年齡與姓名
  18. var result3 = db.Database.SqlQuery<temp>("SELECT `name`,`age` FROM test.student;");
  19. foreach (temp item in result3)
  20. {
  21. Console.WriteLine(item.name + ":" + item.age);
  22. }
  23. }

使用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查詢到的數據,修改之后是可以保存到數據庫的
  6. student result2 = db.Database.SqlQuery<student>("SELECT * FROM test.student WHERE name = '旺財'").FirstOrDefault();
  7. result2.age = 21; //因為使用的是.Database.SqlQuery查詢到的,所以這里的修改不會保存到數據庫
  8. //如果希望.Database.SqlQuery下查出的數據在修改后也能保存到數據庫
  9. student result3 = db.Database.SqlQuery<student>("SELECT * FROM test.student WHERE name = '小明'").FirstOrDefault();
  10. result3.age = 36;
  11. db.Entry<student>(result3).State = System.Data.Entity.EntityState.Modified; //通知數據上下文,這條記錄也被修改了
  12. db.SaveChanges();
  13. }

到此為止,EF6中的常用操作就全部講完了,之后如果發現還有什么值得拿出來講的,到時候再加。

目錄:EntityFramework6 快速入門教程


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM