Khách 42 tên gì lúc lập hóa đơn: temporal table và mốc giờ UTC

#:package Microsoft.EntityFrameworkCore.SqlServer@10.0.12
#:property PublishAot=false
// Bảng temporal dbo.KhachHang: đọc lại tên khách tại một mốc bằng EF Core, đo chi phí ghi và chi phí tra lịch sử.
// Chạy: dotnet run KhachHangLichSu.cs   (LocalDB SQL Server 2019, tạo database Kumeo_C nếu chưa có)
using System.Diagnostics;
using System.Globalization;
using Microsoft.Data.SqlClient;
using Microsoft.EntityFrameworkCore;

CultureInfo.DefaultThreadCurrentCulture = CultureInfo.CurrentCulture = new CultureInfo("vi-VN");
const string May = @"Server=(localdb)\MSSQLLocalDB;Integrated Security=true;TrustServerCertificate=true";
const string Cs = May + ";Database=Kumeo_C";
await TaoBang();

// 1. Khách 42: ghi, đổi tên, đổi số điện thoại. Nhớ mốc UTC trước mỗi lần sửa.
await using (var db = new BanHangDb(Cs))
{
    db.KhachHang.Add(new KhachHang { KhachHangId = 42, ChiNhanhId = 3, Ten = "Đại lý A", SoDienThoai = "0901000042" });
    await db.SaveChangesAsync();
}
await Task.Delay(1000);
var moc1Utc = DateTime.UtcNow; var moc1May = DateTime.Now;
await Task.Delay(1000);
await SuaAsync(k => k.Ten = "Đại lý A - Chi nhánh 3");
await Task.Delay(1000);
var moc2Utc = DateTime.UtcNow;
await Task.Delay(1000);
await SuaAsync(k => k.SoDienThoai = "0909000042");
await Task.Delay(1000);
var moc3Utc = DateTime.UtcNow;

await using (var db = new BanHangDb(Cs))
{
    var q = db.KhachHang.TemporalAsOf(moc1Utc).Where(k => k.KhachHangId == 42).Select(k => k.Ten);
    Console.WriteLine(q.ToQueryString());
    Console.WriteLine();
    foreach (var (nhan, moc) in new[] { ("mốc 1 (UTC)", moc1Utc), ("mốc 2 (UTC)", moc2Utc), ("mốc 3 (UTC)", moc3Utc), ("mốc 1 (giờ máy)", moc1May) })
    {
        var k = await db.KhachHang.TemporalAsOf(moc).Where(k => k.KhachHangId == 42)
            .Select(k => new { k.Ten, k.SoDienThoai }).SingleAsync();
        Console.WriteLine($"AS OF {moc:HH:mm:ss} {nhan,-16} {k.Ten,-24} {k.SoDienThoai}");
    }
    Console.WriteLine();
    var lichSu = await db.KhachHang.TemporalAll().Where(k => k.KhachHangId == 42)
        .OrderBy(k => EF.Property<DateTime>(k, "SysStart"))
        .Select(k => new { k.Ten, k.SoDienThoai, Tu = EF.Property<DateTime>(k, "SysStart"), Den = EF.Property<DateTime>(k, "SysEnd") })
        .ToListAsync();
    foreach (var d in lichSu) Console.WriteLine($"{d.Ten,-24} {d.SoDienThoai} {d.Tu:HH:mm:ss.fff} → {d.Den:yyyy-MM-dd HH:mm:ss.fff}");
    Console.WriteLine();

    // Nhân viên hỏi theo giờ Việt Nam: đổi sang UTC trước khi truyền vào TemporalAsOf.
    var gioVn = new DateTimeOffset(2026, 10, 2, 12, 0, 0, TimeSpan.FromHours(7));
    Console.WriteLine($"12:00 ngày 2026-10-02 giờ Việt Nam = {gioVn.UtcDateTime:yyyy-MM-dd HH:mm} UTC, {gioVn.UtcDateTime.Kind}");
    Console.WriteLine(db.KhachHang.TemporalAsOf(gioVn.UtcDateTime).Where(k => k.KhachHangId == 42).Select(k => k.Ten).ToQueryString());
    Console.WriteLine();
}

