Blazor Serverで実装するシンプルで高速なDBトランザクション処理（on ORACLE）

.Net 6.0 の Blazor Serverから、Dapper+Oracle.EntityFrameworkCore NuGetパッケージを使い、ORACLEデータベースへDBトランザクション処理を行うサンプルを作成しました。
ORマッピングの主流はDapperになって来てる。
ソースコードはGitHubで公開しています。

ビジネスロジックやデータベース処理を、Repogitoryや Interfaceを駆使して実装すると、ソースコードが複雑になり保守性が下がります。
staticクラスで実装するとソースコードがシンプルになり保守性が高くなります。
staticクラスで実装したソースコードは、ユニットテストの実装も容易です。

Repogitoryや Interfaceを駆使して無駄な処理を大量に実装し、工数が爆発して開発が終わらなくなっているプロジェクトが多過ぎる。駆使するべきはstatic。
いまだに、C#のマルチスレッド処理が分からず「staticを使うのは不安だ」と言っている人がいて、その人の意見が採用され「static禁止」になると、開発工数が爆発します。

ソースコード構成

今回使った Visual Studio プロジェクトテンプレートは、Visual Studio 2022 + .Net 6 + Blazor Server アプリの HTTPS無し。

画像に alt 属性が指定されていません。ファイル名: image-10.png

画像に alt 属性が指定されていません。ファイル名: image-11.png

テンプレートに対して、下記の処理を加えました。

ソースコード変更内容を解説

/BlazorApp1.csproj

Dapper/Oracle.EntityFrameworkCore NuGetパッケージをインストール。
Oracle.EntityFrameworkCore は Oracle.ManagedDataAccess と違い、ORACLE Client を別途インストールしなくても、OracleConnectionを実行できるので便利。


<Project Sdk="Microsoft.NET.Sdk.Web">

  <PropertyGroup>
    <TargetFramework>net6.0</TargetFramework>
    <Nullable>enable</Nullable>
    <ImplicitUsings>enable</ImplicitUsings>
  </PropertyGroup>

  <ItemGroup>
    <PackageReference Include="Dapper" Version="2.0.123" />
    <PackageReference Include="Oracle.EntityFrameworkCore" Version="7.21.9" />
  </ItemGroup>

</Project>

<Nullable>enable</Nullable>

<ImplicitUsings>enable</ImplicitUsings>

</PropertyGroup>

</ItemGroup>

</Project>

/appsettings.Development.json

ORACLEへ接続するコネクションストリングを追加。


{
  "DetailedErrors": true,
  "Logging": {
    "LogLevel": {
      "Default": "Information",
      "Microsoft.AspNetCore": "Warning"
    }
  },
  "ConnectionStrings": {
    "OracleDB": "User Id = TESTUSER1; Password = testuser1password; Data Source = (DESCRIPTION = (ADDRESS = (PROTOCOL = tcp)(HOST = LOCALHOST)(PORT = 1521))(CONNECT_DATA = (SERVICE_NAME = ORCL1)));"
  }
}

{

"DetailedErrors": true,

"Logging": {

"LogLevel": {

"Default": "Information",

"Microsoft.AspNetCore": "Warning"

}

"ConnectionStrings": {

"OracleDB": "User Id = TESTUSER1; Password = testuser1password; Data Source = (DESCRIPTION = (ADDRESS = (PROTOCOL = tcp)(HOST = LOCALHOST)(PORT = 1521))(CONNECT_DATA = (SERVICE_NAME = ORCL1)));"

}

/Shared/SharedData.cs

・staticメンバ変数で実装した、アプリ全体で使えるコネクションストリング変数を追加。


namespace BlazorApp1.Shared
{
    public static class SharedData
    {
        /// <summary>
        /// ORACLE DB 接続文字列
        /// </summary>
        public static string ConnectionString;

    }
}

namespace BlazorApp1.Shared

{

public static class SharedData

{

/// <summary>

/// ORACLE DB 接続文字列

/// </summary>

public static string ConnectionString;

}

/Program.cs

・アプリ起動時に環境設定ファイルを読み込み、アプリ全体で使えるコネクションストリング変数にセットする処理を追加。
　環境設定ファイルの読み込み処理をアプリ起動時１回だけにし、アプリ起動後は staticメンバ変数を直接参照することで、処理コストを減らせる。


using BlazorApp1.Data;
using BlazorApp1.Shared;
using Microsoft.AspNetCore.Components;
using Microsoft.AspNetCore.Components.Web;

var builder = WebApplication.CreateBuilder(args);

var configuration = builder.Configuration;
SharedData.ConnectionString = configuration.GetSection("ConnectionStrings")["OracleDB"];

// Add services to the container.
builder.Services.AddRazorPages();
builder.Services.AddServerSideBlazor();
builder.Services.AddSingleton<WeatherForecastService>();

var app = builder.Build();

// Configure the HTTP request pipeline.
if (!app.Environment.IsDevelopment())
{
    app.UseExceptionHandler("/Error");
}


app.UseStaticFiles();

app.UseRouting();

app.MapBlazorHub();
app.MapFallbackToPage("/_Host");

app.Run();

using BlazorApp1.Data;

using BlazorApp1.Shared;

using Microsoft.AspNetCore.Components;

using Microsoft.AspNetCore.Components.Web;

var builder = WebApplication.CreateBuilder(args);

var configuration = builder.Configuration;

SharedData.ConnectionString = configuration.GetSection("ConnectionStrings")["OracleDB"];

// Add services to the container.

builder.Services.AddRazorPages();

builder.Services.AddServerSideBlazor();

builder.Services.AddSingleton<WeatherForecastService>();

var app = builder.Build();

// Configure the HTTP request pipeline.

if (!app.Environment.IsDevelopment())

{

app.UseExceptionHandler("/Error");

}

app.UseStaticFiles();

app.UseRouting();

app.MapBlazorHub();

app.MapFallbackToPage("/_Host");

app.Run();

/Model/TableModels.cs

・ORACLEから取得したデータに対応する、データモデルクラスを追加。


using static System.Net.Mime.MediaTypeNames;

namespace BlazorApp1.Model
{
    public class TABLE1
    {
        public long ID;
        public string CODE;
        public string? VALUE_STRING;
        public DateTime? VALUE_DATE;
    }

}

using static System.Net.Mime.MediaTypeNames;

namespace BlazorApp1.Model

{

public class TABLE1

{

public long ID;

public string CODE;

public string? VALUE_STRING;

public DateTime? VALUE_DATE;

}

/Pages/Counter.razor

・ORACLEデータベースに対して、DBトランザクション処理を実行する「DB Transaction ORACLE」ボタンを追加。


@page "/counter"

<PageTitle>Counter</PageTitle>

<h1>Counter</h1>

<p role="status">Current count: @currentCount</p>

<button class="btn btn-primary" @onclick="IncrementCount">Click me</button>

<button class="btn btn-primary" @onclick="Transaction1">DB Transaction ORACLE</button>

@code {
    private int currentCount = 0;

    private void IncrementCount()
    {
        currentCount++;
    }

    private void Transaction1()
    {
        try
        {
            var insertTABLE1 = new TABLE1()
            {
                ID = 1,
                CODE = "1",
                VALUE_STRING = "1",
                VALUE_DATE = DateTime.Now
            };

            SQL_TABLE1.Transaction1(insertTABLE1);
        }
        catch (Exception ex)
        {
            throw;
        }
    }

}

@page "/counter"

<PageTitle>Counter</PageTitle>

<h1>Counter</h1>

<p role="status">Current count: @currentCount</p>

<button class="btn btn-primary" @onclick="IncrementCount">Click me</button>

<button class="btn btn-primary" @onclick="Transaction1">DB Transaction ORACLE</button>

@code {

private int currentCount = 0;

private void IncrementCount()

{

currentCount++;

}

private void Transaction1()

{

try

{

var insertTABLE1 = new TABLE1()

{

ID = 1,

CODE = "1",

VALUE_STRING = "1",

VALUE_DATE = DateTime.Now

};

SQL_TABLE1.Transaction1(insertTABLE1);

}

catch (Exception ex)

{

throw;

}

/SQL/SQL_TABLE1.cs

・DBトランザクション処理を行う Transaction1メソッドから、Insert SQLを発行する Insertメソッド、Select SQLを発行する Selectメソッドを呼び出しています。
・BeginTransactionでトランザクションを開始し、DBコネクション変数（conn）とトランザクション変数（tran）を各メソッドへ渡し、Dapperを通してSQLを発行することで、とてもシンプルで高速なDBトランザクション処理を実装しています。
・razorページには画面処理のみ、SQLフォルダ配下の staticクラスにはDB処理と、レイヤー分けをしています。
　今回は簡単なロジックなので2レイヤーにしています。業務システムだとビジネスロジックレイヤーのソースコードをDataフォルダ配下に纏め、「画面レイヤー（Pagesフォルダ） => ビジネスロジックレイヤー（Dataフォルダ） => データベースレイヤー（Sqlフォルダ）」と繋げていくイメージです。
　ビジネスロジックレイヤーを設ける場合、トランザクション処理の開始処理（BeginTransaction）はビジネスロジックレイヤーに実装します。
・データベース処理を行う、SQL文を伴うソースコードはSQLフォルダに纏まっていると分かり易い。
・Insert文のパラメータは匿名クラスにし、DapperにSQLとパラメータを渡して、Insert SQLを発行しています。
・データベースとC#側のデータ型が一致していれば、あとは Dapperがバインドしてくれる。
・SQL文は定数化しておくことで処理コストを減らしています。


using System.Data;
using BlazorApp1.Model;
using BlazorApp1.Shared;
using Dapper;
using Microsoft.Extensions.Logging;
using Oracle.ManagedDataAccess.Client;

namespace BlazorApp1.SQL
{
    public class SQL_TABLE1
    {
        public static void Transaction1(TABLE1 insertTABLE1)
        {
            using (var conn = new OracleConnection(SharedData.ConnectionString))
            {
                conn.Open();
                using (var tran = conn.BeginTransaction(IsolationLevel.ReadCommitted))
                {
                    try
                    {
                        var table1List = Select(conn);

                        Insert(conn, tran, insertTABLE1);

                        var table1List2 = Select(conn);

                        tran.Commit();
                    }
                    catch
                    {
                        tran.Rollback();
                        throw;
                    }
                }
            }
        }

        public static IEnumerable<TABLE1> Select(OracleConnection conn)
        {
            const string sql =
                " SELECT " +
                "  id, " +
                "  code, " +
                "  value_string, " +
                "  value_date " +
                " FROM " +
                "  testuser1.table1 ";

            return conn.Query<TABLE1>(sql);
        }

        public static void Insert(OracleConnection conn, OracleTransaction tran, TABLE1 insertTABLE1)
        {
            const string sql =
                " INSERT INTO testuser1.table1( " +
                "   id,  " +
                "   value_string,  " +
                "   value_date, " +
                "   code " +
                " ) VALUES ( " +
                "   :id,  " +
                "   :value_string,  " +
                "   :value_date, " +
                "   :code " +
                " ) ";

            var sqlParam = new
            {
                id = insertTABLE1.ID,
                code = insertTABLE1.CODE,
                value_string = insertTABLE1.VALUE_STRING,
                value_date = insertTABLE1.VALUE_DATE
            };

            conn.Execute(sql, sqlParam, tran);
        }
    }

}

using System.Data;

using BlazorApp1.Model;

using BlazorApp1.Shared;

using Dapper;

using Microsoft.Extensions.Logging;

using Oracle.ManagedDataAccess.Client;

namespace BlazorApp1.SQL

{

public class SQL_TABLE1

{

public static void Transaction1(TABLE1 insertTABLE1)

{

using (var conn = new OracleConnection(SharedData.ConnectionString))

{

conn.Open();

using (var tran = conn.BeginTransaction(IsolationLevel.ReadCommitted))

{

try

{

var table1List = Select(conn);

Insert(conn, tran, insertTABLE1);

var table1List2 = Select(conn);

tran.Commit();

}

catch

{

tran.Rollback();

throw;

}

public static IEnumerable<TABLE1> Select(OracleConnection conn)

{

const string sql =

" SELECT " +

" id, " +

" code, " +

" value_string, " +

" value_date " +

" FROM " +

" testuser1.table1 ";

return conn.Query<TABLE1>(sql);

}

public static void Insert(OracleConnection conn, OracleTransaction tran, TABLE1 insertTABLE1)

{

const string sql =

" INSERT INTO testuser1.table1( " +

" id, " +

" value_string, " +

" value_date, " +

" code " +

" ) VALUES ( " +

" :id, " +

" :value_string, " +

" :value_date, " +

" :code " +

" ) ";

var sqlParam = new

{

id = insertTABLE1.ID,

code = insertTABLE1.CODE,

value_string = insertTABLE1.VALUE_STRING,

value_date = insertTABLE1.VALUE_DATE

};

conn.Execute(sql, sqlParam, tran);

}

/_Imports.razor

・追加した classを、各Razorページで使用できるように Usingを追加。


@using System.Net.Http
@using Microsoft.AspNetCore.Authorization
@using Microsoft.AspNetCore.Components.Authorization
@using Microsoft.AspNetCore.Components.Forms
@using Microsoft.AspNetCore.Components.Routing
@using Microsoft.AspNetCore.Components.Web
@using Microsoft.AspNetCore.Components.Web.Virtualization
@using Microsoft.JSInterop
@using BlazorApp1
@using BlazorApp1.Model
@using BlazorApp1.Shared
@using BlazorApp1.SQL

@using System.Net.Http

@using Microsoft.AspNetCore.Authorization

@using Microsoft.AspNetCore.Components.Authorization

@using Microsoft.AspNetCore.Components.Forms

@using Microsoft.AspNetCore.Components.Routing

@using Microsoft.AspNetCore.Components.Web

@using Microsoft.AspNetCore.Components.Web.Virtualization

@using Microsoft.JSInterop

@using BlazorApp1

@using BlazorApp1.Model

@using BlazorApp1.Shared

@using BlazorApp1.SQL

Select対象のDBテーブル構成


--------------------------------------------------------
--  DDL for Table TABLE1
--------------------------------------------------------

  CREATE TABLE "TESTUSER1"."TABLE1" 
   (	"ID" NUMBER, 
	"CODE" VARCHAR2(20 BYTE), 
	"VALUE_STRING" NVARCHAR2(20), 
	"VALUE_DATE" DATE
   ) SEGMENT CREATION IMMEDIATE 
  PCTFREE 10 PCTUSED 40 INITRANS 1 MAXTRANS 255 
 NOCOMPRESS LOGGING
  STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645
  PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1
  BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)
  TABLESPACE "TABLESPACE1" ;
--------------------------------------------------------
--  DDL for Index TABLE1_PK
--------------------------------------------------------

  CREATE UNIQUE INDEX "TESTUSER1"."TABLE1_PK" ON "TESTUSER1"."TABLE1" ("ID") 
  PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS 
  STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645
  PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1
  BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)
  TABLESPACE "TABLESPACE1" ;
--------------------------------------------------------
--  Constraints for Table TABLE1
--------------------------------------------------------

  ALTER TABLE "TESTUSER1"."TABLE1" ADD CONSTRAINT "TABLE1_PK" PRIMARY KEY ("ID")
  USING INDEX PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS 
  STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645
  PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1
  BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)
  TABLESPACE "TABLESPACE1"  ENABLE;
  ALTER TABLE "TESTUSER1"."TABLE1" MODIFY ("ID" NOT NULL ENABLE);

--------------------------------------------------------

-- DDL for Table TABLE1

--------------------------------------------------------

CREATE TABLE "TESTUSER1"."TABLE1"

( "ID" NUMBER,

"CODE" VARCHAR2(20 BYTE),

"VALUE_STRING" NVARCHAR2(20),

"VALUE_DATE" DATE

) SEGMENT CREATION IMMEDIATE

PCTFREE 10 PCTUSED 40 INITRANS 1 MAXTRANS 255

NOCOMPRESS LOGGING

STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645

PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1

BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)

TABLESPACE "TABLESPACE1" ;

--------------------------------------------------------

-- DDL for Index TABLE1_PK

--------------------------------------------------------

CREATE UNIQUE INDEX "TESTUSER1"."TABLE1_PK" ON "TESTUSER1"."TABLE1" ("ID")

PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS

STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645

PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1

BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)

TABLESPACE "TABLESPACE1" ;

--------------------------------------------------------

-- Constraints for Table TABLE1

--------------------------------------------------------

ALTER TABLE "TESTUSER1"."TABLE1" ADD CONSTRAINT "TABLE1_PK" PRIMARY KEY ("ID")

USING INDEX PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS

STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645

PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1

BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)

TABLESPACE "TABLESPACE1" ENABLE;

ALTER TABLE "TESTUSER1"."TABLE1" MODIFY ("ID" NOT NULL ENABLE);