package com.myapp.camel.spring.route;

import java.sql.SQLException;

import javax.sql.DataSource;

import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.sql.SqlComponent;
import org.json.simple.JSONObject;
import org.json.simple.parser.JSONParser;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import org.springframework.stereotype.Component;



@Component
public class DBRouter extends RouteBuilder {

	@Autowired
	private DataSource dataSource;

	@Bean
	public DataSource dataSource() {
	DriverManagerDataSource dataSource=new DriverManagerDataSource();
		dataSource.setUrl("jdbc:mysql://localhost:3306/hcl");
		dataSource.setUsername("admin");
		dataSource.setPassword("admin");
	return dataSource;
	}

	@Bean
	public SqlComponent sql() {
		SqlComponent sqlComponent=new SqlComponent();
		sqlComponent.setDataSource(dataSource);
		return sqlComponent;
	}

	@Override
	public void configure() throws Exception {
		// TODO Auto-generated method stub
onException(SQLException.class).handled(true)
.log("Exception While Inserting");

from("direct:db")
.to("log:?level=INFO&showBody=true")
		.process((Exchange exchange)->{
		String body=(String)	exchange.getIn().getBody();
		JSONParser parser=new JSONParser();
		JSONObject jsonObject=(JSONObject)parser.parse(body);
	Integer orderid=	Integer.parseInt((String)jsonObject.get("orderid"));
	String orderName=(String)jsonObject.get("ordername");
	String insertQuery="insert INTO orders values(".concat("'").concat(String.valueOf(orderid).concat("'").concat(",").concat("'")
			.concat(orderName).concat("'").concat(")"));


		exchange.getIn().setBody(insertQuery);

			}).to("jdbc:dataSource")
		.to("sql:select * from orders")
		.to("log:?level=INFO&showBody=true")
		.to("mock:out");

	}

}