athena.ResultSet.ToMapString - Code Metrics - Inspection of "[athena] Create Athena API (#24)" - evalphobia/aws-sdk-go-v2-wrapper - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 0cc65a...2c9229 )

by eval

created 2020-12-21 18:47 UTC

athena.ResultSet.ToMapString A

↳ Parent: athena/type.go

Complexity

Conditions

Size

Total Lines	20
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	5
eloc	14
nop	0
dl	0
loc	20
rs	9.2333
c	0
b	0
f	0

package athena

import (
	"time"

	SDK "github.com/aws/aws-sdk-go-v2/service/athena"
	"github.com/evalphobia/aws-sdk-go-v2-wrapper/private/pointers"
)

type ColumnInfo struct {

	Name string
	Type string

	// optional
	CaseSensitive bool
	CatalogName   string
	Label         string
	Nullable      ColumnNullable
	Precision     int64
	Scale         int64
	SchemaName    string
	TableName     string
}

func NewColumnInfoListFromMetadata(o *SDK.ResultSetMetadata) []ColumnInfo {

	if o == nil {
		return nil
	}
	return NewColumnInfoList(o.ColumnInfo)
}

func NewColumnInfoList(list []SDK.ColumnInfo) []ColumnInfo {

	if len(list) == 0 {
		return nil
	}

	results := make([]ColumnInfo, len(list))
	for i, v := range list {
		results[i] = NewColumnInfo(v)
	}
	return results
}

func NewColumnInfo(o SDK.ColumnInfo) ColumnInfo {

	r := ColumnInfo{}

	if o.Name != nil {
		r.Name = *o.Name
	}
	if o.Type != nil {
		r.Type = *o.Type
	}
	if o.CaseSensitive != nil {
		r.CaseSensitive = *o.CaseSensitive
	}
	if o.CatalogName != nil {
		r.CatalogName = *o.CatalogName
	}
	if o.Label != nil {
		r.Label = *o.Label
	}
	if o.Precision != nil {
		r.Precision = *o.Precision
	}
	if o.Scale != nil {
		r.Scale = *o.Scale
	}
	if o.SchemaName != nil {
		r.SchemaName = *o.SchemaName
	}
	if o.TableName != nil {
		r.TableName = *o.TableName
	}

	r.Nullable = ColumnNullable(o.Nullable)
	return r
}

type Datum struct {

	VarCharValue string

	HasValue bool
}

func NewDatumList(list []SDK.Datum) []Datum {

	if len(list) == 0 {
		return nil
	}

	results := make([]Datum, len(list))
	for i, v := range list {
		results[i] = NewDatum(v)
	}
	return results
}

func NewDatum(o SDK.Datum) Datum {

	r := Datum{}
	if o.VarCharValue != nil {
		r.VarCharValue = *o.VarCharValue
		r.HasValue = true
	}
	return r
}

type QueryExecutionContext struct {

	Catalog  string
	Database string
}

func NewQueryExecutionContext(o *SDK.QueryExecutionContext) QueryExecutionContext {

	r := QueryExecutionContext{}
	if o == nil {
		return r
	}

	if o.Catalog != nil {
		r.Catalog = *o.Catalog
	}
	if o.Database != nil {
		r.Database = *o.Database
	}
	return r
}

func (v QueryExecutionContext) ToSDK() *SDK.QueryExecutionContext {

	switch {
	case v.Catalog != "",
		v.Database != "":
	default:
		return nil
	}

	o := SDK.QueryExecutionContext{}
	if v.Catalog != "" {
		o.Catalog = pointers.String(v.Catalog)
	}
	if v.Database != "" {
		o.Database = pointers.String(v.Database)
	}
	return &o
}

type QueryExecutionStatistics struct {

	DataManifestLocation          string
	DataScannedInBytes            int64
	EngineExecutionTimeInMillis   int64
	QueryPlanningTimeInMillis     int64
	QueryQueueTimeInMillis        int64
	ServiceProcessingTimeInMillis int64
	TotalExecutionTimeInMillis    int64
}