// 2. Nạp 200.000 khách, thêm bản sao không lịch sử để so chi phí ghi.
await NapKhach(200_000);

// 3. Một lệnh UPDATE cả 200.000 khách, 5 lượt mỗi bảng: thời gian, CPU và log ghi ra. Bảng lịch sử lên khoảng 1 triệu dòng.
for (var i = 0; i < 5; i++)
    foreach (var bang in new[] { "dbo.KhachHang_KhongLichSu", "dbo.KhachHang" })
    {
        await using var cn = new SqlConnection(Cs);
        await cn.OpenAsync();
        await using var cmd = new SqlCommand($"""
            DECLARE @cpu0 int = (SELECT cpu_time FROM sys.dm_exec_requests WHERE session_id = @@SPID);
            BEGIN TRAN;
            UPDATE {bang} SET SoDienThoai = '09' + RIGHT('0000000' + CAST(KhachHangId * 7 + {i} AS varchar(12)), 8);
            SELECT (SELECT cpu_time FROM sys.dm_exec_requests WHERE session_id = @@SPID) - @cpu0,
                   database_transaction_log_bytes_used, database_transaction_log_record_count
            FROM sys.dm_tran_database_transactions
            WHERE database_id = DB_ID() AND transaction_id = CURRENT_TRANSACTION_ID();
            COMMIT;
            """, cn) { CommandTimeout = 600 };
        var sw = Stopwatch.StartNew();
        await using var r = await cmd.ExecuteReaderAsync();
        await r.ReadAsync();
        var (cpu, logBytes, logRec) = (r.GetInt32(0), r.GetInt64(1), r.GetInt64(2));
        await r.CloseAsync();
        Console.WriteLine($"lượt {i + 1} {bang,-26} UPDATE 200.000 dòng: {sw.ElapsedMilliseconds,6:N0} ms, CPU {cpu,5:N0} ms, log {logBytes / 1048576.0,6:N1} MB, {logRec:N0} log record");
    }
Console.WriteLine($"Bảng lịch sử: {await Scalar("SELECT COUNT_BIG(*) FROM dbo.KhachHang_LichSu;"):N0} dòng, "
    + $"{await Scalar("SELECT SUM(used_page_count) * 8 / 1024 FROM sys.dm_db_partition_stats WHERE object_id = OBJECT_ID(N'dbo.KhachHang_LichSu');"):N0} MB; "
    + $"bảng chính {await Scalar("SELECT SUM(used_page_count) * 8 / 1024 FROM sys.dm_db_partition_stats WHERE object_id = OBJECT_ID(N'dbo.KhachHang');"):N0} MB");
await using (var cn = new SqlConnection(Cs))
{
    await cn.OpenAsync();
    await using var cmd = new SqlCommand("""
        SELECT i.name COLLATE DATABASE_DEFAULT + N' ' + i.type_desc COLLATE DATABASE_DEFAULT + N' (' + STRING_AGG(c.name COLLATE DATABASE_DEFAULT, N', ') WITHIN GROUP (ORDER BY ic.key_ordinal) + N') ' + MAX(p.data_compression_desc) COLLATE DATABASE_DEFAULT
        FROM sys.indexes i
        JOIN sys.index_columns ic ON ic.object_id = i.object_id AND ic.index_id = i.index_id AND ic.key_ordinal > 0
        JOIN sys.columns c ON c.object_id = ic.object_id AND c.column_id = ic.column_id
        JOIN sys.partitions p ON p.object_id = i.object_id AND p.index_id = i.index_id
        WHERE i.object_id = OBJECT_ID(N'dbo.KhachHang_LichSu') GROUP BY i.name, i.type_desc;
        """, cn);
    Console.WriteLine($"Chỉ mục có sẵn của bảng lịch sử: {await cmd.ExecuteScalarAsync()}");
}
Console.WriteLine();

// 4. Tra tên khách 42 tại mốc 1 khi bảng lịch sử lớn: logical reads trước và sau khi thêm chỉ mục theo khách.
for (var lan = 1; lan <= 2; lan++) Console.WriteLine($"AS OF, chỉ mục mặc định (SysEnd, SysStart): {await DocAsOf(moc1Utc)}");
await Exec("CREATE INDEX IX_KhachHang_LichSu_Khach ON dbo.KhachHang_LichSu (KhachHangId, SysEnd, SysStart) WITH (DATA_COMPRESSION = PAGE);");
for (var lan = 1; lan <= 2; lan++) Console.WriteLine($"AS OF, thêm (KhachHangId, SysEnd, SysStart):   {await DocAsOf(moc1Utc)}");

