84 lines
2.0 KiB
Go
84 lines
2.0 KiB
Go
package elasticsearch
|
|
|
|
import (
|
|
"github.com/elastic/go-elasticsearch/v8"
|
|
)
|
|
|
|
var (
|
|
es *elasticsearch.TypedClient
|
|
)
|
|
|
|
type elastic struct {
|
|
client *elasticsearch.TypedClient
|
|
}
|
|
|
|
//func (d *Driver) Insert(ctx context.Context, table string, data interface{}, batch ...int) (res sql.Result, err error) {
|
|
//
|
|
// return
|
|
//}
|
|
//
|
|
//// createIndex 创建索引
|
|
//func (d *Driver) CreateIndex(name string) {
|
|
//
|
|
// resp, err := d.client.Indices.
|
|
// Create(name).
|
|
// Do(context.Background())
|
|
// if err != nil {
|
|
// fmt.Printf("create index failed, err:%v\n", err)
|
|
// return
|
|
// }
|
|
// fmt.Printf("index:%#v\n", resp.Index)
|
|
//}
|
|
//
|
|
//// indexDocument 索引文档
|
|
//func (d *Driver) IndexDocument(name string, key string, data interface{}) {
|
|
//
|
|
// // 添加文档
|
|
// resp, err := d.client.Index(name).
|
|
// Id(key).
|
|
// Document(data).
|
|
// Do(context.Background())
|
|
// if err != nil {
|
|
// fmt.Printf("indexing document failed, err:%v\n", err)
|
|
// return
|
|
// }
|
|
// fmt.Printf("result:%#v\n", resp.Result)
|
|
//}
|
|
//
|
|
//// getDocument 获取文档
|
|
//func (d *Driver) GetDocument(name string, id string) (res json.RawMessage) {
|
|
// resp, err := d.client.Get(name, id).
|
|
// Do(context.Background())
|
|
// if err != nil {
|
|
// fmt.Printf("get document by id failed, err:%v\n", err)
|
|
// return
|
|
// }
|
|
// fmt.Printf("fileds:%d\n", resp.Source_)
|
|
// res = resp.Source_
|
|
// return
|
|
//}
|
|
//
|
|
//// updateDocument 更新文档
|
|
//func (d *Driver) UpdateDocument(name string, key string, data interface{}) {
|
|
//
|
|
// resp, err := d.client.Update(name, key).
|
|
// Doc(data). // 使用结构体变量更新
|
|
// Do(context.Background())
|
|
// if err != nil {
|
|
// fmt.Printf("update document failed, err:%v\n", err)
|
|
// return
|
|
// }
|
|
// fmt.Printf("result:%v\n", resp.Result)
|
|
//}
|
|
//
|
|
//// deleteDocument 删除 document
|
|
//func (d *Driver) DeleteDocument(name string, key string) {
|
|
// resp, err := d.client.Delete(name, key).
|
|
// Do(context.Background())
|
|
// if err != nil {
|
|
// fmt.Printf("delete document failed, err:%v\n", err)
|
|
// return
|
|
// }
|
|
// fmt.Printf("result:%v\n", resp.Result)
|
|
//}
|