func NewQueryExecutionStatistics(o *SDK.QueryExecutionStatistics) QueryExecutionStatistics {

	r := QueryExecutionStatistics{}
	if o == nil {
		return r
	}

	if o.DataManifestLocation != nil {
		r.DataManifestLocation = *o.DataManifestLocation
	}
	if o.DataScannedInBytes != nil {
		r.DataScannedInBytes = *o.DataScannedInBytes
	}
	if o.EngineExecutionTimeInMillis != nil {
		r.EngineExecutionTimeInMillis = *o.EngineExecutionTimeInMillis
	}
	if o.QueryPlanningTimeInMillis != nil {
		r.QueryPlanningTimeInMillis = *o.QueryPlanningTimeInMillis
	}
	if o.QueryQueueTimeInMillis != nil {
		r.QueryQueueTimeInMillis = *o.QueryQueueTimeInMillis
	}
	if o.ServiceProcessingTimeInMillis != nil {
		r.ServiceProcessingTimeInMillis = *o.ServiceProcessingTimeInMillis
	}
	if o.TotalExecutionTimeInMillis != nil {
		r.TotalExecutionTimeInMillis = *o.TotalExecutionTimeInMillis
	}
	return r
}

type QueryExecutionStatus struct {

	CompletionDateTime time.Time
	State              QueryExecutionState
	StateChangeReason  string
	SubmissionDateTime time.Time
}

func NewQueryExecutionStatus(o *SDK.QueryExecutionStatus) QueryExecutionStatus {

	r := QueryExecutionStatus{}
	if o == nil {
		return r
	}

	if o.CompletionDateTime != nil {
		r.CompletionDateTime = *o.CompletionDateTime
	}
	if o.StateChangeReason != nil {
		r.StateChangeReason = *o.StateChangeReason
	}
	if o.SubmissionDateTime != nil {
		r.SubmissionDateTime = *o.SubmissionDateTime
	}
	r.State = QueryExecutionState(o.State)
	return r
}

type ResultConfiguration struct {

	OutputLocation   string
	EncryptionKMSKey string
	EncryptionOption EncryptionOption
}

func NewResultConfiguration(o *SDK.ResultConfiguration) ResultConfiguration {

	r := ResultConfiguration{}
	if o == nil {
		return r
	}

	if o.OutputLocation != nil {
		r.OutputLocation = *o.OutputLocation
	}
	if v := o.EncryptionConfiguration; v != nil {
		r.EncryptionOption = EncryptionOption(v.EncryptionOption)
		if v.KmsKey != nil {
			r.EncryptionKMSKey = *v.KmsKey
		}
	}
	return r
}

func (v ResultConfiguration) ToSDK() *SDK.ResultConfiguration {

	switch {
	case v.OutputLocation != "",
		v.EncryptionKMSKey != "",
		v.EncryptionOption != "":
	default:
		return nil
	}

	o := SDK.ResultConfiguration{}

	if v.OutputLocation != "" {
		o.OutputLocation = pointers.String(v.OutputLocation)
	}
	switch {
	case v.EncryptionKMSKey != "",
		v.EncryptionOption != "":
		vv := SDK.EncryptionConfiguration{}
		vv.EncryptionOption = SDK.EncryptionOption(v.EncryptionOption)
		if v.EncryptionKMSKey != "" {
			vv.KmsKey = pointers.String(v.EncryptionKMSKey)
		}
		o.EncryptionConfiguration = &vv
	}
	return &o
}

type ResultSet struct {

	ColumnInfo []ColumnInfo
	Rows       []Row
}

func NewResultSet(o *SDK.ResultSet) ResultSet {

	r := ResultSet{}
	if o == nil {
		return r
	}
	r.ColumnInfo = NewColumnInfoListFromMetadata(o.ResultSetMetadata)
	r.Rows = NewRowList(o.Rows)
	return r
}

func (r ResultSet) ToMapString() []map[string]string {

	if len(r.Rows) < 2 {
		return nil
	}

	results := make([]map[string]string, len(r.Rows)-1)
	hd := r.Rows[0].Data
	header := make([]string, len(hd))
	for i, v := range hd {
		header[i] = v.VarCharValue
	}

	for i, row := range r.Rows[1:] {
		m := make(map[string]string, len(row.Data))
		for j, v := range row.Data {
			m[header[j]] = v.VarCharValue
		}
		results[i] = m
	}
	return results
}

