import data into elastic search from mysql - downgoon/hello-world GitHub Wiki

`mysql-passport-user-sit-all.sh`


#!/bin/sh
DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )"
bin=${DIR}/../bin
lib=${DIR}/../lib

echo '
{
    "type" : "jdbc",
    "jdbc" : {
        "url" : "jdbc:mysql://10.209.44.12:10043/passport",
        "user" : "passport",
        "password" : "passport",

        "sql" : [ {
            "statement" : "select a.id as _id, nick, headface, gender, mobile, email, emailchk, u.createtime as createtime from access a, user u where a.id = u.id"
           } ],

        "elasticsearch" : {
             "cluster" : "elasticsearch",
             "host" : "localhost",
             "port" : 9300
        },
        "index" : "passport",
        "type" : "user"
    }
}
' | java \
    -cp "${lib}/*" \
    org.xbib.tools.Runner \
    org.xbib.tools.JDBCImporter

查询测试

查询昵称为 xujingyan1 的用户

http://10.213.42.230:10092/passport/user/_search?q=nick:xujingyan1

查询邮件后缀为 qq.com 的用户

http://10.213.42.230:10092/passport/user/_search?q=email:qq.com