ouiytre 发表于 2017-3-23 09:56:29

elasticsearch-jdbc 例子

#!/bin/sh
DIR="$( cd "$( dirname "${BASH_SOURCE}" )" && pwd )"
bin=${DIR}/../bin
lib=${DIR}/../lib
echo '{
"type" : "jdbc",
"jdbc": {
"elasticsearch.autodiscover":true,
"elasticsearch.cluster":"company",
"url":"jdbc:mysql://***:3306/es",
"user":"***",
"password":"***",
"sql":"SELECT id as _id , id, name, status, type,full_name, frequency, gmt_modifiedFROMtable",
"elasticsearch" : {
"host" : "***.***.***.***",
"port" : 9300
},
"index" : "searchsuggestion-temp",
"type" : "searchsuggestion-temp",
"type_mapping": {
   "searchsuggestion-temp": {

      "properties": {

         "id": {
          "type" : "long",
                   "include_in_all" : false
      },
      "name": {
         "type" : "string",
                   "index" : "not_analyzed",
                   "include_in_all" : false
      },
                "status": {
         "type" : "integer",
                   "include_in_all" : false
      },
                "type": {
         "type" : "integer",
                   "include_in_all" : false
      },
                "full_name": {
         "type" : "string",
                   "index" : "not_analyzed",
                   "include_in_all" : false
      },
                "frequency": {
         "type" : "integer",
                   "include_in_all" : false
      },
         "gmt_modified": {
         "type" : "date",
                   "include_in_all" : false
      }

      }
      }
}}
}'| java \
-cp "${lib}/*" \
-Dlog4j.configurationFile=${bin}/log4j2.xml \
org.xbib.tools.Runner \
org.xbib.tools.JDBCImporter

sdylag 发表于 2017-4-1 13:24:03

{:6_394:}{:6_394:}{:6_394:}{:6_394:}{:6_394:}
页: [1]
查看完整版本: elasticsearch-jdbc 例子