您好,欢迎来到九壹网。
搜索
您的当前位置:首页同步-elasticseachjdbc-riverreadonly

同步-elasticseachjdbc-riverreadonly

来源:九壹网
 同步jdbcriver数据elsaticsearchmysql

使用jdbcriver 连接mysql,同步数据,同步已有的,新增的,修改的,可以同步数据但是报错
我用java程序jdbc查询数据的时候并不报错,
这是建立索引的代码:
创建索引
curl -XPUT 'http://localhost:9200/profile'
创建数据表与索引映射
curl -XPUT 'http://localhost:9200/profile/user/_mapping' -d '
{
"user": {
"properties": {
"id": {
"type": "string",
"store": "yes"
},
"name": {
"type": "string",
"store": "yes"
},
"login_name": {
"type": "string",
"store": "yes"
}
}
}
}'

  • 运行river同步数据
  • curl -XPUT 'http://localhost:9200/_river/who_jdbc_river/_meta' -d '{
    "type": "jdbc",
    "jdbc": {
    "driver": "com.mysql.jdbc.Driver",
    "url": "jdbc:mysql://localhost:3306/profile",
    "user": "root",
    "password": "root",
    "sql": "select id as _id,name,login_name from user",
    "index": "profile",
    "type": "user",
    "bulk_size": 100,
    "max_bulk_requests": 30,
    "bulk_timeout": "10s",
    "flush_interval": "5s",
    "schedule": "0 0-59 0-23 ? * *"
    }
    }' 经过三个步骤后,可以同步我本地数据库中的数据了,只是报错,想解决一下,各位帮帮忙

    Copyright © 2019- 91gzw.com 版权所有 湘ICP备2023023988号-2

    违法及侵权请联系:TEL:199 18 7713 E-MAIL:2724546146@qq.com

    本站由北京市万商天勤律师事务所王兴未律师提供法律服务