|
|
@@ -316,6 +316,7 @@ func (req *ESQueryRequest) parseJsonQuery() (queryMap map[string]interface{}) {
|
|
|
func (es *ESClient) Count(params *ESQueryRequest) (response ESResponse, err error) {
|
|
|
queryMap := params.parseJsonQuery()
|
|
|
jsonQuery, _ := json.Marshal(queryMap)
|
|
|
+ logger.Info("查询语句: %s", string(jsonQuery))
|
|
|
request := esapi.CountRequest{
|
|
|
Index: []string{params.IndexName},
|
|
|
Body: strings.NewReader(string(jsonQuery)),
|
|
|
@@ -342,6 +343,7 @@ func (es *ESClient) Count(params *ESQueryRequest) (response ESResponse, err erro
|
|
|
func (es *ESClient) Search(params *ESQueryRequest) (response ESResponse, err error) {
|
|
|
queryMap := params.parseJsonQuery()
|
|
|
jsonQuery, _ := json.Marshal(queryMap)
|
|
|
+ logger.Info("查询语句: %s", string(jsonQuery))
|
|
|
request := esapi.SearchRequest{
|
|
|
Index: []string{params.IndexName},
|
|
|
Body: strings.NewReader(string(jsonQuery)),
|
|
|
@@ -400,6 +402,7 @@ func (es *ESClient) GetCount(hits Hits) []Hit {
|
|
|
// */
|
|
|
func (es *ESClient) AddOrUpdate(indexName string, id int, doc interface{}) bool {
|
|
|
jsonDoc, _ := json.Marshal(doc)
|
|
|
+ logger.Info("查询语句: %s", string(jsonDoc))
|
|
|
req := esapi.IndexRequest{
|
|
|
Index: indexName,
|
|
|
DocumentID: strconv.Itoa(id),
|
kobe6258