struct.go

package neo4j

import (
	"encoding/json"
	"fmt"
)

func mapToMapParam(item map[string]interface{}, existingParams map[string]interface{}, prefix ...string) (result, params map[string]interface{}) {
	var prf string
	if prefix != nil && len(prefix) > 0 {
		prf = prefix[0]
	}
	result = map[string]interface{}{}
	params = map[string]interface{}{}
	for k, v := range item {
		k2 := prf + k
		if existingParams != nil {
			tempK := k2
			ind := 1
			for {
				if _, keyExists := existingParams[tempK]; keyExists {
					ind++
					tempK = fmt.Sprintf("%s_%d", k2, ind)
				} else {
					break
				}
			}
			k2 = tempK
		}
		if mapItem, ok := v.(map[string]interface{}); ok {
			nestedResult, nestedParams := mapToMapParam(mapItem, params, prefix...)
			for rk, rv := range nestedResult {
				result[fmt.Sprintf("%s$%s", k, rk)] = rv
			}
			for pk, pv := range nestedParams {
				params[pk] = pv
			}
		} else {
			result[k] = "$" + k2
			params[k2] = v
		}
	}
	return
}

func structToMap(item interface{}) (result map[string]interface{}, err error) {
	if item == nil {
		return
	}
	bytes, err := json.Marshal(item)
	if err != nil {
		return
	}
	result = map[string]interface{}{}
	err = json.Unmarshal(bytes, &result)
	if err != nil {
		return
	}
	return
}

func structToMapParam(item interface{}, prefix ...string) (result, params map[string]interface{}) {
	params = map[string]interface{}{}
	if item == nil {
		return
	}
	result, err := structToMap(item)
	if err != nil {
		return
	}
	result, params = mapToMapParam(result, nil, prefix...)
	return
}

func arrayToMap(keys []string, values []any) map[string]any {
	var data = map[string]any{}
	for i, key := range keys {
		data[key] = values[i]
	}
	return data
}