Mysql
 sql >> база данни >  >> RDS >> Mysql

Java - MySQL в Hive Import, където MySQL работи на Windows и Hive работи на Cent OS (Horton Sandbox)

Да, можете да го направите чрез ssh. Horton Sandbox се предлага с предварително инсталирана ssh поддръжка. Можете да изпълните командата sqoop чрез ssh клиент на Windows. Или ако искате да го направите програмно (това съм направил в java), трябва да следвате тази стъпка.

  1. Изтеглете sshxcute java библиотека:https://code.google.com/p/sshxcute/
  2. Добавете към пътя за изграждане на вашия java проект, който съдържа следния java код
import net.neoremind.sshxcute.core.SSHExec;
import net.neoremind.sshxcute.core.ConnBean;
import net.neoremind.sshxcute.task.CustomTask;
import net.neoremind.sshxcute.task.impl.ExecCommand;

public class TestSSH {

public static void main(String args[]) throws Exception{

    // Initialize a ConnBean object, parameter list is ip, username, password

    ConnBean cb = new ConnBean("192.168.56.102", "root","hadoop");

    // Put the ConnBean instance as parameter for SSHExec static method getInstance(ConnBean) to retrieve a singleton SSHExec instance
    SSHExec ssh = SSHExec.getInstance(cb);          
    // Connect to server
    ssh.connect();
    CustomTask sampleTask1 = new ExecCommand("echo $SSH_CLIENT"); // Print Your Client IP By which you connected to ssh server on Horton Sandbox
    System.out.println(ssh.exec(sampleTask1));
    CustomTask sampleTask2 = new ExecCommand("sqoop import --connect jdbc:mysql://192.168.56.101:3316/mysql_db_name --username=mysql_user --password=mysql_pwd --table mysql_table_name --hive-import -m 1 -- --schema default");
    ssh.exec(sampleTask2);
    ssh.disconnect();   
}
}



  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. pip инсталирайте mysqlclient на amazon linux

  2. Как да заредя sql.gz файл в моята база данни? (импортиране)

  3. Съобщение за грешка в синтаксиса на MySQL Операнд трябва да съдържа 1 колона(и)

  4. PHP Предупреждение:Стартиране на PHP:Не може да се зареди динамична библиотека '/usr/lib/php/20151012/msqli.so'

  5. Инициализацията на PHP PDO е неуспешна поради двоен порт - Uncaught PDOException:SQLSTATE[HY000] [2002]