input {
  jdbc {
    jdbc_driver_library => "D:1SearchEnginedataojdbc8.jar"
    jdbc_driver_class => "Java::oracle.jdbc.OracleDriver"
    jdbc_connection_string => "jdbc:oracle:thin:@localhost:1521:XE"
    jdbc_user => "demo"
    jdbc_password => "1234567"
    statement => 'select vp.id, LISTSTAGG(vp.code,",")within GROUP(order by vp.code)"CODE", LISTAGG(vbl.product_id,",")within GROUP(order by vbl.product_id)"PRODUCT_ID",LISTAGG(vbl.type,",")within GROUP(order by vbl.type)"TYPE" from product vp,PRODUCT_LINK vbl where vp.id = vbl.product_id group by id,vbl.product_id,vbl.type'
 }
}

output {
  elasticsearch {
    hosts => ["localhost:9200"]
    index => "replacement"
  }
}

[2018-06-14T16:31:56,472][WARN ][logstash.inputs.jdbc     ] Exception when executing JDBC query {:exception=>#<Sequel::DatabaseError: Java::JavaSql::SQLSyntaxErrorException: ORA-00923: FROM keyword not found where expected