async Task<string> DocAsOf(DateTime mocUtc)
{
    await using var db = new BanHangDb(Cs);
    // Đếm logical reads của phiên trước và sau câu truy vấn, trên cùng một kết nối.
    await db.Database.OpenConnectionAsync();
    const string DemDoc = "SELECT logical_reads AS Value FROM sys.dm_exec_sessions WHERE session_id = @@SPID";
    var truoc = await db.Database.SqlQueryRaw<long>(DemDoc).SingleAsync();
    var sw = Stopwatch.StartNew();
    var ten = await db.KhachHang.TemporalAsOf(mocUtc).Where(k => k.KhachHangId == 42).Select(k => k.Ten).SingleAsync();
    sw.Stop();
    var sau = await db.Database.SqlQueryRaw<long>(DemDoc).SingleAsync();
    return $"{ten}; {sau - truoc:N0} logical reads; {sw.Elapsed.TotalMilliseconds:N1} ms";
}

async Task SuaAsync(Action<KhachHang> sua)
{
    await using var db = new BanHangDb(Cs);
    var k = await db.KhachHang.SingleAsync(k => k.KhachHangId == 42);
    sua(k);
    await db.SaveChangesAsync();
}

async Task NapKhach(int soKhach)
{
    // Khách 1..200.000 trừ khách 42 đã có; bản sao không lịch sử để so chi phí ghi.
    await Exec($"""
        WITH n AS (SELECT TOP ({soKhach}) ROW_NUMBER() OVER (ORDER BY (SELECT NULL)) AS i FROM sys.all_columns a CROSS JOIN sys.all_columns b)
        INSERT dbo.KhachHang (KhachHangId, ChiNhanhId, Ten, SoDienThoai)
        SELECT i, 1 + i % 120, N'Khách ' + CAST(i AS nvarchar(10)), '09' + RIGHT('0000000' + CAST(i AS varchar(10)), 8) FROM n WHERE i <> 42;
        SELECT KhachHangId, ChiNhanhId, Ten, SoDienThoai INTO dbo.KhachHang_KhongLichSu FROM dbo.KhachHang;
        ALTER TABLE dbo.KhachHang_KhongLichSu ADD CONSTRAINT PK_KhachHang_KhongLichSu PRIMARY KEY CLUSTERED (KhachHangId);
        """);
}

async Task TaoBang()
{
    await using (var m = new SqlConnection(May))
    {
        await m.OpenAsync();
        await using var c = new SqlCommand("IF DB_ID(N'Kumeo_C') IS NULL CREATE DATABASE Kumeo_C COLLATE Vietnamese_100_CI_AS;", m);
        await c.ExecuteNonQueryAsync();
    }
    // Đúng định nghĩa dbo.KhachHang dùng chung của BanHang. Xóa bản cũ để chạy lại được.
    await Exec("""
        IF OBJECT_ID(N'dbo.KhachHang') IS NOT NULL
        BEGIN
            ALTER TABLE dbo.KhachHang SET (SYSTEM_VERSIONING = OFF);
            DROP TABLE dbo.KhachHang;
            DROP TABLE dbo.KhachHang_LichSu;
        END;
        DROP TABLE IF EXISTS dbo.KhachHang_KhongLichSu;
        CREATE TABLE dbo.KhachHang (
            KhachHangId int NOT NULL CONSTRAINT PK_KhachHang PRIMARY KEY CLUSTERED,
            ChiNhanhId int NOT NULL,
            Ten nvarchar(200) NOT NULL,
            SoDienThoai varchar(20) NULL,
            SysStart datetime2 GENERATED ALWAYS AS ROW START NOT NULL,
            SysEnd datetime2 GENERATED ALWAYS AS ROW END NOT NULL,
            PERIOD FOR SYSTEM_TIME (SysStart, SysEnd)
        ) WITH (SYSTEM_VERSIONING = ON (HISTORY_TABLE = dbo.KhachHang_LichSu));
        """);
}

