9336995150

Committed 02 Jun 2024 08:43AM UTC coverage: 81.967% (+0.03%) from 81.942%

Build # 9336995150

Build Type

push

github

Committed by

lucaslorentz

Commit Message

Update to EF Core 8

Run Details

6 of 6 new or added lines in 1 file covered. (100.0%)

2350 of 2867 relevant lines covered (81.97%)

139.01 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

66.67

/src/LLL.DurableTask.EFCore.MySql/StraightJoinCommandInterceptor.cs

﻿using System;
using System.Data.Common;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.EntityFrameworkCore.Diagnostics;

namespace LLL.DurableTask.EFCore.MySql;

public class StraightJoinCommandInterceptor : DbCommandInterceptor
{
    public override InterceptionResult<DbDataReader> ReaderExecuting(
        DbCommand command,
        CommandEventData eventData,
        InterceptionResult<DbDataReader> result)
    {
        ManipulateCommand(command);

        return result;
    }

    public override ValueTask<InterceptionResult<DbDataReader>> ReaderExecutingAsync(
        DbCommand command,
        CommandEventData eventData,
        InterceptionResult<DbDataReader> result,
        CancellationToken cancellationToken = default)
    {
        ManipulateCommand(command);

        return new ValueTask<InterceptionResult<DbDataReader>>(result);
    }

    private static void ManipulateCommand(DbCommand command)
    {
        if (command.CommandText.Contains("-- STRAIGHT_JOIN", StringComparison.Ordinal))
        {
            command.CommandText = command.CommandText.Replace("SELECT", "SELECT STRAIGHT_JOIN", StringComparison.OrdinalIgnoreCase);
        }
    }
}

1	using System;
2	using System.Data.Common;
3	using System.Threading;
4	using System.Threading.Tasks;
5	using Microsoft.EntityFrameworkCore.Diagnostics;
6
7	namespace LLL.DurableTask.EFCore.MySql;
8
9	public class StraightJoinCommandInterceptor : DbCommandInterceptor
10	{
11	public override InterceptionResult<DbDataReader> ReaderExecuting(
12	DbCommand command,
13	CommandEventData eventData,
14	InterceptionResult<DbDataReader> result)
15	{
16	ManipulateCommand(command);	×
17
18	return result;	×
19	}
20
21	public override ValueTask<InterceptionResult<DbDataReader>> ReaderExecutingAsync(
22	DbCommand command,
23	CommandEventData eventData,
24	InterceptionResult<DbDataReader> result,
25	CancellationToken cancellationToken = default)
26	{
27	ManipulateCommand(command);	909✔
28
29	return new ValueTask<InterceptionResult<DbDataReader>>(result);	909✔
30	}
31
32	private static void ManipulateCommand(DbCommand command)
33	{
34	if (command.CommandText.Contains("-- STRAIGHT_JOIN", StringComparison.Ordinal))	909✔
35	{
36	command.CommandText = command.CommandText.Replace("SELECT", "SELECT STRAIGHT_JOIN", StringComparison.OrdinalIgnoreCase);	143✔
37	}
38	}
39	}

lucaslorentz / durabletask-extensions / 9336995150

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous