>
> 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].
To view this discussion on the web visit
https://groups.google.com/d/msgid/elasticsearch/865f9ddc-517e-4e1b-aba4-8d7e2a2eebf1%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
