.NET MAUIとCleanArchitectureで簡単なアプリを作成してみる4～実装1～の続き
Domainを実装する
新しいプロジェクトを追加する
種類「クラスライブラリ」
プロジェクト名「MauiApp1.Domain」
フレームワーク「.NET8」
フォルダ構成はフォルダ構成を決める(MauiApp1.Domain)の通り
エンティティを作成する
体調情報エンティティを作成する
Health.cs
public class Health
{
/// <summary>
/// コンストラクタ
/// </summary>
/// <param name="id"></param>
/// <param name="recordDate"></param>
/// <param name="heartNumber"></param>
public Health(int id, DateTime recordDate, int heartNumber)
{
Id = id;
RecordDate = recordDate;
HeartNumber = heartNumber;
}
/// <summary>
/// ID
/// </summary>
public int Id { get; }
/// <summary>
/// 記録日付
/// </summary>
public DateTime RecordDate { get; }
/// <summary>
/// ハート数
/// </summary>
public int HeartNumber { get; }
}
Repositoryインタフェースを作成する
IHealthRepository.cs
public interface IHealthRepository
{
/// <summary>
/// 記録日付を指定して体調情報を取得する
/// </summary>
/// <param name="recordDate"></param>
/// <returns></returns>
Health? Find(DateTime recordDate);
/// <summary>
/// 期間を指定して体調情報を取得する
/// </summary>
/// <param name="startDate"></param>
/// <param name="endDate"></param>
/// <returns></returns>
IEnumerable<Health> Find(DateTime startDate, DateTime endDate);
/// <summary>
/// 体調情報を保存する
/// </summary>
/// <param name="health"></param>
void Save(Health health);
}
便宜上、Interactorは後で作成します。
Infrastructureを実装する
新しいプロジェクトを追加する
種類「クラスライブラリ」
プロジェクト名「MauiApp1.SqlInfrastructure」
フレームワーク「.NET8」
フォルダ構成はフォルダ構成を決める(MauiApp1.SqlInfrastructure)の通り
「MauiApp1.Domain」をプロジェクト参照する
Sqliteをインストールする
NuGetからインストールします。
「Microsoft.Data.Sqlite.Core」を選択してインストールする
「You need to call SQLitePCL.raw.SetProvider().」みたいなエラーになることがあるので、
「SQLitePCLRaw.bundle_e_sqlite3 2.1.7」もインストールする
DBを作成する
DBとテーブルを作成するコードをMauiApp1.SqlInfrastructure直下に作っておく
Sqlite.cs
using Microsoft.Data.Sqlite;
public static class Sqlite
{
/// <summary>
/// 接続文字列
/// </summary>
internal static string ConnectionString = "Data Source={0}";
/// <summary>
/// データベースを作成する
/// </summary>
/// <param name="db"></param>
public static void CreateDB(string db)
{
ConnectionString = string.Format(ConnectionString, db);
using (var connection = new SqliteConnection(ConnectionString))
{
connection.Open();
using (var command = connection.CreateCommand())
{
// テーブルを作成する
command.CommandText = "CREATE TABLE IF NOT EXISTS Health ( id INTEGER NOT NULL PRIMARY KEY, record_date TEXT NOT NULL, heart_number INTEGER NOT NULL);";
command.ExecuteNonQuery();
}
}
}
}
Repositoryを実装する
HealthRepository.cs
using MauiApp1.Domain.Model.Healths;
using Microsoft.Data.Sqlite;
public class HealthRepository : IHealthRepository
{
/// <summary>
/// 記録日付を指定して体調情報を取得する
/// </summary>
/// <param name="recordDate"></param>
/// <returns></returns>
public Health? Find(DateTime recordDate)
{
using (var connection = new SqliteConnection(Sqlite.ConnectionString))
{
connection.Open();
using (var command = connection.CreateCommand())
{
command.CommandText = "SELECT * FROM Health WHERE record_date = $record_date";
command.Parameters.AddWithValue("$record_date", recordDate);
var reader = command.ExecuteReader();
if (reader.Read())
{
return new Health(
(int)((long)reader["id"]),
recordDate,
(int)((long)reader["heart_number"])
);
}
else
{
return null;
}
}
}
}
/// <summary>
/// 期間を指定して体調情報を取得する
/// </summary>
/// <param name="startDate"></param>
/// <param name="endDate"></param>
/// <returns></returns>
public IEnumerable<Health> Find(DateTime startDate, DateTime endDate)
{
using (var connection = new SqliteConnection(Sqlite.ConnectionString))
{
connection.Open();
using (var command = connection.CreateCommand())
{
command.CommandText = "SELECT * FROM Health WHERE record_date BETWEEN $start_date AND $end_date";
command.Parameters.AddWithValue("$start_date", startDate);
command.Parameters.AddWithValue("$end_date", endDate);
var reader = command.ExecuteReader();
var results = new List<Health>();
while (reader.Read())
{
DateTime.TryParse(reader["record_date"] as string, out DateTime recordDate);
var health = new Health(
(int)((long)reader["id"]),
recordDate,
(int)((long)reader["heart_number"])
);
results.Add(health);
}
return results;
}
}
}
/// <summary>
/// 体調情報を保存する
/// </summary>
/// <param name="health"></param>
public void Save(Health health)
{
using (var connection = new SqliteConnection(Sqlite.ConnectionString))
{
connection.Open();
// Idの有無を確認する
bool isExist;
using (var command = connection.CreateCommand())
{
command.CommandText = "SELECT * FROM Health WHERE id = $id";
command.Parameters.AddWithValue("$id", health.Id);
var reader = command.ExecuteReader();
isExist = reader.Read();
}
using (var command = connection.CreateCommand())
{
if (isExist)
{
// Idが存在する場合は更新する
command.CommandText = "UPDATE Health SET heart_number = $heart_number WHERE id = $id";
command.Parameters.AddWithValue("$id", health.Id);
command.Parameters.AddWithValue("$heart_number", health.HeartNumber);
}
else
{
// Idが存在しない場合は追加する
command.CommandText = "INSERT INTO Health(record_date, heart_number) VALUES($record_date, $heart_number)";
command.Parameters.AddWithValue("$record_date", health.RecordDate);
command.Parameters.AddWithValue("$heart_number", health.HeartNumber);
}
command.ExecuteNonQuery();
}
}
}
}
参考にしたURL
実践クリーンアーキテクチャ
Microsoft.Data.Sqlite 概要
まとめ
今回はDomain、Infrastructureを実装しました。
次はInteractorを実装します。
.NET MAUIとCleanArchitectureで簡単なアプリを作成してみる4～実装3～