package main

import (
	"dsTools/Utils/EsUtil"
	"dsTools/Utils/FileUtil"
	"fmt"
	"io/ioutil"
	"strings"
)

func main() {
	//遍历目录下所有的文件
	rd, _ := ioutil.ReadDir("MappingAddJson/")
	for _, fi := range rd {
		if strings.Index(fi.Name(), ".json") > 0 {
			indexName := strings.Replace(fi.Name(), ".json", "", -1)
			//1、判断指定的index是否存在
			found := EsUtil.IndexIsExists(indexName)
			if !found {
				fmt.Println("索引" + indexName + "不存在，无法创建！")
				return
			}
			var jsonFile = "MappingAddJson/" + indexName + ".json"
			//3、追加mapping定义
			createMappingStr := FileUtil.ReadFileContent(jsonFile)
			EsUtil.AddMapping(indexName, createMappingStr)
			fmt.Println("索引"+indexName+"已成功追加Mapping！")
		}
	}
	fmt.Println("恭喜，追加索引工作成功完成！")
}