1

我正在使用jdbc 河，我可以创建以下索引：

curl -XPUT 'localhost:9201/_river/email/_meta' -d '{
    "type" : "jdbc",
    "jdbc" : {
        "strategy":"simple", 
        "poll":"10",
        "driver" : "org.postgresql.Driver",
        "url" : "jdbc:postgresql://localhost:5432/api_development",
        "username" : "paulcowan",
        "password" : "",
        "sql" : "SELECT id, subject, body, personal, sent_at, read_by, account_id, sender_user_id, sender_contact_id, html, folder, draft FROM emails"
    },
    "index" : {
        "index" : "email",
        "type" : "jdbc"
    },
    "mappings" : {
        "email" : {
      "properties" : {
        "account_id" : { "type" : "integer" },
        "subject" : { "type" : "string" },
        "body" : { "type" : "string" },
        "html" : { "type" : "string" },
        "folder" : { "type" : "string", "index" : "not_analyzed" },
        "id" : { "type" : "integer" }
      }
      }
    }
}'

我可以像这样使用 curl 运行基本查询：

curl -XGET 'http://localhost:9201/email/jdbc/_search?pretty&q=fullcontact'

我得到结果

但我想要做的是将结果限制为特定电子邮件account_id和特定电子邮件，我运行以下查询：

curl -XGET 'http://localhost:9201/email/jdbc/_search' -d '{
  "query": {
    "filtered": {
      "filter": {
        "and": [
          {
            "term": {
              "folder": "INBOX"
            }
          },
          {
            "term": {
              "account_id": 1
            }
          }
        ]
      },
      "query": {
        "query_string": {
          "query": "fullcontact*"
        }
      }
    }
  }
}'

我得到以下结果：

{
  "took": 3,
  "timed_out": false,
  "_shards": {
    "total": 5,
    "successful": 5,
    "failed": 0
  },
  "hits": {
    "total": 0,
    "max_score": null,
    "hits": []
  }
}

谁能告诉我我的查询有什么问题？

4

1 回答 1

0

事实证明，您需要使用 type_mapping 部分来指定一个字段 is not_analyzed 在 jdbc 河中，法线映射节点被忽略。

结果如下：

curl -XPUT 'localhost:9200/_river/your_index/_meta' -d '{
    "type" : "jdbc",
    "jdbc" : {
        "strategy":"simple", 
        "poll":"10",
        "driver" : "org.postgresql.Driver",
        "url" : "jdbc:postgresql://localhost:5432/api_development",
        "username" : "user",
        "password" : "your_password",
        "sql" : "SELECT field_one, field_two, field_three, the_rest FROM blah"
    },
    "index" : {
        "index" : "your_index",
        "type" : "jdbc",
    "type_mapping": "{\"your_index\" : {\"properties\" : {\"field_two\":{\"type\":\"string\",\"index\":\"not_analyzed\"}}}}"
    }
}'

奇怪或烦人的是，type_mapping 部分采用 json 编码字符串，而不是普通的 json 节点：

我可以通过运行检查映射：

# check mappings
curl -XGET 'http://localhost:9200/your_index/jdbc/_mapping?pretty=true'

应该给出如下内容：

{
  "jdbc" : {
    "properties" : {
      "field_one" : {
        "type" : "long"
      },
      "field_two" : {
        "type" : "string",
        "index" : "not_analyzed",
        "omit_norms" : true,
        "index_options" : "docs"
      },
      "field_three" : {
        "type" : "string"
      }
    }
  }
}
于 2013-12-10T11:47:11.023 回答