Go1.10基于olivere/elastic实现Elasticsearch整条选中记录更新求助

针对你的场景，用olivere/elastic实现「找到则全量更新，找不到则新增」，有两种实用的方式，推荐第一种更高效的方案：

1. 直接利用Index API的Upsert特性（推荐） #

Elasticsearch的Index API本身就自带Upsert逻辑：当你指定文档ID时，如果ID不存在则自动新增文档，存在则全量替换原有文档。这种方式不需要先查询再判断，少一次网络请求，性能更优。

代码示例 #

package main

import (
    "context"
    "fmt"
    "github.com/olivere/elastic" // 注意匹配你的ES版本，比如ES6用v6分支
)

// 定义和数据库对应的记录结构体
type DBRecord struct {
    ID      string `json:"id"`
    Title   string `json:"title"`
    Content string `json:"content"`
    Status  int    `json:"status"`
    // 其他业务字段...
}

func main() {
    // 初始化ES客户端（连接Docker中的ES服务）
    client, err := elastic.NewClient(
        elastic.SetURL("http://localhost:9200"), // 替换成你的Docker ES地址
        elastic.SetSniff(false), // 单节点ES建议关闭自动嗅探
    )
    if err != nil {
        panic(err)
    }

    // 假设这是从数据库获取的更新后记录
    updatedRecord := DBRecord{
        ID:      "db_12345", // 用数据库主键作为ES文档ID，确保一一对应
        Title:   "更新后的文章标题",
        Content: "更新后的文章内容",
        Status:  1,
    }

    // 执行Index请求，自动处理新增/全量更新
    resp, err := client.Index().
        Index("your_index_name"). // 替换成你的ES索引名
        Type("_doc").             // ES7+默认类型为_doc，旧版本按需调整
        Id(updatedRecord.ID).     // 绑定数据库记录的唯一ID
        BodyJson(updatedRecord).  // 传入整个结构体，全量替换原有文档
        Do(context.Background())
    if err != nil {
        panic(err)
    }

    // 打印结果：created表示新增，updated表示全量更新
    fmt.Printf("操作结果: %s，文档ID: %s\n", resp.Result, resp.Id)
}

2. 先查询再处理（适合需依赖旧数据的场景） #

如果你的业务逻辑需要先获取旧文档做对比或其他处理，可以先查询文档，再根据是否存在执行新增或全量更新：

代码示例 #

// 先查询指定ID的文档
getResp, err := client.Get().
    Index("your_index_name").
    Type("_doc").
    Id(updatedRecord.ID).
    Do(context.Background())

if err != nil {
    if elastic.IsNotFound(err) {
        // 文档不存在，执行新增
        _, err = client.Index().
            Index("your_index_name").
            Type("_doc").
            Id(updatedRecord.ID).
            BodyJson(updatedRecord).
            Do(context.Background())
        if err != nil {
            panic(err)
        }
        fmt.Println("文档不存在，已完成新增")
    } else {
        // 处理其他查询错误
        panic(err)
    }
} else {
    // 文档存在，执行全量更新（用Index覆盖原有文档）
    _, err = client.Index().
        Index("your_index_name").
        Type("_doc").
        Id(updatedRecord.ID).
        BodyJson(updatedRecord).
        Do(context.Background())
    if err != nil {
        panic(err)
    }
    fmt.Println("文档已存在，已完成全量更新")
}

注意事项 #

• 版本匹配：确保olivere/elastic的版本和Docker中ES的版本对应（比如ES 6.x用github.com/olivere/elastic/v6），Go 1.10对新版本库可能有兼容性问题，建议选对应ES版本的稳定分支。
• ID绑定：必须用数据库记录的唯一标识（如主键）作为ES文档ID，才能保证数据库和ES记录的一一对应，避免更新错误。
• 全量vs增量：Index API是全量替换，原有文档中未在新结构体中出现的字段（或结构体零值字段）会被覆盖；仅需更新部分字段时，才用Update API的Doc方法。

内容的提问来源于stack exchange，提问作者Coder99