6834079100

Committed 11 Nov 2023 12:05PM UTC coverage: 82.326%. Remained the same

Build # 6834079100

Build Type

push

github

Committed by

web-flow

Commit Message

Merge branch 'main' into add-limit-to-purge-with-filter

Run Details

2357 of 2863 relevant lines covered (82.33%)

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

lucaslorentz / durabletask-extensions / 6834079100

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