NHibernate-基本的なCRUD操作
この章では、基本的なことをカバーします CRUD operations。システムを起動する準備ができたので、ドメインStudentクラスを正常に実装したので、マッピングファイルを定義し、NHibernateを構成しました。これで、いくつかのクエリを使用してCRUD操作を実行できます。
データの作成
ご覧のとおり、Studentテーブルにはデータがありません。 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();
}
ご覧のとおり、2人の生徒を作成してから、の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();
}
}
}
}
次に、このアプリケーションを実行してから、SQLServerオブジェクトエクスプローラーに移動してデータベースを更新します。上記の2人の学生がNHibernateDemoDBデータベースのStudentテーブルに追加されていることがわかります。
学生テーブルからデータを読み取る
これで、studentテーブルに2つのレコードがあることがわかります。テーブルからこれらのレコードを読み取るには、を呼び出す必要があります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
ご覧のとおり、IDが1のLastNameが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のレコードはデータベースで使用できなくなりました。データベースは、SQLServerオブジェクトエクスプローラーでも確認できます。