-
Notifications
You must be signed in to change notification settings - Fork 29
/
Copy pathjson2csv.go
64 lines (58 loc) · 1.14 KB
/
json2csv.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
// Package json2csv provides JSON to CSV functions.
package json2csv
import (
"errors"
"reflect"
)
// JSON2CSV converts JSON to CSV.
func JSON2CSV(data interface{}) ([]KeyValue, error) {
results := []KeyValue{}
v := valueOf(data)
switch v.Kind() {
case reflect.Map:
if v.Len() > 0 {
result, err := flatten(v)
if err != nil {
return nil, err
}
results = append(results, result)
}
case reflect.Slice:
if isObjectArray(v) {
for i := 0; i < v.Len(); i++ {
result, err := flatten(v.Index(i))
if err != nil {
return nil, err
}
results = append(results, result)
}
} else if v.Len() > 0 {
result, err := flatten(v)
if err != nil {
return nil, err
}
if result != nil {
results = append(results, result)
}
}
default:
return nil, errors.New("Unsupported JSON structure.")
}
return results, nil
}
func isObjectArray(obj interface{}) bool {
value := valueOf(obj)
if value.Kind() != reflect.Slice {
return false
}
len := value.Len()
if len == 0 {
return false
}
for i := 0; i < len; i++ {
if valueOf(value.Index(i)).Kind() != reflect.Map {
return false
}
}
return true
}