11548165371

Committed 28 Oct 2024 05:50AM UTC coverage: 87.467% (+2.2%) from 85.281%

Build # 11548165371

Build Type

push

github

Committed by

shamcode

Commit Message

Change go version

Run Details

1996 of 2282 relevant lines covered (87.47%)

39.93 hits per line

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

74.19

/debug/executor.go

package debug

import (
        "context"
        "strings"

        "github.com/shamcode/simd/record"

        "github.com/shamcode/simd/executor"
        "github.com/shamcode/simd/query"
)

type QueryExecutorWithDump[R record.Record] interface {
        executor.QueryExecutor[R]
        DumpQuery(query query.Query[R], onlyTotal bool)
}

type debugExecutor[R record.Record] struct {
        executor executor.QueryExecutor[R]
        dump     func(string)
}

func (e *debugExecutor[R]) FetchTotal(
        ctx context.Context,
        query query.Query[R],
) (int, error) {
        e.DumpQuery(query, true)
        return e.executor.FetchTotal(ctx, query)
}

func (e *debugExecutor[R]) FetchAll(
        ctx context.Context,
        query query.Query[R],
) (executor.Iterator[R], error) {
        e.DumpQuery(query, false)
        return e.executor.FetchAll(ctx, query)
}

func (e *debugExecutor[R]) FetchAllAndTotal(
        ctx context.Context,
        query query.Query[R],
) (executor.Iterator[R], int, error) {
        e.DumpQuery(query, false)
        return e.executor.FetchAllAndTotal(ctx, query)
}

func (e *debugExecutor[R]) DumpQuery(query query.Query[R], onlyTotal bool) {
        var result strings.Builder
        result.WriteString("SELECT ")
        if !onlyTotal {
                result.WriteString("*, ")
        }
        result.WriteString("COUNT(*)")
        if dq, ok := any(query).(QueryWithDumper[R]); ok {
                result.WriteString(dq.String())
        } else {
                result.WriteString(" <Query dont implement QueryWithDumper interface, check QueryBuilder>")
        }
        e.dump(result.String())
}

func WrapQueryExecutor[R record.Record](
        executor executor.QueryExecutor[R],
        dump func(string),
) executor.QueryExecutor[R] {
        return &debugExecutor[R]{
                executor: executor,
                dump:     dump,
        }
}

1	package debug
2
3	import (
4	"context"
5	"strings"
6
7	"github.com/shamcode/simd/record"
8
9	"github.com/shamcode/simd/executor"
10	"github.com/shamcode/simd/query"
11	)
12
13	type QueryExecutorWithDump[R record.Record] interface {
14	executor.QueryExecutor[R]
15	DumpQuery(query query.Query[R], onlyTotal bool)
16	}
17
18	type debugExecutor[R record.Record] struct {
19	executor executor.QueryExecutor[R]
20	dump func(string)
21	}
22
23	func (e *debugExecutor[R]) FetchTotal(
24	ctx context.Context,
25	query query.Query[R],
26	) (int, error) {	×
27	e.DumpQuery(query, true)	×
28	return e.executor.FetchTotal(ctx, query)	×
29	}	×
30
31	func (e *debugExecutor[R]) FetchAll(
32	ctx context.Context,
33	query query.Query[R],
34	) (executor.Iterator[R], error) {	25✔
35	e.DumpQuery(query, false)	25✔
36	return e.executor.FetchAll(ctx, query)	25✔
37	}	25✔
38
39	func (e *debugExecutor[R]) FetchAllAndTotal(
40	ctx context.Context,
41	query query.Query[R],
42	) (executor.Iterator[R], int, error) {	×
43	e.DumpQuery(query, false)	×
44	return e.executor.FetchAllAndTotal(ctx, query)	×
45	}	×
46
47	func (e *debugExecutor[R]) DumpQuery(query query.Query[R], onlyTotal bool) {	25✔
48	var result strings.Builder	25✔
49	result.WriteString("SELECT ")	25✔
50	if !onlyTotal {	50✔
51	result.WriteString("*, ")	25✔
52	}	25✔
53	result.WriteString("COUNT(*)")	25✔
54	if dq, ok := any(query).(QueryWithDumper[R]); ok {	49✔
55	result.WriteString(dq.String())	24✔
56	} else {	25✔
57	result.WriteString(" <Query dont implement QueryWithDumper interface, check QueryBuilder>")	1✔
58	}	1✔
59	e.dump(result.String())	25✔
60	}
61
62	func WrapQueryExecutor[R record.Record](
63	executor executor.QueryExecutor[R],
64	dump func(string),
65	) executor.QueryExecutor[R] {	25✔
66	return &debugExecutor[R]{	25✔
67	executor: executor,	25✔
68	dump: dump,	25✔
69	}	25✔
70	}	25✔

shamcode / simd / 11548165371

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