package com.intel.richard;

import org.apache.sqoop.client.SqoopClient;
import org.apache.sqoop.model.MConnection;
import org.apache.sqoop.model.MConnectionForms;
import org.apache.sqoop.validation.Status;

public class App{
  public static void main(String[] args){
    String url = "http://localhost:12000/sqoop/";
    SqoopClient client = new SqoopClient(url);
    client.setServerUrl(url);
    MConnection newCon = client.newConnection(1);

    MConnectionForms conForms = newCon.getConnectorPart();
    MConnectionForms frameworkForms = newCon.getFrameworkPart();
    newCon.setName("MyConnection");
    conForms.getStringInput("connection.connectionString").setValue("jdbc:mysql://localhost/sqoop_test");
    conForms.getStringInput("connection.jdbcDriver").setValue("com.mysql.jdbc.Driver");
    conForms.getStringInput("connection.username").setValue("root");
    conForms.getStringInput("connection.password").setValue("root");
    frameworkForms.getIntegerInput("security.maxConnections").setValue(0);
    Status status  = client.createConnection(newCon);
    if(status.canProceed()) {
      System.out.println("Created. New Connection ID : " +newCon.getPersistenceId());
    } else {
      System.out.println("Check for status and forms error ");
    }
  }
}