Hi Jörg I have problems when I use that, I didn't insert the data, I create the river but I can get the data in ES.
El miércoles, 7 de enero de 2015 12:05:47 UTC-4:30, Jörg Prante escribió: > > You can use the JDBC plugin instead of reinventing the wheel. > > https://github.com/jprante/elasticsearch-river-jdbc > > Jörg > > On Wed, Jan 7, 2015 at 5:28 PM, Marian Valero <[email protected] > <javascript:>> wrote: > >> Thanks! >>> >> >> I have a problem with jsonBuilder() method, eclipse don't found this, I >> do it that way: >> >> public static void main(String args[]) throws SQLException { >> >> int count=0; >> Node node = nodeBuilder().client(true).node(); >> Client client = node.client(); >> >> String url = "jdbc:oracle:thin:@eso:1521:eso"; >> >> Properties props = new Properties(); >> props.setProperty("user", "eso"); >> props.setProperty("password", "eso"); >> >> Connection conn = DriverManager.getConnection(url,props); >> >> String sql ="select * from responselog"; >> >> PreparedStatement preStatement = conn.prepareStatement(sql); >> >> ResultSet result = preStatement.executeQuery(); >> >> // Timestamp timestamp = null; >> >> BulkRequestBuilder bulkRequest = client.prepareBulk(); >> >> while(result.next() && count<1000){ >> count++; >> String id = result.getString("id"); >> String deliveryid = result.getString("deliveryid"); >> String msgid = result.getString("msgid"); >> String rspdate = result.getString("rspdate"); >> String parsedresponse = result.getString("parsedresponse"); >> String shortcode = result.getString("shortcode"); >> String insid = result.getString("insid"); >> String mobilenumber = result.getString("mobilenumber"); >> String rawresponse = result.getString("rawresponse"); >> >> XContentBuilder builder = jsonBuilder() >> .startObject() >> .field("deliveryid", deliveryid) >> .field("msgid", msgid) >> .field("message", "trying out Elasticsearch") >> .endObject(); >> >> >> // YOUR ORACLE stuff here >> // either use client#prepare, or use Requests# to directly build >> index/delete requests >> bulkRequest.add(client.prepareIndex("logs", "responselog", id) >> .setSource(jsonBuilder() >> .startObject() >> .field("deliveryid", deliveryid) >> .field("msgid", msgid) >> .field("rspdate", rspdate) >> .field("parsedresponse", parsedresponse) >> .field("shortcode", shortcode) >> .field("insid", insid) >> .field("mobilenumber", mobilenumber) >> .field("rawresponse", rawresponse) >> .endObject() >> ) >> ); >> >> System.out.println("Responselog from Oracle : "+ >> result.getString("id")+" "+result.getString("deliveryid")+" >> "+result.getString("msgid")+" "+result.getString("rspdate")+" >> "+result.getString("parsedresponse")+" "+result.getString("shortcode")+" >> "+result.getString("insid")+" "+result.getString("mobilenumber")+" >> "+result.getString("rawresponse")); >> } >> >> BulkResponse bulkResponse = bulkRequest.execute().actionGet(); >> System.out.println("done"); >> } >> >> -- >> 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 [email protected] <javascript:>. >> To view this discussion on the web visit >> https://groups.google.com/d/msgid/elasticsearch/865f9ddc-517e-4e1b-aba4-8d7e2a2eebf1%40googlegroups.com >> >> <https://groups.google.com/d/msgid/elasticsearch/865f9ddc-517e-4e1b-aba4-8d7e2a2eebf1%40googlegroups.com?utm_medium=email&utm_source=footer> >> . >> >> For more options, visit 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 [email protected]. To view this discussion on the web visit https://groups.google.com/d/msgid/elasticsearch/d90b58c2-fb33-4dc3-b630-183c12e0566c%40googlegroups.com. For more options, visit https://groups.google.com/d/optout.
