package com.myapp.camel.spring;

import javax.sql.DataSource;

import org.apache.camel.CamelContext;
import org.apache.camel.RoutesBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.component.sql.SqlComponent;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.impl.SimpleRegistry;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Test;
import org.springframework.context.annotation.Bean;
import org.springframework.jdbc.datasource.DriverManagerDataSource;

import com.myapp.camel.spring.route.DBRouter;

// https://pastebin.com/JievNDw0

// logback.xml

//https://pastebin.com/FxxA4CHp


public class DBRouteTest extends CamelTestSupport {

    @Override
    public RoutesBuilder createRouteBuilder() throws Exception {
        return new DBRouter();
    }
    @Override
    public CamelContext createCamelContext() {



        SimpleRegistry registry = new SimpleRegistry();
        registry.put("dataSource",dataSource());
        registry.put("sql", sql());

        CamelContext context = new DefaultCamelContext(registry);

        return context;
    }


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


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

    @Test
    public void beanTest() throws InterruptedException{
    	 MockEndpoint mock=getMockEndpoint("mock:out");
    	 mock.expectedBodiesReceived();
        String json = "{\"orderid\":\"1\",\"ordername\":\"Order1\"}";
        String output = (String)
        		template.requestBody("direct:db",json );
        System.out.println("output : "+ output);
        assertMockEndpointsSatisfied();



    }
}