# Elasticsearch river for postgres **URL:** \ **Category:** Elasticsearch\ **Created:** [June 25, 2014, 9:00am UTC](https://discuss.elastic.co/t/elasticsearch-river-for-postgres/18322 "2014-06-25T09:00:04Z")\ **Posts on this page:** 11\ **Page:** 1
**Author:** ![Jorge\_von\_Rudno](https://avatars.discourse-cdn.com/v4/letter/j/71c47a/32.png) [@Jorge\_von\_Rudno](https://discuss.elastic.co/u/Jorge_von_Rudno)\ **Post date:** [June 25, 2014, 9:00am UTC](https://discuss.elastic.co/t/elasticsearch-river-for-postgres/18322/1 "2014-06-25T09:00:04Z")
Dear colleagues, I just start to work with ES and after read the documentation, I am trying to load the data from my postgres db. To do this I found that the plugin river jdbc should be work for this purpose. After following the instruction to install the plugin, I run the following command and my expectation is to have the whole data in the index created for river: curl -XPUT '[http://localhost:9200/\_river/customers/\_meta](http://localhost:9200/_river/customers/_meta)' -d' { "type" : "jdbc", "jdbc" : { "url" : "jdbc:postgresql://192.100.10.17:5432/customers", "user" : "postgres", "password" : "", "sql" : "SELECT ba.customernumber, ba.company, ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main = 1 AND rd.status != 5", "strategy" : "oneshot" } }' After run the command I get the notification message: {"\_index":"\_river","\_type":"customers","\_id":"\_meta","\_version":1,"created":true} As I say before I was expecting to get all the data but if I make a query I just get: { "took": 1, "timed\_out": false, "\_shards": { "total": 1, "successful": 1, "failed": 0 }, "hits": { "total": 1, "max\_score": 1, "hits": [ { "\_index": "\_river", "\_type": "customers", "\_id": "\_meta", "\_score": 1, "\_source": { "type": "jdbc", "jdbc": { "url": "jdbc:postgresql://192.100.10.17:5432/kunden", "user": "postgres", "password": "", "sql": "SELECT ba.customernumber, ba.company, ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main = 1 AND rd.status != 5", "strategy": "oneshot" } } } ] } } My question is if I just omit something or I am doing something wrong. In advance thanks a lot. Regards Jorge von Rudno -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\ **Post date:** [June 25, 2014, 9:04am UTC](https://discuss.elastic.co/t/elasticsearch-river-for-postgres/18322/2 "2014-06-25T09:04:17Z")
How did you run your search? By any chance did you search in \_river index? -- David Pilato | Technical Advocate | [Elasticsearch.com](http://Elasticsearch.com) @dadoonet | @elasticsearchfr Le 25 juin 2014 à 11:00:08, Jorge von Rudno ([jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com)) a écrit: Dear colleagues, I just start to work with ES and after read the documentation, I am trying to load the data from my postgres db. To do this I found that the plugin river jdbc should be work for this purpose. After following the instruction to install the plugin, I run the following command and my expectation is to have the whole data in the index created for river: curl -XPUT '[http://localhost:9200/\_river/customers/\_meta](http://localhost:9200/_river/customers/_meta)' -d' { "type" : "jdbc", "jdbc" : { "url" : "jdbc:postgresql://192.100.10.17:5432/customers", "user" : "postgres", "password" : "", "sql" : "SELECT ba.customernumber, ba.company, ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main = 1 AND rd.status != 5", "strategy" : "oneshot" } }' After run the command I get the notification message: {"\_index":"\_river","\_type":"customers","\_id":"\_meta","\_version":1,"created":true} As I say before I was expecting to get all the data but if I make a query I just get: { "took": 1, "timed\_out": false, "\_shards": { "total": 1, "successful": 1, "failed": 0 }, "hits": { "total": 1, "max\_score": 1, "hits": [ { "\_index": "\_river", "\_type": "customers", "\_id": "\_meta", "\_score": 1, "\_source": { "type": "jdbc", "jdbc": { "url": "jdbc:postgresql://192.100.10.17:5432/kunden", "user": "postgres", "password": "", "sql": "SELECT ba.customernumber, ba.company, ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main = 1 AND rd.status != 5", "strategy": "oneshot" } } } ] } } My question is if I just omit something or I am doing something wrong. In advance thanks a lot. Regards ## Jorge von Rudno You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/etPan.53aa9091.2eb141f2.9da9%40MacBook-Air-de-David.local](https://groups.google.com/d/msgid/elasticsearch/etPan.53aa9091.2eb141f2.9da9%40MacBook-Air-de-David.local). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![Jorge\_von\_Rudno](https://avatars.discourse-cdn.com/v4/letter/j/71c47a/32.png) [@Jorge\_von\_Rudno](https://discuss.elastic.co/u/Jorge_von_Rudno)\ **Post date:** [June 25, 2014, 11:05am UTC](https://discuss.elastic.co/t/elasticsearch-river-for-postgres/18322/3 "2014-06-25T11:05:31Z")
Hi David!!, Thanks a lot for your answer. Concerning your question I just run the command: GET /\_river/\_search { "query": { "match\_all": {} } } and I get: { "took": 1, "timed\_out": false, "\_shards": { "total": 1, "successful": 1, "failed": 0 }, "hits": { "total": 1, "max\_score": 1, "hits": [ { "\_index": "\_river", "\_type": "customers", "\_id": "\_meta", "\_score": 1, "\_source": { "type": "jdbc", "jdbc": { "url": "jdbc:postgresql://192.168.20.27:5432/kunden", "user": "postgres", "password": "", "sql": SELECT ba.customernumber, ba.company, ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main = 1 AND rd.status != 5", "type": "customers", "strategy": "oneshot" } } } ] } } Anyway if I change the name of the index for example by "my\_index\_name", have the same result in the new index. In advance thanks for your interest to help me. Regards. Jorge von Rudno 2014-06-25 11:04 GMT+02:00 David Pilato [david@pilato.fr](mailto:david@pilato.fr): > How did you run your search? > By any chance did you search in \_river index? > > -- > _David Pilato_ | _Technical Advocate_ | _[Elasticsearch.com](http://Elasticsearch.com)_ > @dadoonet [https://twitter.com/dadoonet](https://twitter.com/dadoonet) | @elasticsearchfr > [https://twitter.com/elasticsearchfr](https://twitter.com/elasticsearchfr) > > Le 25 juin 2014 à 11:00:08, Jorge von Rudno ( > [jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com)) a écrit: > > Dear colleagues, > > I just start to work with ES and after read the documentation, I am trying > to load the data from my postgres db. To do this I found that the plugin > river jdbc should be work for this purpose. > After following the instruction to install the plugin, I run the following > command and my expectation is to have the whole data in the index created > for river: > > curl -XPUT '[http://localhost:9200/\_river/customers/\_meta](http://localhost:9200/_river/customers/_meta)' -d' > { > "type" : "jdbc", > "jdbc" : { > "url" : "jdbc:postgresql://192.100.10.17:5432/customers", > "user" : "postgres", > "password" : "", > "sql" : "SELECT ba.customernumber, ba.company, ba.address, > ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, > rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN > aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN > customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main > = 1 AND rd.status != 5", > "strategy" : "oneshot" > } > }' > > After run the command I get the notification message: > > {"\_index":"\_river","\_type":"customers","\_id":"\_meta","\_version":1,"created":true} > > As I say before I was expecting to get all the data but if I make a query > I just get: > > { > "took": 1, > "timed\_out": false, > "\_shards": { > "total": 1, > "successful": 1, > "failed": 0 > }, > "hits": { > "total": 1, > "max\_score": 1, > "hits": [ > { > "\_index": "\_river", > "\_type": "customers", > "\_id": "\_meta", > "\_score": 1, > "\_source": { > "type": "jdbc", > "jdbc": { > "url": "jdbc:postgresql://192.100.10.17:5432/kunden", > "user": "postgres", > "password": "", > "sql": "SELECT ba.customernumber, ba.company, > ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, > ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT > JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN > customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main > = 1 AND rd.status != 5", > "strategy": "oneshot" > } > } > } > ] > } > } > > My question is if I just omit something or I am doing something wrong. > > In advance thanks a lot. > > Regards > > ## Jorge von Rudno > > You received this message because you are subscribed to the Google Groups > "elasticsearch" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). > > To view this discussion on the web visit > [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com) > [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com?utm\_medium=email&utm\_source=footer](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com?utm_medium=email&utm_source=footer) > . > For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). > > -- > You received this message because you are subscribed to a topic in the > Google Groups "elasticsearch" group. > To unsubscribe from this topic, visit > [https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe](https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe). > To unsubscribe from this group and all its topics, send an email to > [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). > To view this discussion on the web visit > [https://groups.google.com/d/msgid/elasticsearch/etPan.53aa9091.2eb141f2.9da9%40MacBook-Air-de-David.local](https://groups.google.com/d/msgid/elasticsearch/etPan.53aa9091.2eb141f2.9da9%40MacBook-Air-de-David.local) > [https://groups.google.com/d/msgid/elasticsearch/etPan.53aa9091.2eb141f2.9da9%40MacBook-Air-de-David.local?utm\_medium=email&utm\_source=footer](https://groups.google.com/d/msgid/elasticsearch/etPan.53aa9091.2eb141f2.9da9%40MacBook-Air-de-David.local?utm_medium=email&utm_source=footer) > . > > For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DZvWmzFFxwGYQ9wWb9D%3DmgsjAGu%2BG%3DRJXd\_rAq4pKhq%2Bw%40mail.gmail.com](https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DZvWmzFFxwGYQ9wWb9D%3DmgsjAGu%2BG%3DRJXd_rAq4pKhq%2Bw%40mail.gmail.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\ **Post date:** [June 25, 2014, 12:38pm UTC](https://discuss.elastic.co/t/elasticsearch-river-for-postgres/18322/4 "2014-06-25T12:38:20Z")
You should not query the \_river index but the `customers` index I think. Just check what gives GET /\_search -- David Pilato | Technical Advocate | [Elasticsearch.com](http://Elasticsearch.com) @dadoonet | @elasticsearchfr Le 25 juin 2014 à 13:05:37, Jorge von Rudno ([jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com)) a écrit: Hi David!!, Thanks a lot for your answer. Concerning your question I just run the command: GET /\_river/\_search { "query": { "match\_all": {} } } and I get: { "took": 1, "timed\_out": false, "\_shards": { "total": 1, "successful": 1, "failed": 0 }, "hits": { "total": 1, "max\_score": 1, "hits": [ { "\_index": "\_river", "\_type": "customers", "\_id": "\_meta", "\_score": 1, "\_source": { "type": "jdbc", "jdbc": { "url": "jdbc:postgresql://192.168.20.27:5432/kunden", "user": "postgres", "password": "", "sql": SELECT ba.customernumber, ba.company, ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main = 1 AND rd.status != 5", "type": "customers", "strategy": "oneshot" } } } ] } } Anyway if I change the name of the index for example by "my\_index\_name", have the same result in the new index. In advance thanks for your interest to help me. Regards. Jorge von Rudno 2014-06-25 11:04 GMT+02:00 David Pilato [david@pilato.fr](mailto:david@pilato.fr): How did you run your search? By any chance did you search in \_river index? -- David Pilato | Technical Advocate | [Elasticsearch.com](http://Elasticsearch.com) @dadoonet | @elasticsearchfr Le 25 juin 2014 à 11:00:08, Jorge von Rudno ([jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com)) a écrit: Dear colleagues, I just start to work with ES and after read the documentation, I am trying to load the data from my postgres db. To do this I found that the plugin river jdbc should be work for this purpose. After following the instruction to install the plugin, I run the following command and my expectation is to have the whole data in the index created for river: curl -XPUT '[http://localhost:9200/\_river/customers/\_meta](http://localhost:9200/_river/customers/_meta)' -d' { "type" : "jdbc", "jdbc" : { "url" : "jdbc:postgresql://192.100.10.17:5432/customers", "user" : "postgres", "password" : "", "sql" : "SELECT ba.customernumber, ba.company, ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main = 1 AND rd.status != 5", "strategy" : "oneshot" } }' After run the command I get the notification message: {"\_index":"\_river","\_type":"customers","\_id":"\_meta","\_version":1,"created":true} As I say before I was expecting to get all the data but if I make a query I just get: { "took": 1, "timed\_out": false, "\_shards": { "total": 1, "successful": 1, "failed": 0 }, "hits": { "total": 1, "max\_score": 1, "hits": [ { "\_index": "\_river", "\_type": "customers", "\_id": "\_meta", "\_score": 1, "\_source": { "type": "jdbc", "jdbc": { "url": "jdbc:postgresql://192.100.10.17:5432/kunden", "user": "postgres", "password": "", "sql": "SELECT ba.customernumber, ba.company, ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main = 1 AND rd.status != 5", "strategy": "oneshot" } } } ] } } My question is if I just omit something or I am doing something wrong. In advance thanks a lot. Regards ## Jorge von Rudno You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). ## To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). You received this message because you are subscribed to a topic in the Google Groups "elasticsearch" group. To unsubscribe from this topic, visit [https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe](https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe). To unsubscribe from this group and all its topics, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/etPan.53aa9091.2eb141f2.9da9%40MacBook-Air-de-David.local](https://groups.google.com/d/msgid/elasticsearch/etPan.53aa9091.2eb141f2.9da9%40MacBook-Air-de-David.local). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DZvWmzFFxwGYQ9wWb9D%3DmgsjAGu%2BG%3DRJXd\_rAq4pKhq%2Bw%40mail.gmail.com](https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DZvWmzFFxwGYQ9wWb9D%3DmgsjAGu%2BG%3DRJXd_rAq4pKhq%2Bw%40mail.gmail.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/etPan.53aac2bc.41a7c4c9.9da9%40MacBook-Air-de-David.local](https://groups.google.com/d/msgid/elasticsearch/etPan.53aac2bc.41a7c4c9.9da9%40MacBook-Air-de-David.local). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![Jorge\_von\_Rudno](https://avatars.discourse-cdn.com/v4/letter/j/71c47a/32.png) [@Jorge\_von\_Rudno](https://discuss.elastic.co/u/Jorge_von_Rudno)\ **Post date:** [June 25, 2014, 1:21pm UTC](https://discuss.elastic.co/t/elasticsearch-river-for-postgres/18322/5 "2014-06-25T13:21:07Z")
Hi David, When I run I "GET /\_search", I get some documents but not what I expect (some index about ".marvel" . The river should be generate around 1 million documents. I just delete all and change the index name by "cm\_customer" PUT /cm\_customer/customers/ { "type" : "jdbc", "jdbc" : { "url" : "jdbc:postgresql://192.168.20.27:5432/kunden", "user" : "postgres", "password" : "", "sql" : "SELECT ba.kundennummer, ba.firma, ba.anschrift, ba.plz, ba.ort, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.hauptbranche, sortierung FROM basiseintrag ba LEFT JOIN rechnungsdaten rd ON ba.kundennummer = rd.kundennummer LEFT JOIN kundenbranchen AS kb ON ba.kundennummer = kb.kundennummer WHERE ba.main = 1 AND rd.status != 5", "index" : "cm\_customers", "type" : "customers", "strategy" : "oneshot" } } The first quetion is: Whit this command I get the message: "No handler found for uri [/cm\_/customers/] and method [PUT]". If I give an Id like: PUT /cm\_customer/customers/1 the mistake is gone, but think that if river generate a lot of documents, it should generate the Id automatic. The result is: { "took": 1, "timed\_out": false, "\_shards": { "total": 5, "successful": 5, "failed": 0 }, "hits": { "total": 1, "max\_score": 1, "hits": [ { "\_index": "cm\_customer", "\_type": "customers", "\_id": "1", "\_score": 1, "\_source": { "type": "jdbc", "jdbc": { "url": "jdbc:postgresql://192.168.20.27:5432/kunden", "user": "postgres", "password": "", "sql": "SELECT ba.kundennummer, ba.firma, ba.anschrift, ba.plz, ba.ort, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.hauptbranche, sortierung FROM basiseintrag ba LEFT JOIN rechnungsdaten rd ON ba.kundennummer = rd.kundennummer LEFT JOIN kundenbranchen AS kb ON ba.kundennummer = kb.kundennummer WHERE ba.main = 1 AND rd.status != 5", "index": "cm\_customers", "type": "customers", "strategy": "oneshot" } } } ] } } 2014-06-25 11:00 GMT+02:00 Jorge von Rudno \<[jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com) > : > Dear colleagues, > > I just start to work with ES and after read the documentation, I am trying > to load the data from my postgres db. To do this I found that the plugin > river jdbc should be work for this purpose. > After following the instruction to install the plugin, I run the following > command and my expectation is to have the whole data in the index created > for river: > > curl -XPUT '[http://localhost:9200/\_river/customers/\_meta](http://localhost:9200/_river/customers/_meta)' -d' > { > "type" : "jdbc", > "jdbc" : { > "url" : "jdbc:postgresql://192.100.10.17:5432/customers", > "user" : "postgres", > "password" : "", > "sql" : "SELECT ba.customernumber, ba.company, ba.address, > ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, > rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN > aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN > customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main > = 1 AND rd.status != 5", > "strategy" : "oneshot" > } > }' > > After run the command I get the notification message: > > {"\_index":"\_river","\_type":"customers","\_id":"\_meta","\_version":1,"created":true} > > As I say before I was expecting to get all the data but if I make a query > I just get: > > { > "took": 1, > "timed\_out": false, > "\_shards": { > "total": 1, > "successful": 1, > "failed": 0 > }, > "hits": { > "total": 1, > "max\_score": 1, > "hits": [ > { > "\_index": "\_river", > "\_type": "customers", > "\_id": "\_meta", > "\_score": 1, > "\_source": { > "type": "jdbc", > "jdbc": { > "url": "jdbc:postgresql://192.100.10.17:5432/kunden", > "user": "postgres", > "password": "", > "sql": "SELECT ba.customernumber, ba.company, > ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, > ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT > JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN > customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main > = 1 AND rd.status != 5", > "strategy": "oneshot" > } > } > } > ] > } > } > > My question is if I just omit something or I am doing something wrong. > > In advance thanks a lot. > > Regards > > Jorge von Rudno > > -- > You received this message because you are subscribed to a topic in the > Google Groups "elasticsearch" group. > To unsubscribe from this topic, visit > [https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe](https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe). > To unsubscribe from this group and all its topics, send an email to > [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). > To view this discussion on the web visit > [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com) > [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com?utm\_medium=email&utm\_source=footer](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com?utm_medium=email&utm_source=footer) > . > For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DYM1UHDET0QxmBOKQw%2BErBa1wu3ErCCPQEMebxzXu-iXQ%40mail.gmail.com](https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DYM1UHDET0QxmBOKQw%2BErBa1wu3ErCCPQEMebxzXu-iXQ%40mail.gmail.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\ **Post date:** [June 25, 2014, 1:54pm UTC](https://discuss.elastic.co/t/elasticsearch-river-for-postgres/18322/6 "2014-06-25T13:54:57Z")
You need to create the river in \_river special index. Otherwise it won't be considered as a river. -- David Pilato | Technical Advocate | [Elasticsearch.com](http://Elasticsearch.com) @dadoonet | @elasticsearchfr Le 25 juin 2014 à 15:21:10, Jorge von Rudno ([jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com)) a écrit: Hi David, When I run I "GET /\_search", I get some documents but not what I expect (some index about ".marvel" . The river should be generate around 1 million documents. I just delete all and change the index name by "cm\_customer" PUT /cm\_customer/customers/ { "type" : "jdbc", "jdbc" : { "url" : "jdbc:postgresql://192.168.20.27:5432/kunden", "user" : "postgres", "password" : "", "sql" : "SELECT ba.kundennummer, ba.firma, ba.anschrift, ba.plz, ba.ort, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.hauptbranche, sortierung FROM basiseintrag ba LEFT JOIN rechnungsdaten rd ON ba.kundennummer = rd.kundennummer LEFT JOIN kundenbranchen AS kb ON ba.kundennummer = kb.kundennummer WHERE ba.main = 1 AND rd.status != 5", "index" : "cm\_customers", "type" : "customers", "strategy" : "oneshot" } } The first quetion is: Whit this command I get the message: "No handler found for uri [/cm\_/customers/] and method [PUT]". If I give an Id like: PUT /cm\_customer/customers/1 the mistake is gone, but think that if river generate a lot of documents, it should generate the Id automatic. The result is: { "took": 1, "timed\_out": false, "\_shards": { "total": 5, "successful": 5, "failed": 0 }, "hits": { "total": 1, "max\_score": 1, "hits": [ { "\_index": "cm\_customer", "\_type": "customers", "\_id": "1", "\_score": 1, "\_source": { "type": "jdbc", "jdbc": { "url": "jdbc:postgresql://192.168.20.27:5432/kunden", "user": "postgres", "password": "", "sql": "SELECT ba.kundennummer, ba.firma, ba.anschrift, ba.plz, ba.ort, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.hauptbranche, sortierung FROM basiseintrag ba LEFT JOIN rechnungsdaten rd ON ba.kundennummer = rd.kundennummer LEFT JOIN kundenbranchen AS kb ON ba.kundennummer = kb.kundennummer WHERE ba.main = 1 AND rd.status != 5", "index": "cm\_customers", "type": "customers", "strategy": "oneshot" } } } ] } } 2014-06-25 11:00 GMT+02:00 Jorge von Rudno [jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com): Dear colleagues, I just start to work with ES and after read the documentation, I am trying to load the data from my postgres db. To do this I found that the plugin river jdbc should be work for this purpose. After following the instruction to install the plugin, I run the following command and my expectation is to have the whole data in the index created for river: curl -XPUT '[http://localhost:9200/\_river/customers/\_meta](http://localhost:9200/_river/customers/_meta)' -d' { "type" : "jdbc", "jdbc" : { "url" : "jdbc:postgresql://192.100.10.17:5432/customers", "user" : "postgres", "password" : "", "sql" : "SELECT ba.customernumber, ba.company, ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main = 1 AND rd.status != 5", "strategy" : "oneshot" } }' After run the command I get the notification message: {"\_index":"\_river","\_type":"customers","\_id":"\_meta","\_version":1,"created":true} As I say before I was expecting to get all the data but if I make a query I just get: { "took": 1, "timed\_out": false, "\_shards": { "total": 1, "successful": 1, "failed": 0 }, "hits": { "total": 1, "max\_score": 1, "hits": [ { "\_index": "\_river", "\_type": "customers", "\_id": "\_meta", "\_score": 1, "\_source": { "type": "jdbc", "jdbc": { "url": "jdbc:postgresql://192.100.10.17:5432/kunden", "user": "postgres", "password": "", "sql": "SELECT ba.customernumber, ba.company, ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main = 1 AND rd.status != 5", "strategy": "oneshot" } } } ] } } My question is if I just omit something or I am doing something wrong. In advance thanks a lot. Regards ## Jorge von Rudno You received this message because you are subscribed to a topic in the Google Groups "elasticsearch" group. To unsubscribe from this topic, visit [https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe](https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe). To unsubscribe from this group and all its topics, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DYM1UHDET0QxmBOKQw%2BErBa1wu3ErCCPQEMebxzXu-iXQ%40mail.gmail.com](https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DYM1UHDET0QxmBOKQw%2BErBa1wu3ErCCPQEMebxzXu-iXQ%40mail.gmail.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/etPan.53aad4b1.257130a3.9da9%40MacBook-Air-de-David.local](https://groups.google.com/d/msgid/elasticsearch/etPan.53aad4b1.257130a3.9da9%40MacBook-Air-de-David.local). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![Jorge\_von\_Rudno](https://avatars.discourse-cdn.com/v4/letter/j/71c47a/32.png) [@Jorge\_von\_Rudno](https://discuss.elastic.co/u/Jorge_von_Rudno)\ **Post date:** [June 25, 2014, 2:44pm UTC](https://discuss.elastic.co/t/elasticsearch-river-for-postgres/18322/7 "2014-06-25T14:44:58Z")
David when you say that I have to create the river in \_river special index, this mean that I have to use the word "\_river" as a Index or that I have to use the word "/\_meta" as Id or I have to do some special configuration? Sorry if the question sound a little dumm. Could you write for me an example, please? 2014-06-25 15:54 GMT+02:00 David Pilato [david@pilato.fr](mailto:david@pilato.fr): > You need to create the river in \_river special index. Otherwise it won't > be considered as a river. > > -- > _David Pilato_ | _Technical Advocate_ | _[Elasticsearch.com](http://Elasticsearch.com)_ > @dadoonet [https://twitter.com/dadoonet](https://twitter.com/dadoonet) | @elasticsearchfr > [https://twitter.com/elasticsearchfr](https://twitter.com/elasticsearchfr) > > Le 25 juin 2014 à 15:21:10, Jorge von Rudno ( > [jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com)) a écrit: > > Hi David, > > When I run I "GET /\_search", I get some documents but not what I expect > (some index about ".marvel" . The river should be generate around 1 million > documents. > > I just delete all and change the index name by "cm\_customer" > > PUT /cm\_customer/customers/ > { > "type" : "jdbc", > "jdbc" : { > "url" : "jdbc:postgresql://192.168.20.27:5432/kunden", > "user" : "postgres", > "password" : "", > "sql" : "SELECT ba.kundennummer, ba.firma, ba.anschrift, ba.plz, > ba.ort, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, > branchenid, kb.hauptbranche, sortierung FROM basiseintrag ba LEFT JOIN > rechnungsdaten rd ON ba.kundennummer = rd.kundennummer LEFT JOIN > kundenbranchen AS kb ON ba.kundennummer = kb.kundennummer WHERE ba.main = 1 > AND rd.status != 5", > "index" : "cm\_customers", > "type" : "customers", > "strategy" : "oneshot" > } > } > > The first quetion is: Whit this command I get the message: "No handler > found for uri [/cm\_/customers/] and method [PUT]". > If I give an Id like: PUT /cm\_customer/customers/1 the mistake is > gone, but think that if river generate a lot of documents, it should > generate the Id automatic. > The result is: > > { > "took": 1, > "timed\_out": false, > "\_shards": { > "total": 5, > "successful": 5, > "failed": 0 > }, > "hits": { > "total": 1, > "max\_score": 1, > "hits": [ > { > "\_index": "cm\_customer", > "\_type": "customers", > "\_id": "1", > "\_score": 1, > "\_source": { > "type": "jdbc", > "jdbc": { > "url": "jdbc:postgresql://192.168.20.27:5432/kunden", > "user": "postgres", > "password": "", > "sql": "SELECT ba.kundennummer, ba.firma, ba.anschrift, > ba.plz, ba.ort, ba.telefon, ba.telefax, ba.latitude, ba.longitude, > rd.status, branchenid, kb.hauptbranche, sortierung FROM basiseintrag ba > LEFT JOIN rechnungsdaten rd ON ba.kundennummer = rd.kundennummer LEFT JOIN > kundenbranchen AS kb ON ba.kundennummer = kb.kundennummer WHERE ba.main = 1 > AND rd.status != 5", > "index": "cm\_customers", > "type": "customers", > "strategy": "oneshot" > } > } > } > ] > } > } > > 2014-06-25 11:00 GMT+02:00 Jorge von Rudno \< > [jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com)\>: > > > Dear colleagues, > > > > I just start to work with ES and after read the documentation, I am > > trying to load the data from my postgres db. To do this I found that the > > plugin river jdbc should be work for this purpose. > > After following the instruction to install the plugin, I run the > > following command and my expectation is to have the whole data in the index > > created for river: > > > > curl -XPUT '[http://localhost:9200/\_river/customers/\_meta](http://localhost:9200/_river/customers/_meta)' -d' > > { > > "type" : "jdbc", > > "jdbc" : { > > "url" : "jdbc:postgresql://192.100.10.17:5432/customers", > > "user" : "postgres", > > "password" : "", > > "sql" : "SELECT ba.customernumber, ba.company, ba.address, > > ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, > > rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN > > aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN > > customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main > > = 1 AND rd.status != 5", > > "strategy" : "oneshot" > > } > > }' > > > > After run the command I get the notification message: > > > > {"\_index":"\_river","\_type":"customers","\_id":"\_meta","\_version":1,"created":true} > > > > As I say before I was expecting to get all the data but if I make a query > > I just get: > > > > { > > "took": 1, > > "timed\_out": false, > > "\_shards": { > > "total": 1, > > "successful": 1, > > "failed": 0 > > }, > > "hits": { > > "total": 1, > > "max\_score": 1, > > "hits": [ > > { > > "\_index": "\_river", > > "\_type": "customers", > > "\_id": "\_meta", > > "\_score": 1, > > "\_source": { > > "type": "jdbc", > > "jdbc": { > > "url": "jdbc:postgresql://192.100.10.17:5432/kunden", > > "user": "postgres", > > "password": "", > > "sql": "SELECT ba.customernumber, ba.company, > > ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, > > ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT > > JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN > > customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main > > = 1 AND rd.status != 5", > > "strategy": "oneshot" > > } > > } > > } > > ] > > } > > } > > > > My question is if I just omit something or I am doing something wrong. > > > > In advance thanks a lot. > > > > Regards > > > > ## Jorge von Rudno > > > > You received this message because you are subscribed to a topic in the > > Google Groups "elasticsearch" group. > > To unsubscribe from this topic, visit > > [https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe](https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe). > > To unsubscribe from this group and all its topics, send an email to > > [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). > > To view this discussion on the web visit > > [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com) > > [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com?utm\_medium=email&utm\_source=footer](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com?utm_medium=email&utm_source=footer) > > . > > For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). > > ``` > -- > > ``` > > You received this message because you are subscribed to the Google Groups > "elasticsearch" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). > To view this discussion on the web visit > [https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DYM1UHDET0QxmBOKQw%2BErBa1wu3ErCCPQEMebxzXu-iXQ%40mail.gmail.com](https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DYM1UHDET0QxmBOKQw%2BErBa1wu3ErCCPQEMebxzXu-iXQ%40mail.gmail.com) > [https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DYM1UHDET0QxmBOKQw%2BErBa1wu3ErCCPQEMebxzXu-iXQ%40mail.gmail.com?utm\_medium=email&utm\_source=footer](https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DYM1UHDET0QxmBOKQw%2BErBa1wu3ErCCPQEMebxzXu-iXQ%40mail.gmail.com?utm_medium=email&utm_source=footer) > . > > For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). > > -- > You received this message because you are subscribed to a topic in the > Google Groups "elasticsearch" group. > To unsubscribe from this topic, visit > [https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe](https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe). > To unsubscribe from this group and all its topics, send an email to > [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). > To view this discussion on the web visit > [https://groups.google.com/d/msgid/elasticsearch/etPan.53aad4b1.257130a3.9da9%40MacBook-Air-de-David.local](https://groups.google.com/d/msgid/elasticsearch/etPan.53aad4b1.257130a3.9da9%40MacBook-Air-de-David.local) > [https://groups.google.com/d/msgid/elasticsearch/etPan.53aad4b1.257130a3.9da9%40MacBook-Air-de-David.local?utm\_medium=email&utm\_source=footer](https://groups.google.com/d/msgid/elasticsearch/etPan.53aad4b1.257130a3.9da9%40MacBook-Air-de-David.local?utm_medium=email&utm_source=footer) > . > > For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DZv9aL\_f0Xtut5g8PpwTQActsBFei%3D4dZoG9jN%3DExqGZA%40mail.gmail.com](https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DZv9aL_f0Xtut5g8PpwTQActsBFei%3D4dZoG9jN%3DExqGZA%40mail.gmail.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\ **Post date:** [June 25, 2014, 2:50pm UTC](https://discuss.elastic.co/t/elasticsearch-river-for-postgres/18322/8 "2014-06-25T14:50:40Z")
You have to do this: curl -XPUT 'localhost:9200/\_river/my\_jdbc\_river/\_meta' -d '{ "type" : "jdbc", "jdbc" : { "url" : "jdbc:mysql://localhost:3306/test", "user" : "", "password" : "", "sql" : "select \* from orders" } }' Then if you did not set the index name you want your docs to be put in, search in default index which is I think here: the river name: my\_jdbc\_river GET /my\_jdbc\_river/\_search should give you results. If not, check your logs. May be bad driver installation??? -- David Pilato | Technical Advocate | [Elasticsearch.com](http://Elasticsearch.com) @dadoonet | @elasticsearchfr Le 25 juin 2014 à 16:45:02, Jorge von Rudno ([jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com)) a écrit: David when you say that I have to create the river in \_river special index, this mean that I have to use the word "\_river" as a Index or that I have to use the word "/\_meta" as Id or I have to do some special configuration? Sorry if the question sound a little dumm. Could you write for me an example, please? 2014-06-25 15:54 GMT+02:00 David Pilato [david@pilato.fr](mailto:david@pilato.fr): You need to create the river in \_river special index. Otherwise it won't be considered as a river. -- David Pilato | Technical Advocate | [Elasticsearch.com](http://Elasticsearch.com) @dadoonet | @elasticsearchfr Le 25 juin 2014 à 15:21:10, Jorge von Rudno ([jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com)) a écrit: Hi David, When I run I "GET /\_search", I get some documents but not what I expect (some index about ".marvel" . The river should be generate around 1 million documents. I just delete all and change the index name by "cm\_customer" PUT /cm\_customer/customers/ { "type" : "jdbc", "jdbc" : { "url" : "jdbc:postgresql://192.168.20.27:5432/kunden", "user" : "postgres", "password" : "", "sql" : "SELECT ba.kundennummer, ba.firma, ba.anschrift, ba.plz, ba.ort, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.hauptbranche, sortierung FROM basiseintrag ba LEFT JOIN rechnungsdaten rd ON ba.kundennummer = rd.kundennummer LEFT JOIN kundenbranchen AS kb ON ba.kundennummer = kb.kundennummer WHERE ba.main = 1 AND rd.status != 5", "index" : "cm\_customers", "type" : "customers", "strategy" : "oneshot" } } The first quetion is: Whit this command I get the message: "No handler found for uri [/cm\_/customers/] and method [PUT]". If I give an Id like: PUT /cm\_customer/customers/1 the mistake is gone, but think that if river generate a lot of documents, it should generate the Id automatic. The result is: { "took": 1, "timed\_out": false, "\_shards": { "total": 5, "successful": 5, "failed": 0 }, "hits": { "total": 1, "max\_score": 1, "hits": [ { "\_index": "cm\_customer", "\_type": "customers", "\_id": "1", "\_score": 1, "\_source": { "type": "jdbc", "jdbc": { "url": "jdbc:postgresql://192.168.20.27:5432/kunden", "user": "postgres", "password": "", "sql": "SELECT ba.kundennummer, ba.firma, ba.anschrift, ba.plz, ba.ort, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.hauptbranche, sortierung FROM basiseintrag ba LEFT JOIN rechnungsdaten rd ON ba.kundennummer = rd.kundennummer LEFT JOIN kundenbranchen AS kb ON ba.kundennummer = kb.kundennummer WHERE ba.main = 1 AND rd.status != 5", "index": "cm\_customers", "type": "customers", "strategy": "oneshot" } } } ] } } 2014-06-25 11:00 GMT+02:00 Jorge von Rudno [jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com): Dear colleagues, I just start to work with ES and after read the documentation, I am trying to load the data from my postgres db. To do this I found that the plugin river jdbc should be work for this purpose. After following the instruction to install the plugin, I run the following command and my expectation is to have the whole data in the index created for river: curl -XPUT '[http://localhost:9200/\_river/customers/\_meta](http://localhost:9200/_river/customers/_meta)' -d' { "type" : "jdbc", "jdbc" : { "url" : "jdbc:postgresql://192.100.10.17:5432/customers", "user" : "postgres", "password" : "", "sql" : "SELECT ba.customernumber, ba.company, ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main = 1 AND rd.status != 5", "strategy" : "oneshot" } }' After run the command I get the notification message: {"\_index":"\_river","\_type":"customers","\_id":"\_meta","\_version":1,"created":true} As I say before I was expecting to get all the data but if I make a query I just get: { "took": 1, "timed\_out": false, "\_shards": { "total": 1, "successful": 1, "failed": 0 }, "hits": { "total": 1, "max\_score": 1, "hits": [ { "\_index": "\_river", "\_type": "customers", "\_id": "\_meta", "\_score": 1, "\_source": { "type": "jdbc", "jdbc": { "url": "jdbc:postgresql://192.100.10.17:5432/kunden", "user": "postgres", "password": "", "sql": "SELECT ba.customernumber, ba.company, ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main = 1 AND rd.status != 5", "strategy": "oneshot" } } } ] } } My question is if I just omit something or I am doing something wrong. In advance thanks a lot. Regards ## Jorge von Rudno You received this message because you are subscribed to a topic in the Google Groups "elasticsearch" group. To unsubscribe from this topic, visit [https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe](https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe). To unsubscribe from this group and all its topics, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DYM1UHDET0QxmBOKQw%2BErBa1wu3ErCCPQEMebxzXu-iXQ%40mail.gmail.com](https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DYM1UHDET0QxmBOKQw%2BErBa1wu3ErCCPQEMebxzXu-iXQ%40mail.gmail.com). ## For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). You received this message because you are subscribed to a topic in the Google Groups "elasticsearch" group. To unsubscribe from this topic, visit [https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe](https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe). To unsubscribe from this group and all its topics, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/etPan.53aad4b1.257130a3.9da9%40MacBook-Air-de-David.local](https://groups.google.com/d/msgid/elasticsearch/etPan.53aad4b1.257130a3.9da9%40MacBook-Air-de-David.local). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DZv9aL\_f0Xtut5g8PpwTQActsBFei%3D4dZoG9jN%3DExqGZA%40mail.gmail.com](https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DZv9aL_f0Xtut5g8PpwTQActsBFei%3D4dZoG9jN%3DExqGZA%40mail.gmail.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/etPan.53aae1c0.4353d0cd.9da9%40MacBook-Air-de-David.local](https://groups.google.com/d/msgid/elasticsearch/etPan.53aae1c0.4353d0cd.9da9%40MacBook-Air-de-David.local). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![jprante](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/jprante/32/44941_2.png) [@jprante](https://discuss.elastic.co/u/jprante)\ **Post date:** [June 25, 2014, 4:01pm UTC](https://discuss.elastic.co/t/elasticsearch-river-for-postgres/18322/9 "2014-06-25T16:01:40Z")
You did not specify an index for the JDBC river to index to, so it assumes the index name is "jdbc". It means, if you search curl '0:9200/jdbc/\_search' you should see some of the indexed documents. Jörg On Wed, Jun 25, 2014 at 11:00 AM, Jorge von Rudno \< [jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com)\> wrote: > Dear colleagues, > > I just start to work with ES and after read the documentation, I am trying > to load the data from my postgres db. To do this I found that the plugin > river jdbc should be work for this purpose. > After following the instruction to install the plugin, I run the following > command and my expectation is to have the whole data in the index created > for river: > > curl -XPUT '[http://localhost:9200/\_river/customers/\_meta](http://localhost:9200/_river/customers/_meta)' -d' > { > "type" : "jdbc", > "jdbc" : { > "url" : "jdbc:postgresql://192.100.10.17:5432/customers", > "user" : "postgres", > "password" : "", > "sql" : "SELECT ba.customernumber, ba.company, ba.address, > ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, > rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN > aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN > customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main > = 1 AND rd.status != 5", > "strategy" : "oneshot" > } > }' > > After run the command I get the notification message: > > {"\_index":"\_river","\_type":"customers","\_id":"\_meta","\_version":1,"created":true} > > As I say before I was expecting to get all the data but if I make a query > I just get: > > { > "took": 1, > "timed\_out": false, > "\_shards": { > "total": 1, > "successful": 1, > "failed": 0 > }, > "hits": { > "total": 1, > "max\_score": 1, > "hits": [ > { > "\_index": "\_river", > "\_type": "customers", > "\_id": "\_meta", > "\_score": 1, > "\_source": { > "type": "jdbc", > "jdbc": { > "url": "jdbc:postgresql://192.100.10.17:5432/kunden", > "user": "postgres", > "password": "", > "sql": "SELECT ba.customernumber, ba.company, > ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, > ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT > JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN > customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main > = 1 AND rd.status != 5", > "strategy": "oneshot" > } > } > } > ] > } > } > > My question is if I just omit something or I am doing something wrong. > > In advance thanks a lot. > > Regards > > Jorge von Rudno > > -- > You received this message because you are subscribed to the Google Groups > "elasticsearch" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). > To view this discussion on the web visit > [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com) > [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com?utm\_medium=email&utm\_source=footer](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com?utm_medium=email&utm_source=footer) > . > For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/CAKdsXoFV\_o4eMnOjgDhs9MxHhnRYN%3D8X3XCd1h6Su7RfB7Lchg%40mail.gmail.com](https://groups.google.com/d/msgid/elasticsearch/CAKdsXoFV_o4eMnOjgDhs9MxHhnRYN%3D8X3XCd1h6Su7RfB7Lchg%40mail.gmail.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![Jorge\_von\_Rudno](https://avatars.discourse-cdn.com/v4/letter/j/71c47a/32.png) [@Jorge\_von\_Rudno](https://discuss.elastic.co/u/Jorge_von_Rudno)\ **Post date:** [June 26, 2014, 12:52pm UTC](https://discuss.elastic.co/t/elasticsearch-river-for-postgres/18322/10 "2014-06-26T12:52:22Z")
Hi David and Jörg, Many thanks for your help. Finally I can found the problem. It was in the version of the postgres driver. Kind regards!!! Jorge von Rudno 2014-06-25 18:01 GMT+02:00 [joergprante@gmail.com](mailto:joergprante@gmail.com) [joergprante@gmail.com](mailto:joergprante@gmail.com): > You did not specify an index for the JDBC river to index to, so it assumes > the index name is "jdbc". > > It means, if you search > > curl '0:9200/jdbc/\_search' > > you should see some of the indexed documents. > > Jörg > > On Wed, Jun 25, 2014 at 11:00 AM, Jorge von Rudno \< > [jorge.vonrudno.gp@googlemail.com](mailto:jorge.vonrudno.gp@googlemail.com)\> wrote: > > > Dear colleagues, > > > > I just start to work with ES and after read the documentation, I am > > trying to load the data from my postgres db. To do this I found that the > > plugin river jdbc should be work for this purpose. > > After following the instruction to install the plugin, I run the > > following command and my expectation is to have the whole data in the index > > created for river: > > > > curl -XPUT '[http://localhost:9200/\_river/customers/\_meta](http://localhost:9200/_river/customers/_meta)' -d' > > { > > "type" : "jdbc", > > "jdbc" : { > > "url" : "jdbc:postgresql://192.100.10.17:5432/customers", > > "user" : "postgres", > > "password" : "", > > "sql" : "SELECT ba.customernumber, ba.company, ba.address, > > ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, ba.longitude, > > rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT JOIN > > aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN > > customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main > > = 1 AND rd.status != 5", > > "strategy" : "oneshot" > > } > > }' > > > > After run the command I get the notification message: > > > > {"\_index":"\_river","\_type":"customers","\_id":"\_meta","\_version":1,"created":true} > > > > As I say before I was expecting to get all the data but if I make a query > > I just get: > > > > { > > "took": 1, > > "timed\_out": false, > > "\_shards": { > > "total": 1, > > "successful": 1, > > "failed": 0 > > }, > > "hits": { > > "total": 1, > > "max\_score": 1, > > "hits": [ > > { > > "\_index": "\_river", > > "\_type": "customers", > > "\_id": "\_meta", > > "\_score": 1, > > "\_source": { > > "type": "jdbc", > > "jdbc": { > > "url": "jdbc:postgresql://192.100.10.17:5432/kunden", > > "user": "postgres", > > "password": "", > > "sql": "SELECT ba.customernumber, ba.company, > > ba.address, ba.zipcode, ba.city, ba.telefon, ba.telefax, ba.latitude, > > ba.longitude, rd.status, branchenid, kb.mainbranch, sort FROM basis ba LEFT > > JOIN aditionaldata rd ON ba.customernumber = rd.customernumber LEFT JOIN > > customerbranch AS kb ON ba.customernumber = kb.customernumber WHERE ba.main > > = 1 AND rd.status != 5", > > "strategy": "oneshot" > > } > > } > > } > > ] > > } > > } > > > > My question is if I just omit something or I am doing something wrong. > > > > In advance thanks a lot. > > > > Regards > > > > Jorge von Rudno > > > > -- > > You received this message because you are subscribed to the Google Groups > > "elasticsearch" group. > > To unsubscribe from this group and stop receiving emails from it, send an > > email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). > > > > To view this discussion on the web visit > > [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com) > > [https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com?utm\_medium=email&utm\_source=footer](https://groups.google.com/d/msgid/elasticsearch/dafcf553-14fb-4ee9-b52e-380341b3ab1c%40googlegroups.com?utm_medium=email&utm_source=footer) > > . > > For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). > > -- > You received this message because you are subscribed to a topic in the > Google Groups "elasticsearch" group. > To unsubscribe from this topic, visit > [https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe](https://groups.google.com/d/topic/elasticsearch/ULC8-xaimLs/unsubscribe). > To unsubscribe from this group and all its topics, send an email to > [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). > To view this discussion on the web visit > [https://groups.google.com/d/msgid/elasticsearch/CAKdsXoFV\_o4eMnOjgDhs9MxHhnRYN%3D8X3XCd1h6Su7RfB7Lchg%40mail.gmail.com](https://groups.google.com/d/msgid/elasticsearch/CAKdsXoFV_o4eMnOjgDhs9MxHhnRYN%3D8X3XCd1h6Su7RfB7Lchg%40mail.gmail.com) > [https://groups.google.com/d/msgid/elasticsearch/CAKdsXoFV\_o4eMnOjgDhs9MxHhnRYN%3D8X3XCd1h6Su7RfB7Lchg%40mail.gmail.com?utm\_medium=email&utm\_source=footer](https://groups.google.com/d/msgid/elasticsearch/CAKdsXoFV_o4eMnOjgDhs9MxHhnRYN%3D8X3XCd1h6Su7RfB7Lchg%40mail.gmail.com?utm_medium=email&utm_source=footer) > . > > For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to [elasticsearch+unsubscribe@googlegroups.com](mailto:elasticsearch+unsubscribe@googlegroups.com). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DbSQS9pu7%3DkjaEH95%2Bz0hmmYjbHevghTkD3aS8vkjFPPQ%40mail.gmail.com](https://groups.google.com/d/msgid/elasticsearch/CAFqKu%3DbSQS9pu7%3DkjaEH95%2Bz0hmmYjbHevghTkD3aS8vkjFPPQ%40mail.gmail.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [July 6, 2017, 1:19am UTC](https://discuss.elastic.co/t/elasticsearch-river-for-postgres/18322/11 "2017-07-06T01:19:30Z")