19704439390

Committed 26 Nov 2025 12:55PM UTC coverage: 79.868% (-3.2%) from 83.091%

Build # 19704439390

Build Type

push

github

Committed by

web-flow

Commit Message

Merge 184da62ca into 7a5a0b9c2

Run Details

2305 of 2886 relevant lines covered (79.87%)

119.79 hits per line

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

0.0

/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);	×
28
29	return new ValueTask<InterceptionResult<DbDataReader>>(result);	×
30	}
31
32	private static void ManipulateCommand(DbCommand command)
33	{
34	if (command.CommandText.Contains("-- STRAIGHT_JOIN", StringComparison.Ordinal))	×
35	{
36	command.CommandText = command.CommandText.Replace("SELECT", "SELECT STRAIGHT_JOIN", StringComparison.OrdinalIgnoreCase);	×
37	}
38	}
39	}

lucaslorentz / durabletask-extensions / 19704439390

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