Nhibernate-basic-crud-operations

提供:Dev Guides
移動先:案内検索

NHibernate-基本的なCRUD操作

この章では、基本的な* CRUD操作*について説明します。 ドメインのStudentクラスを正常に実装したため、システムを起動する準備ができたので、マッピングファイルも定義し、NHibernateを構成しました。 これで、いくつかのクエリを使用してCRUD操作を実行できます。

データを作成する

ご覧のとおり、 NHibernateDemoDB データベースのStudentテーブルにはデータがありません。

NHibernate DemoDB

そのため、データを追加するには、以下に示すように 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();
}

ご覧のとおり、2人の生徒を作成し、 OpenSession のSave()メソッドを呼び出してから、 BeginTransaction のCommit()を呼び出します。 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オブジェクトエクスプローラーに移動し、データベースを更新します。 上記の2人の生徒が、NHibernateDemoDBデータベースのStudentテーブルに追加されたことがわかります。

SQL Serverオブジェクト

学生テーブルからデータを読み取る

学生テーブルに2つのレコードがあることがわかります。 テーブルからこれらのレコードを読み取るには、次のコードに示すように、OpenSessionの* CreateCriteria()*を呼び出す必要があります。

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

次のコードを使用して、OpenSessionの* Get()*メソッドでIDを指定することにより、任意のレコードを取得することもできます。

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

レコードを更新

テーブル内のレコードを更新するには、最初にその特定のレコードをフェッチしてから、次のコードに示すようにOpenSessionの* Update()*メソッドを呼び出してそのレコードを更新する必要があります。

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

ご覧のとおり、IDが1のLastNameがBommerからDonaldに更新されます。

レコードを削除

テーブルからレコードを削除するには、次のコードに示すように、まず特定のレコードをフェッチしてから、OpenSessionの* Delete()*メソッドを呼び出してそのレコードを削除する必要があります。

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オブジェクトエクスプローラーでデータベースを確認することもできます。

オブジェクトエクスプローラ