合并两个 JSON 数组的 golang 公共键

一分耕耘，一分收获！既然都打开这篇《合并两个 JSON 数组的 golang 公共键》，就坚持看下去，学下去吧！本文主要会给大家讲到等等知识点，如果大家对本文有好的建议或者看到有不足之处，非常欢迎大家积极提出！在后续文章我会继续更新Golang相关的内容，希望对大家都有所帮助！

这几天我尝试根据一个公用密钥合并两个 jons。我输入了两个具有公共字段的不同 json，我想根据公共键合并两个 json 的数据。两个 json 之间的一种 sql 连接。

json 源自此代码

func dati_plus(c *gin.context) {

oracle, err := http.get("http://xxxx/xxx")
    if err != nil {
            panic(err)
    }
defer oracle.body.close()

mysql, err := http.get("http://xxxx/xxx")
if err != nil {
        panic(err)
}
defer mysql.body.close()

oraclejson, err := ioutil.readall(oracle.body)
if err != nil {
        panic(err)
}
mysqljson, err := ioutil.readall(mysql.body)
if err != nil {
        panic(err)
}

var oracleout map[string]interface{}
var mysqlout map[string]interface{}

json.unmarshal([]byte(oraclejson), &oracleout)
json.unmarshal([]byte(mysqljson), &mysqlout)

a := map[string]interface{}{"result":mysqlout["result"]}
b := map[string]interface{}{"result":oracleout["result"]}

输入中的 json 具有以下形式

{"count":2,"result":[{"desc":"2","nomemy":"pippo","cognomemy":"pippo"},{"desc":"7","nomemy":"pippo","cognomemy":"pippo"}]

{"count":2,"result":[{"desc":"2","cos":"pippo","ros":"pippo"},{"desc":"7","cos":"pippo","ros":"pippo"},{"desc":"60","cos":"pippo","ros":"pippo"}]

如果我有两个像这样的 json 函数的结果应该是

{"count":2,"result":[{"desc":"2","cos":"pippo","ros":"pippo","nomemy":"pippo","cognomemy":"pippo"},{"desc":"7","cos":"pippo","ros":"pippo","nomemy":"pippo","cognomemy":"pippo"},{"desc":"60","cos":"pippo","ros":"pippo"}]

如果有帮助的话，这是我用来合并两个单值 json 的函数，但我无法以正确的方式修改它

func merge(dst, src map[string]interface{}, depth int) map[string]interface{} {
    if depth > MaxDepth {
        panic("Troppo Lungo")
    }
    for key, srcVal := range src {
        if dstVal, ok := dst[key]; ok {
            srcMap, srcMapOk := mapify(srcVal)
            dstMap, dstMapOk := mapify(dstVal)
            if srcMapOk && dstMapOk {
                srcVal = merge(dstMap, srcMap, depth+1)
            }
        }
        dst[key] = srcVal
    }
    return dst
}

    func mapify(i interface{}) (map[string]interface{}, bool) {
        value := reflect.ValueOf(i)
        if value.Kind() == reflect.Map {
            m := map[string]interface{}{}
            for _, k := range value.MapKeys() {
                m[k.String()] = value.MapIndex(k).Interface()
            }
            return m, true
        }
        return map[string]interface{}{}, false
    }

请帮助我。谢谢

解决方案

这里的一个观察是，您可以定义一个简单的类型，它将对您的数据集进行建模，并使用 golang 类型系统来发挥您的优势（而不是通过使用如此多的反射来对抗它），例如：

type data struct {
  count   int                 `json:"count"`
  results []map[string]string `json:"result"`
}

// ...
oracledata, mysqldata := data{}, data{}
err := json.unmarshal([]byte(oraclejson), &oracledata)
check(err)
err := json.unmarshal([]byte(mysqljson), &mysqldata)
check(err)

现在，您的“合并”函数可以简单地返回一个新的“数据”结构，其中包含从两个输入填充的值，而不必担心类型断言或转换。此实现的一个关键特性是，它通过数据结果对象的“desc”键创建一个查找表，稍后用于关联：

func merge(d1, d2 Data) Data {
  // Create the lookup table by each result object "DESC".
  d1ResultsByDesc := map[string]map[string]string{}
  for _, obj1 := range d1.Results {
    d1ResultsByDesc[obj1["DESC"]] = obj1
  }

  newData := Data{}
  for _, obj2 := range d2.Results {
    newObj := map[string]string{}
    // Include all result data objects from d2
    for k2, v2 := range obj2 {
      newObj[k2] = v2
    }
    // Also include the matching result data from d1
    obj1 := d1ResultsByDesc[obj2["DESC"]]
    for k1, v1 := range obj1 {
      newObj[k1] = v1
    }
    newData.Results = append(newData.Results, newObj)
  }

  return newData
}

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。