15063404311

Committed 16 May 2025 07:46AM UTC coverage: 27.73% (+1.0%) from 26.721%

Build # 15063404311

Build Type

push

github

Committed by

jbeemster

Commit Message

Prepared for release

Run Details

353 of 1273 relevant lines covered (27.73%)

2.04 hits per line

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

0.0

/sql_runner/scanner.go

// Copyright (c) 2015-2025 Snowplow Analytics Ltd. All rights reserved.
//
// This program is licensed to you under the Apache License Version 2.0,
// and you may not use this file except in compliance with the Apache License Version 2.0.
// You may obtain a copy of the Apache License Version 2.0 at http://www.apache.org/licenses/LICENSE-2.0.
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the Apache License Version 2.0 is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the Apache License Version 2.0 for the specific language governing permissions and limitations there under.
package main

import (
        "github.com/go-pg/pg/v10/orm"
        "github.com/go-pg/pg/v10/types"
)

// Results information.
type Results struct {
        results  [][]string
        columns  []string
        elements int
        rows     int
}

var _ orm.HooklessModel = (*Results)(nil)

// Init initializes Results.
func (results *Results) Init() error {
        results.elements = 0
        results.rows = 0

        if s := results; len(s.results) >= 0 {
                results.results = (s.results)[:0]
        }

        if s := results; len(s.columns) >= 0 {
                results.columns = (s.columns)[:0]
        }
        return nil
}

// NextColumnScanner returns a ColumnScanner that is used to scan columns.
func (results *Results) NextColumnScanner() orm.ColumnScanner {
        return results
}

// AddColumnScanner adds the ColumnScanner to the model.
func (Results) AddColumnScanner(_ orm.ColumnScanner) error {
        return nil
}

// ScanColumn implements ColumnScanner interface.
func (results *Results) ScanColumn(col types.ColumnInfo, rd types.Reader, n int) error {
        tmp, err := rd.ReadFullTemp()
        if err != nil {
                return err
        }

        curRow := len(results.results) - 1

        if col.Index == 0 {
                results.results = append(results.results, []string{})
                curRow = len(results.results) - 1
                results.rows++
        }

        if curRow == 0 {
                results.columns = append(results.columns, col.Name)
        }

        results.elements++
        results.results[curRow] = append(results.results[curRow], string(tmp))
        return nil
}

1	// Copyright (c) 2015-2025 Snowplow Analytics Ltd. All rights reserved.
2	//
3	// This program is licensed to you under the Apache License Version 2.0,
4	// and you may not use this file except in compliance with the Apache License Version 2.0.
5	// You may obtain a copy of the Apache License Version 2.0 at http://www.apache.org/licenses/LICENSE-2.0.
6	//
7	// Unless required by applicable law or agreed to in writing,
8	// software distributed under the Apache License Version 2.0 is distributed on an
9	// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
10	// See the Apache License Version 2.0 for the specific language governing permissions and limitations there under.
11	package main
12
13	import (
14	"github.com/go-pg/pg/v10/orm"
15	"github.com/go-pg/pg/v10/types"
16	)
17
18	// Results information.
19	type Results struct {
20	results [][]string
21	columns []string
22	elements int
23	rows int
24	}
25
26	var _ orm.HooklessModel = (*Results)(nil)
27
28	// Init initializes Results.
29	func (results *Results) Init() error {	×
30	results.elements = 0	×
31	results.rows = 0	×
32		×
33	if s := results; len(s.results) >= 0 {	×
34	results.results = (s.results)[:0]	×
35	}	×
36
37	if s := results; len(s.columns) >= 0 {	×
38	results.columns = (s.columns)[:0]	×
39	}	×
40	return nil	×
41	}
42
43	// NextColumnScanner returns a ColumnScanner that is used to scan columns.
44	func (results *Results) NextColumnScanner() orm.ColumnScanner {	×
45	return results	×
46	}	×
47
48	// AddColumnScanner adds the ColumnScanner to the model.
49	func (Results) AddColumnScanner(_ orm.ColumnScanner) error {	×
50	return nil	×
51	}	×
52
53	// ScanColumn implements ColumnScanner interface.
54	func (results *Results) ScanColumn(col types.ColumnInfo, rd types.Reader, n int) error {	×
55	tmp, err := rd.ReadFullTemp()	×
56	if err != nil {	×
57	return err	×
58	}	×
59
60	curRow := len(results.results) - 1	×
61		×
62	if col.Index == 0 {	×
63	results.results = append(results.results, []string{})	×
64	curRow = len(results.results) - 1	×
65	results.rows++	×
66	}	×
67
68	if curRow == 0 {	×
69	results.columns = append(results.columns, col.Name)	×
70	}	×
71
72	results.elements++	×
73	results.results[curRow] = append(results.results[curRow], string(tmp))	×
74	return nil	×
75	}

snowplow / sql-runner / 15063404311

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