package com.daffodilwoods.demo.simple;
/*
* Replicator - class Sample application OneToOne

*/


import com.daffodilwoods.replicator.dataSources.JDBCDataSource;
import com.daffodilwoods.replicator.server.Replicator;
import com.daffodilwoods.replicator.server.datasources.RepSource;
import com.daffodilwoods.replicator.server.datasources.RepTarget;
import com.daffodilwoods.replicator.server.jobs.OneToOneJob;
import com.daffodilwoods.replicator.server.jobs._Job;
import com.daffodilwoods.replicator.server.schedule.Schedule;
import com.daffodilwoods.replicator.server.schedule._OccurrenceTypes;

/**
* This is Sample application which show The replication of one data base into
* another data base. SQL Server is taken in this sample as source data base as
* well target data base
*/
public class OneToOne {

private String SOURCE_DATABASE_SERVER_NAME = "localhost";
private String SOURCE_SERVER_PORT = "1433";
private String SOURCE_DATABASE_NAME = "Northwind";
private String SOURCE_USER_NAME = "sa";
private String SOURCE_PASSWORD = "hrhk";
private String SOURCE_DATA_SOURCE_NAME = "Northwind";
private String SOURCE_DATASOUREC_CLASSNAME = "com.microsoft.jdbcx.sqlserver.SQLServerDataSource";
private String SOURCE_REPLICATION_HOME = "C:/source";
private String SOURCE_TABLENAMES[] = { "dbo.Customers" };

// The following constants specifies data base server name OR IP Address,
// data base port no , data base name , user-name , password
// and , source name and replication home path for TARGET data source

private String TARGET_DATABASE_SERVER_NAME = "localhost";
private String TARGET_SERVER_PORT = "1433";
private String TARGET_DATABASE_NAME = "target";
private String TARGET_USER_NAME = "sa";
private String TARGET_PASSWORD = "hrhk";
private String TARGET_DATA_SOURCE_NAME = "target";
private String TARGET_DATASOUREC_CLASSNAME = "com.microsoft.jdbcx.sqlserver.SQLServerDataSource";
private String TARGET_REPLICATION_HOME = "C:/target";

// Constants to define the table names as schemaName.tableName
private String TARGET_TABLENAMES[] = { "dbo.Customers"};

// Constants to define the Job name
private String JOB_NAME = "OneToOne";

// Constants to define the Schedule name,OccurrenceType,OccurrenceInterval
private String SCHEDULE_NAME = "scheduleName";
private int OCCURRENCETYPE = _OccurrenceTypes.MINUTE;
private int OCCURRENCEINTERVAL = 2;

private SampleJBDCDataSource sampleJdbcDataSource = new SampleJBDCDataSource();

public void setSourceDataSource(Replicator repServer) {

JDBCDataSource sourceDataSource;
try {
JDBCDataSource sourceJDBCDataSource = sampleJdbcDataSource.getJDBCDataSource(SOURCE_USER_NAME,
SOURCE_PASSWORD, SOURCE_DATABASE_NAME, SOURCE_SERVER_PORT, SOURCE_DATABASE_SERVER_NAME,
SOURCE_DATA_SOURCE_NAME, SOURCE_DATASOUREC_CLASSNAME, SOURCE_REPLICATION_HOME, SOURCE_TABLENAMES);

sourceJDBCDataSource.enableExistingDataForReplication(true);
repServer.addDataSource(sourceJDBCDataSource);
System.out.println(" Data soruce one created successfully ");

} catch (Exception e) {
e.printStackTrace();
}
}

public void setTargetDataSource(Replicator repServer) {
JDBCDataSource targetDataSoruce;
try {
JDBCDataSource targetJDBCDataSoruce = sampleJdbcDataSource.getJDBCDataSource(TARGET_USER_NAME,
TARGET_PASSWORD, TARGET_DATABASE_NAME, TARGET_SERVER_PORT, TARGET_DATABASE_SERVER_NAME,
TARGET_DATA_SOURCE_NAME, TARGET_DATASOUREC_CLASSNAME, TARGET_REPLICATION_HOME, null);
repServer.addDataSource(targetJDBCDataSoruce);

/* To add Replication DataSource follow following configruation*/
//RemoteDataSource targetRemoteDataSource = new RemoteDataSource();
//targetRemoteDataSource.setReplicatorClientIPAddress("169.254.182.164");
//targetRemoteDataSource.setReplicatorClientPortNo(new Integer("5010"));
//targetRemoteDataSource.setDataSourceName("target");
//repServer.addDataSource(targetRemoteDataSource);

System.out.println(" Data soruce Two created successfully ");

} catch (Exception e) {
e.printStackTrace();
}
}

public void performReplicationJob(Replicator repServer)throws Exception {

try {
RepSource soruceDataSource = new RepSource(repServer, SOURCE_DATA_SOURCE_NAME);
RepTarget targetDataSource = new RepTarget(repServer, TARGET_DATA_SOURCE_NAME);
targetDataSource.setCreateSchema(true);
targetDataSource.populateExistingSourceData(true);


Schedule schedule = new Schedule();
schedule.setScheduleName("scheduleName");
schedule.setOccurrenceType(_OccurrenceTypes.HOUR);
schedule.setOccurrenceInterval(2);

_Job job = new OneToOneJob(soruceDataSource, targetDataSource);
job.setName(JOB_NAME);
repServer.addJob(job);
System.out.println(" Going to perform the job ");

repServer.doJob(JOB_NAME);

// if there is more than one job to be executed then use
// repServer.doJobs();

System.out.println(" Job performed successfully ");
} catch (Exception e) {
e.printStackTrace();
throw new Exception("Job Excecution faild : "+e.getMessage());

}
}

/**
* Creating replication server instance and add data sources to server
*
*/
public void replicateDataSource() {
try {
Replicator repServer = new Replicator();
repServer.setReplicationHome(SOURCE_REPLICATION_HOME);
OneToOne oneToOne = new OneToOne();
oneToOne.setSourceDataSource(repServer);
oneToOne.setTargetDataSource(repServer);
oneToOne.performReplicationJob(repServer);
} catch (Exception e) {
e.printStackTrace();
}

}

public static void main(String[] args) {
new OneToOne().replicateDataSource();
}
}