Go语言中处理XML重复元素的迭代解析策略

<data>
  <entry>
    <id>101</id>
    <title>First Item</title>
    <description>Details for the first item.</description>
    <metadata>
      <source>Web</source>
    </metadata>
  </entry>
  <entry>
    <id>102</id>
    <title>Second Item</title>
    <description>More details for the second item.</description>
    <metadata>
      <source>API</source>
    </metadata>
  </entry>
</data>

package main

import (
    "encoding/xml"
    "fmt"
    "io"
    "log"
    "os"
)

// Metadata 结构体对应 <metadata> 元素
type Metadata struct {
    Source string `xml:"source"`
}

// Entry 结构体对应 <entry> 元素
type Entry struct {
    XMLName     xml.Name `xml:"entry"` // 明确指定XML元素名
    ID          string   `xml:"id"`
    Title       string   `xml:"title"`
    Description string   `xml:"description"`
    Metadata    Metadata `xml:"metadata"` // 嵌套结构体
}

// Data 结构体对应 <data> 元素，虽然我们不直接解析整个Data，但可以作为参考
type Data struct {
    XMLName xml.Name `xml:"data"`
    Entries []Entry  `xml:"entry"`
}

func main() {
    filename := "data.xml" // 假设XML数据保存在data.xml文件中

    // 创建一个示例XML文件用于测试
    createSampleXML(filename)

    xmlFile, err := os.Open(filename)
    if err != nil {
        log.Fatalf("Error opening XML file: %v", err)
    }
    defer xmlFile.Close()

    decoder := xml.NewDecoder(xmlFile)
    totalEntriesProcessed := 0

    for {
        // 读取下一个XML令牌
        token, err := decoder.Token()
        if err == io.EOF {
            // 文件末尾，退出循环
            break
        }
        if err != nil {
            log.Fatalf("Error getting XML token: %v", err)
        }

        // 判断令牌类型
        switch startElement := token.(type) {
        case xml.StartElement:
            // 检查是否是目标 <entry> 元素
            if startElement.Name.Local == "entry" {
                var entry Entry // 声明一个 Entry 结构体变量来存储当前 <entry> 的数据
                // 使用 DecodeElement 将当前 <entry> 元素及其内容解析到 entry 变量中
                err := decoder.DecodeElement(&entry, &startElement)
                if err != nil {
                    log.Printf("Error decoding entry: %v", err)
                    // 可以选择跳过当前错误元素或终止程序
                    continue
                }

                // 成功解析了一个 <entry> 元素，现在可以对 'entry' 进行操作
                fmt.Printf("--- Processed Entry #%d ---\n", totalEntriesProcessed+1)
                fmt.Printf("  ID: %s\n", entry.ID)
                fmt.Printf("  Title: %s\n", entry.Title)
                fmt.Printf("  Description: %s\n", entry.Description)
                fmt.Printf("  Metadata Source: %s\n", entry.Metadata.Source)
                fmt.Println("--------------------------")

                totalEntriesProcessed++
                // 在这里可以执行数据库存储、进一步的数据转换等操作
            }
        }
    }

    fmt.Printf("Finished processing. Total entries processed: %d\n", totalEntriesProcessed)
}

// createSampleXML 函数用于生成一个示例XML文件
func createSampleXML(filename string) {
    sampleXML := `
<data>
  <entry>
    <id>101</id>
    <title>First Item</title>
    <description>Details for the first item.</description>
    <metadata>
      <source>Web</source>
    </metadata>
  </entry>
  <entry>
    <id>102</id>
    <title>Second Item</title>
    <description>More details for the second item.</description>
    <metadata>
      <source>API</source>
    </metadata>
  </entry>
  <entry>
    <id>103</id>
    <title>Third Item</title>
    <description>Yet another item.</description>
    <metadata>
      <source>Manual</source>
    </metadata>
  </entry>
</data>`
    err := os.WriteFile(filename, []byte(sampleXML), 0644)
    if err != nil {
        log.Fatalf("Failed to create sample XML file: %v", err)
    }
}