func (r ResultSet) ToListString() [][]string {

	if len(r.Rows) < 2 {
		return nil
	}

	results := make([][]string, len(r.Rows))
	for i, row := range r.Rows {
		rr := make([]string, len(r.Rows))
		for j, v := range row.Data {
			rr[j] = v.VarCharValue
		}
		results[i] = rr
	}
	return results
}

type Row struct {

	Data []Datum
}

func NewRowList(list []SDK.Row) []Row {

	if len(list) == 0 {
		return nil
	}

	results := make([]Row, len(list))
	for i, v := range list {
		results[i] = NewRow(v)
	}
	return results
}

func NewRow(o SDK.Row) Row {

	r := Row{}
	r.Data = NewDatumList(o.Data)
	return r
}


1			package athena
2
3			import (
4			"time"
5
6			SDK "github.com/aws/aws-sdk-go-v2/service/athena"
7			"github.com/evalphobia/aws-sdk-go-v2-wrapper/private/pointers"
8			)
9
10			type ColumnInfo struct {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported type ColumnInfo should have comment or be unexported Loading history...
11			Name string
12			Type string
13
14			// optional
15			CaseSensitive bool
16			CatalogName string
17			Label string
18			Nullable ColumnNullable
19			Precision int64
20			Scale int64
21			SchemaName string
22			TableName string
23			}
24
25			func NewColumnInfoListFromMetadata(o *SDK.ResultSetMetadata) []ColumnInfo {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported function NewColumnInfoListFromMetadata should have comment or be unexported Loading history...
26			if o == nil {
27			return nil
28			}
29			return NewColumnInfoList(o.ColumnInfo)
30			}
31
32			func NewColumnInfoList(list []SDK.ColumnInfo) []ColumnInfo {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported function NewColumnInfoList should have comment or be unexported Loading history...
33			if len(list) == 0 {
34			return nil
35			}
36
37			results := make([]ColumnInfo, len(list))
38			for i, v := range list {
39			results[i] = NewColumnInfo(v)
40			}
41			return results
42			}
43
44			func NewColumnInfo(o SDK.ColumnInfo) ColumnInfo {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported function NewColumnInfo should have comment or be unexported Loading history...
45			r := ColumnInfo{}
46
47			if o.Name != nil {
48			r.Name = *o.Name
49			}
50			if o.Type != nil {
51			r.Type = *o.Type
52			}
53			if o.CaseSensitive != nil {
54			r.CaseSensitive = *o.CaseSensitive
55			}
56			if o.CatalogName != nil {
57			r.CatalogName = *o.CatalogName
58			}
59			if o.Label != nil {
60			r.Label = *o.Label
61			}
62			if o.Precision != nil {
63			r.Precision = *o.Precision
64			}
65			if o.Scale != nil {
66			r.Scale = *o.Scale
67			}
68			if o.SchemaName != nil {
69			r.SchemaName = *o.SchemaName
70			}
71			if o.TableName != nil {
72			r.TableName = *o.TableName
73			}
74
75			r.Nullable = ColumnNullable(o.Nullable)
76			return r
77			}
78
79			type Datum struct {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported type Datum should have comment or be unexported Loading history...
80			VarCharValue string
81
82			HasValue bool
83			}
84
85			func NewDatumList(list []SDK.Datum) []Datum {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported function NewDatumList should have comment or be unexported Loading history...
86			if len(list) == 0 {
87			return nil
88			}
89
90			results := make([]Datum, len(list))
91			for i, v := range list {
92			results[i] = NewDatum(v)
93			}
94			return results
95			}
96
97			func NewDatum(o SDK.Datum) Datum {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported function NewDatum should have comment or be unexported Loading history...
98			r := Datum{}
99			if o.VarCharValue != nil {
100			r.VarCharValue = *o.VarCharValue
101			r.HasValue = true
102			}
103			return r
104			}
105
106			type QueryExecutionContext struct {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported type QueryExecutionContext should have comment or be unexported Loading history...
107			Catalog string
108			Database string
109			}
110
111			func NewQueryExecutionContext(o *SDK.QueryExecutionContext) QueryExecutionContext {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported function NewQueryExecutionContext should have comment or be unexported Loading history...
112			r := QueryExecutionContext{}
113			if o == nil {
114			return r
115			}
116
117			if o.Catalog != nil {
118			r.Catalog = *o.Catalog
119			}
120			if o.Database != nil {
121			r.Database = *o.Database
122			}
123			return r
124			}
125
126			func (v QueryExecutionContext) ToSDK() *SDK.QueryExecutionContext {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported method QueryExecutionContext.ToSDK should have comment or be unexported Loading history...
127			switch {
128			case v.Catalog != "",
129			v.Database != "":
130			default:
131			return nil
132			}
133
134			o := SDK.QueryExecutionContext{}
135			if v.Catalog != "" {
136			o.Catalog = pointers.String(v.Catalog)
137			}
138			if v.Database != "" {
139			o.Database = pointers.String(v.Database)
140			}
141			return &o
142			}
143
144			type QueryExecutionStatistics struct {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported type QueryExecutionStatistics should have comment or be unexported Loading history...
145			DataManifestLocation string
146			DataScannedInBytes int64
147			EngineExecutionTimeInMillis int64
148			QueryPlanningTimeInMillis int64
149			QueryQueueTimeInMillis int64
150			ServiceProcessingTimeInMillis int64
151			TotalExecutionTimeInMillis int64
152			}
153
154			func NewQueryExecutionStatistics(o *SDK.QueryExecutionStatistics) QueryExecutionStatistics {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported function NewQueryExecutionStatistics should have comment or be unexported Loading history...
155			r := QueryExecutionStatistics{}
156			if o == nil {
157			return r
158			}
159
160			if o.DataManifestLocation != nil {
161			r.DataManifestLocation = *o.DataManifestLocation
162			}
163			if o.DataScannedInBytes != nil {
164			r.DataScannedInBytes = *o.DataScannedInBytes
165			}
166			if o.EngineExecutionTimeInMillis != nil {
167			r.EngineExecutionTimeInMillis = *o.EngineExecutionTimeInMillis
168			}
169			if o.QueryPlanningTimeInMillis != nil {
170			r.QueryPlanningTimeInMillis = *o.QueryPlanningTimeInMillis
171			}
172			if o.QueryQueueTimeInMillis != nil {
173			r.QueryQueueTimeInMillis = *o.QueryQueueTimeInMillis
174			}
175			if o.ServiceProcessingTimeInMillis != nil {
176			r.ServiceProcessingTimeInMillis = *o.ServiceProcessingTimeInMillis
177			}
178			if o.TotalExecutionTimeInMillis != nil {
179			r.TotalExecutionTimeInMillis = *o.TotalExecutionTimeInMillis
180			}
181			return r
182			}
183
184			type QueryExecutionStatus struct {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported type QueryExecutionStatus should have comment or be unexported Loading history...
185			CompletionDateTime time.Time
186			State QueryExecutionState
187			StateChangeReason string
188			SubmissionDateTime time.Time
189			}
190
191			func NewQueryExecutionStatus(o *SDK.QueryExecutionStatus) QueryExecutionStatus {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported function NewQueryExecutionStatus should have comment or be unexported Loading history...
192			r := QueryExecutionStatus{}
193			if o == nil {
194			return r
195			}
196
197			if o.CompletionDateTime != nil {
198			r.CompletionDateTime = *o.CompletionDateTime
199			}
200			if o.StateChangeReason != nil {
201			r.StateChangeReason = *o.StateChangeReason
202			}
203			if o.SubmissionDateTime != nil {
204			r.SubmissionDateTime = *o.SubmissionDateTime
205			}
206			r.State = QueryExecutionState(o.State)
207			return r
208			}
209
210			type ResultConfiguration struct {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported type ResultConfiguration should have comment or be unexported Loading history...
211			OutputLocation string
212			EncryptionKMSKey string
213			EncryptionOption EncryptionOption
214			}
215
216			func NewResultConfiguration(o *SDK.ResultConfiguration) ResultConfiguration {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported function NewResultConfiguration should have comment or be unexported Loading history...
217			r := ResultConfiguration{}
218			if o == nil {
219			return r
220			}
221
222			if o.OutputLocation != nil {
223			r.OutputLocation = *o.OutputLocation
224			}
225			if v := o.EncryptionConfiguration; v != nil {
226			r.EncryptionOption = EncryptionOption(v.EncryptionOption)
227			if v.KmsKey != nil {
228			r.EncryptionKMSKey = *v.KmsKey
229			}
230			}
231			return r
232			}
233
234			func (v ResultConfiguration) ToSDK() *SDK.ResultConfiguration {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported method ResultConfiguration.ToSDK should have comment or be unexported Loading history...
235			switch {
236			case v.OutputLocation != "",
237			v.EncryptionKMSKey != "",
238			v.EncryptionOption != "":
239			default:
240			return nil
241			}
242
243			o := SDK.ResultConfiguration{}
244
245			if v.OutputLocation != "" {
246			o.OutputLocation = pointers.String(v.OutputLocation)
247			}
248			switch {
249			case v.EncryptionKMSKey != "",
250			v.EncryptionOption != "":
251			vv := SDK.EncryptionConfiguration{}
252			vv.EncryptionOption = SDK.EncryptionOption(v.EncryptionOption)
253			if v.EncryptionKMSKey != "" {
254			vv.KmsKey = pointers.String(v.EncryptionKMSKey)
255			}
256			o.EncryptionConfiguration = &vv
257			}
258			return &o
259			}
260
261			type ResultSet struct {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported type ResultSet should have comment or be unexported Loading history...
262			ColumnInfo []ColumnInfo
263			Rows []Row
264			}
265
266			func NewResultSet(o *SDK.ResultSet) ResultSet {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported function NewResultSet should have comment or be unexported Loading history...
267			r := ResultSet{}
268			if o == nil {
269			return r
270			}
271			r.ColumnInfo = NewColumnInfoListFromMetadata(o.ResultSetMetadata)
272			r.Rows = NewRowList(o.Rows)
273			return r
274			}
275
276			func (r ResultSet) ToMapString() []map[string]string {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported method ResultSet.ToMapString should have comment or be unexported Loading history...
277			if len(r.Rows) < 2 {
278			return nil
279			}
280
281			results := make([]map[string]string, len(r.Rows)-1)
282			hd := r.Rows[0].Data
283			header := make([]string, len(hd))
284			for i, v := range hd {
285			header[i] = v.VarCharValue
286			}
287
288			for i, row := range r.Rows[1:] {
289			m := make(map[string]string, len(row.Data))
290			for j, v := range row.Data {
291			m[header[j]] = v.VarCharValue
292			}
293			results[i] = m
294			}
295			return results
296			}
297
298			func (r ResultSet) ToListString() [][]string {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported method ResultSet.ToListString should have comment or be unexported Loading history...
299			if len(r.Rows) < 2 {
300			return nil
301			}
302
303			results := make([][]string, len(r.Rows))
304			for i, row := range r.Rows {
305			rr := make([]string, len(r.Rows))
306			for j, v := range row.Data {
307			rr[j] = v.VarCharValue
308			}
309			results[i] = rr
310			}
311			return results
312			}
313
314			type Row struct {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported type Row should have comment or be unexported Loading history...
315			Data []Datum
316			}
317
318			func NewRowList(list []SDK.Row) []Row {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported function NewRowList should have comment or be unexported Loading history...
319			if len(list) == 0 {
320			return nil
321			}
322
323			results := make([]Row, len(list))
324			for i, v := range list {
325			results[i] = NewRow(v)
326			}
327			return results
328			}
329
330			func NewRow(o SDK.Row) Row {
			0 ignored issues – show introduced 2020-12-21 18:38 UTC by Report Bug Copy Issue Report exported function NewRow should have comment or be unexported Loading history...
331			r := Row{}
332			r.Data = NewDatumList(o.Data)
333			return r
334			}
335

evalphobia / aws-sdk-go-v2-wrapper

Push — master ( 0cc65a...2c9229 )

athena.ResultSet.ToMapString A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like