NHibernate - การทำงานของ CRUD ขั้นพื้นฐาน

ในบทนี้เราจะกล่าวถึงพื้นฐาน CRUD operations. ตอนนี้ระบบของเราพร้อมที่จะเริ่มต้นแล้วเนื่องจากเราได้ติดตั้งคลาสโดเมน Student เรียบร้อยแล้วเราได้กำหนดไฟล์การแมปและกำหนดค่า NHibernate ขณะนี้เราสามารถใช้แบบสอบถามเพื่อดำเนินการ CRUD ได้

สร้างข้อมูล

ดังที่คุณเห็นว่าเราไม่มีข้อมูลในตารางนักเรียนของเราใน NHibernateDemoDB ฐานข้อมูล.

ดังนั้นในการเพิ่มข้อมูลเราจำเป็นต้องดำเนินการ Add/Create การทำงานตามที่แสดงด้านล่าง

using (var session = sefact.OpenSession()) { 

   using (var tx = session.BeginTransaction()) { 
     
      var student1 = new Student { 
         ID = 1, 
         FirstMidName = "Allan", 
         LastName = "Bommer" 
      }; 
      
      var student2 = new Student { 
         ID = 2, 
         FirstMidName = "Jerry", 
         LastName = "Lewis" 
      }; 
      
      session.Save(student1); 
      session.Save(student2); 
      tx.Commit(); 
   } 
   
   Console.ReadLine(); 
}

ดังที่คุณเห็นว่าเราได้สร้างนักเรียนสองคนแล้วเรียกใช้เมธอด Save () ของไฟล์ OpenSession จากนั้นเรียก Commit () ของไฟล์ BeginTransaction. นี่คือการใช้งานที่สมบูรณ์ในProgram.cs ไฟล์

using NHibernate.Cfg; 
using NHibernate.Dialect; 
using NHibernate.Driver; 

using System; 
using System.Linq; 
using System.Reflection;

namespace NHibernateDemoApp { 
   
   class Program { 
      
      static void Main(string[] args) { 
         var cfg = new Configuration();
			
         String Data Source = asia13797\\sqlexpress;
         String Initial Catalog = NHibernateDemoDB;
         String Integrated Security = True;
         String Connect Timeout = 15;
         String Encrypt = False;
         String TrustServerCertificate = False;
         String ApplicationIntent = ReadWrite;
         String MultiSubnetFailover = False;
			
         cfg.DataBaseIntegration(x = > { x.ConnectionString = "Data Source + 
            Initial Catalog + Integrated Security + Connect Timeout + Encrypt +
            TrustServerCertificate + ApplicationIntent + MultiSubnetFailover"; 

            x.Driver<SqlClientDriver>(); 
            x.Dialect<MsSql2008Dialect>(); 
         }); 
   
         cfg.AddAssembly(Assembly.GetExecutingAssembly()); 
         var sefact = cfg.BuildSessionFactory(); 
			
         using (var session = sefact.OpenSession()) { 
			
            using (var tx = session.BeginTransaction()) { 
               
               var student1 = new Student { 
                  ID = 1,  
                  FirstMidName = "Allan", 
                  LastName = "Bommer" 
               }; 

               var student2 = new Student { 
                  ID = 2, 
                  FirstMidName = "Jerry", 
                  LastName = "Lewis" 
               }; 
            
               session.Save(student1); 
               session.Save(student2); 
               tx.Commit();
            } 
            
            Console.ReadLine(); 
         } 
      } 
   } 
}

ตอนนี้ให้เรียกใช้แอปพลิเคชันนี้จากนั้นไปที่ SQL Server Object Explorer และรีเฟรชฐานข้อมูลของคุณ คุณจะเห็นว่านักเรียนสองคนข้างต้นถูกเพิ่มลงในตารางนักเรียนในฐานข้อมูล NHibernateDemoDB แล้ว

อ่านข้อมูลจากโต๊ะนักเรียน

คุณจะเห็นว่าตอนนี้เรามีสองระเบียนในตารางนักเรียนของเรา ในการอ่านบันทึกเหล่านี้จากตารางเราต้องเรียกไฟล์CreateCriteria() ของ OpenSession ดังแสดงในรหัสต่อไปนี้

using (var session = sefact.OpenSession()) { 
   
   using (var tx = session.BeginTransaction()) { 
      var students = session.CreateCriteria<Student>().List<Student>(); 
      
      foreach (var student in students) { 
         Console.WriteLine("{0} \t{1} \t{2}", 
            student.ID,student.FirstMidName, student.LastName); 
      } 
      
      tx.Commit(); 
   } 
   
   Console.ReadLine(); 
}

ดังนั้นถ้าคุณต้องการรายการบันทึกเราก็แค่พูดรายการประเภท Student ก็ได้

ตอนนี้ใช้ไฟล์ foreach ผ่านนักเรียนทุกคนและพูดว่าพิมพ์ ID FirstMidName และ LastNameบนคอนโซล ตอนนี้ให้เรียกใช้แอปพลิเคชันนี้อีกครั้งและคุณจะเห็นผลลัพธ์ต่อไปนี้บนหน้าต่างคอนโซล