async Task Exec(string sql)
{
    await using var cn = new SqlConnection(Cs);
    await cn.OpenAsync();
    await using var cmd = new SqlCommand(sql, cn) { CommandTimeout = 600 };
    await cmd.ExecuteNonQueryAsync();
}

async Task<long> Scalar(string sql)
{
    await using var cn = new SqlConnection(Cs);
    await cn.OpenAsync();
    await using var cmd = new SqlCommand(sql, cn);
    return Convert.ToInt64(await cmd.ExecuteScalarAsync());
}

class KhachHang
{
    public int KhachHangId { get; set; }
    public int ChiNhanhId { get; set; }
    public string Ten { get; set; } = "";
    public string? SoDienThoai { get; set; }
}

class BanHangDb : DbContext
{
    public BanHangDb(string cs) : base(new DbContextOptionsBuilder<BanHangDb>().UseSqlServer(cs).Options) { }
    public DbSet<KhachHang> KhachHang => Set<KhachHang>();
    protected override void OnModelCreating(ModelBuilder m) => m.Entity<KhachHang>(e =>
    {
        e.ToTable("KhachHang", "dbo", t => t.IsTemporal(h =>
        {
            h.HasPeriodStart("SysStart");
            h.HasPeriodEnd("SysEnd");
            h.UseHistoryTable("KhachHang_LichSu", "dbo");
        }));
        e.Property(k => k.KhachHangId).ValueGeneratedNever();
        e.Property(k => k.Ten).HasMaxLength(200);
        e.Property(k => k.SoDienThoai).HasMaxLength(20).IsUnicode(false);
    });
}

lượt 1 dbo.KhachHang_KhongLichSu  UPDATE 200.000 dòng:    542 ms, CPU   529 ms, log   21,4 MB, 200.002 log record
lượt 1 dbo.KhachHang              UPDATE 200.000 dòng:  1.538 ms, CPU 1.488 ms, log   27,7 MB, 202.436 log record
lượt 2 dbo.KhachHang_KhongLichSu  UPDATE 200.000 dòng:    454 ms, CPU   445 ms, log   19,9 MB, 200.002 log record
lượt 2 dbo.KhachHang              UPDATE 200.000 dòng:  1.901 ms, CPU 1.889 ms, log   57,5 MB, 400.004 log record
lượt 3 dbo.KhachHang_KhongLichSu  UPDATE 200.000 dòng:    414 ms, CPU   408 ms, log   19,9 MB, 200.002 log record
lượt 3 dbo.KhachHang              UPDATE 200.000 dòng:  1.947 ms, CPU 1.937 ms, log   57,5 MB, 400.004 log record
lượt 4 dbo.KhachHang_KhongLichSu  UPDATE 200.000 dòng:    605 ms, CPU   589 ms, log   19,9 MB, 200.002 log record
lượt 4 dbo.KhachHang              UPDATE 200.000 dòng:  2.268 ms, CPU 2.189 ms, log   26,2 MB, 202.426 log record
lượt 5 dbo.KhachHang_KhongLichSu  UPDATE 200.000 dòng:    720 ms, CPU   711 ms, log   19,9 MB, 200.002 log record
lượt 5 dbo.KhachHang              UPDATE 200.000 dòng:  3.048 ms, CPU 2.928 ms, log   26,2 MB, 202.346 log record
Bảng lịch sử: 1.000.002 dòng, 76 MB; bảng chính 14 MB
Chỉ mục có sẵn của bảng lịch sử: ix_KhachHang_LichSu CLUSTERED (SysEnd, SysStart) NONE

AS OF, chỉ mục mặc định (SysEnd, SysStart): Đại lý A; 13.725 logical reads; 807,7 ms
AS OF, chỉ mục mặc định (SysEnd, SysStart): Đại lý A; 9.742 logical reads; 105,7 ms
AS OF, thêm (KhachHangId, SysEnd, SysStart):   Đại lý A; 37 logical reads; 5,7 ms
AS OF, thêm (KhachHangId, SysEnd, SysStart):   Đại lý A; 9 logical reads; 1,3 ms