/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 * 
 *   http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.    
 */
package organization;

import java.io.InputStream;
import java.util.Random;

import org.apache.tuscany.das.rdb.Command;
import org.apache.tuscany.das.rdb.DAS;
import org.apache.tuscany.sca.host.embedded.SCADomain;
import org.junit.Test;
import org.soa.types.SchemaInfoType;
import org.soa.types.TypesFactory;

import organization.services.OrganizationService;
import util.ConnectionHelper;

import commonj.sdo.DataObject;

public class OrganizationTestCase {

	private static final String id = "1";
	
	/**
	 * This represents BUG_ONE from TUSCANY-2525
	 */
	@Test
	public void testRetrieveOrganizationDAS() {
		DataObject root = null;
		InputStream in = getClass().getClassLoader().getResourceAsStream("organizationConfiguration.xml");
		
		// Need to put in valid values for your DB
        SchemaInfoType schemaInfo = TypesFactory.INSTANCE.createSchemaInfoType();
        schemaInfo.setPASSWORD("");
        schemaInfo.setSCHEMA("");
        schemaInfo.setUSERNAME("");
        
		java.sql.Connection conn = ConnectionHelper.getConnection(schemaInfo);
		
		DAS das = DAS.FACTORY.createDAS(in, conn);
		Command read = das.getCommand("getAccountByID");
		read.setParameter(1, Integer.valueOf(id));
		
		root = read.executeQuery();
		
		// This is just testing to see if the call to das.applyChanges works
		// This doesn't work
		
		Random generator = new Random();
		String accountName = "ACCOUNT_" + Integer.toString(generator.nextInt());
		
		DataObject account = root.getDataObject("ACCOUNT[1]");
		account.set("ACCOUNT_NAME", accountName);
		System.out.println("findOrganization data graph -> " + root.getDataGraph());
        System.out.println("findOrganization data graph root -> " + root.getDataGraph().getRootObject());
		
        das.applyChanges(root);
        
        root = read.executeQuery();
        
        DataObject updatedAccount =  root.getDataObject("ACCOUNT[1]");
        org.junit.Assert.assertEquals(accountName, updatedAccount.get("ACCOUNT_NAME"));
       	
	}
	
		
	@Test
	public void testRetrieveOrganizationSCA() {
		
		System.out.println("\n1. Organization-Service-Composite OrganizationClientRunner ");

        SCADomain scaDomain = SCADomain.newInstance("organization.composite");
        
        OrganizationService organizationService = 
        	scaDomain.getService(OrganizationService.class, "OrganizationServiceComponent");

        //  Need to put in valid values for your DB
        SchemaInfoType schemaInfo = TypesFactory.INSTANCE.createSchemaInfoType();
        schemaInfo.setPASSWORD("");
        schemaInfo.setSCHEMA("");
        schemaInfo.setUSERNAME("");
        
        // This doesn't work.  Just retreive account, make a change, then apply changes
        DataObject root = organizationService.findOrganizationBugOne(id, schemaInfo);
        DataObject account = root.getDataObject("ACCOUNT[1]");
        
        org.junit.Assert.assertEquals("TestNode2", account.get("ACCOUNT_NAME"));
        
        
        // This doesn't work either.  The root datagraph is null
        // If you call das.applyChanges for a dataObject that has null as the dataGraph,
        // it hurls.
        //commonj.sdo.DataObject rootOne = organizationService.findOrganizationBugTwo(id, schemaInfo);
        //System.out.println("rootOne dataGraph -> " + rootOne.getDataGraph());
        //organizationService.updateOrganization(rootOne, schemaInfo);
        
        scaDomain.close();
	}
}