1 Allan Bommer
2 Jerry Lewis

คุณยังสามารถดึงข้อมูลใด ๆ โดยระบุ ID ในไฟล์ Get() วิธีการ OpenSession โดยใช้รหัสต่อไปนี้

using (var session = sefact.OpenSession()) { 
   
   using (var tx = session.BeginTransaction()) { 
      var students = session.CreateCriteria<Student>().List<Student>(); 
      
      foreach (var student in students) { 
         Console.WriteLine("{0} \t{1} \t{2}", student.ID, 
            student.FirstMidName, student.LastName); 
      }
      
      var stdnt = session.Get<Student>(1); 
      Console.WriteLine("Retrieved by ID"); 
      Console.WriteLine("{0} \t{1} \t{2}", stdnt.ID, 
         stdnt.FirstMidName, stdnt.LastName); 
      tx.Commit();
   } 
	
   Console.ReadLine(); 
}

ตอนนี้เมื่อคุณเรียกใช้แอปพลิเคชันของคุณคุณจะเห็นผลลัพธ์ต่อไปนี้

1 Allan Bommer
2 Jerry Lewis
Retrieved by ID
1 Allan Bommer

อัปเดตบันทึก

ในการอัปเดตเรกคอร์ดในตารางเราต้องดึงเรกคอร์ดนั้นก่อนจากนั้นอัปเดตเรกคอร์ดนั้นโดยเรียกไฟล์ Update() วิธีการของ OpenSession ดังแสดงในโค้ดต่อไปนี้

using (var session = sefact.OpenSession()) { 

   using (var tx = session.BeginTransaction()) { 
      var students = session.CreateCriteria<Student>().List<Student>(); 
     
      foreach (var student in students) { 
         Console.WriteLine("{0} \t{1} \t{2}", student.ID, 
            student.FirstMidName, student.LastName); 
      }
      
      var stdnt = session.Get<Student>(1); 
      Console.WriteLine("Retrieved by ID"); 
      Console.WriteLine("{0} \t{1} \t{2}", stdnt.ID, stdnt.FirstMidName, stdnt.LastName);
      
      Console.WriteLine("Update the last name of ID = {0}", stdnt.ID); 
      stdnt.LastName = "Donald"; 
      session.Update(stdnt); 
      Console.WriteLine("\nFetch the complete list again\n"); 
      
      foreach (var student in students) { 
         Console.WriteLine("{0} \t{1} \t{2}", student.ID, 
            student.FirstMidName, student.LastName); 
      } 
      
      tx.Commit();
   } 
   
   Console.ReadLine();
}

ตอนนี้เมื่อคุณเรียกใช้แอปพลิเคชันของคุณคุณจะเห็นผลลัพธ์ต่อไปนี้

1 Allan Bommer
2 Jerry Lewis
Retrieved by ID
1 Allan Bommer
Update the last name of ID = 1
Fetch the complete list again
1 Allan Donald
2 Jerry Lewis

อย่างที่คุณเห็น LastName ของ ID เท่ากับ 1 ได้รับการอัปเดตจาก Bommer เป็น Donald

ลบบันทึก

ในการลบบันทึกใด ๆ ออกจากตารางเราต้องดึงข้อมูลบันทึกนั้นก่อนจากนั้นจึงลบบันทึกนั้นโดยเรียกไฟล์ Delete() วิธีการของ OpenSession ดังแสดงในโค้ดต่อไปนี้

using (var session = sefact.OpenSession()) { 
   
   using (var tx = session.BeginTransaction()) { 
      var students = session.CreateCriteria<Student>().List<Student>();
      
      foreach (var student in students) { 
         Console.WriteLine("{0} \t{1} \t{2}", student.ID, 
            student.FirstMidName, student.LastName); 
      }
      
      var stdnt = session.Get<Student>(1); 
      Console.WriteLine("Retrieved by ID"); 
      Console.WriteLine("{0} \t{1} \t{2}", stdnt.ID, stdnt.FirstMidName, stdnt.LastName);
      
      Console.WriteLine("Delete the record which has ID = {0}", stdnt.ID); 
      session.Delete(stdnt);
      Console.WriteLine("\nFetch the complete list again\n"); 
      
      foreach (var student in students) { 
         Console.WriteLine("{0} \t{1} \t{2}", student.ID, student.FirstMidName, 
            student.LastName); 
      } 
      
      tx.Commit();
   } 
	
   Console.ReadLine(); 
}

ตอนนี้เมื่อคุณเรียกใช้แอปพลิเคชันของคุณคุณจะเห็นผลลัพธ์ต่อไปนี้

1 Allan Donald
2 Jerry Lewis
Retrieved by ID
1 Allan Bommer
Delete the record which has ID = 1
Fetch the complete list again
2 Jerry Lewis

ดังที่คุณเห็นว่าระเบียนที่มี ID เท่ากับ 1 ไม่สามารถใช้ได้ในฐานข้อมูลอีกต่อไป คุณยังสามารถดูฐานข้อมูลใน SQL Server Object Explorer