hadoop怎么进入mysql

Hadoop是一个分布式计算框架，而MySQL是一个关系型数据库管理系统，它们之间并没有直接的联系。但是，如果你要使用Hadoop来处理大数据，可能需要将数据存储在MySQL中，或者从MySQL中读取数据进行处理。这里提供两种方法：

1. 使用Hadoop的Sqoop工具来将数据从MySQL导入到Hadoop中进行处理。

Sqoop是一个用于在Hadoop和关系型数据库之间传输数据的工具。你可以使用Sqoop将MySQL中的数据导入到Hadoop的HDFS文件系统中，然后使用Hadoop进行数据分析和处理。下面是使用Sqoop导入MySQL数据到Hadoop的命令：

sqoop import --connect jdbc:mysql://mysql_host:port/database_name \
--username mysql_user --password mysql_password \
--table table_name \
--target-dir /hdfs/path/to/store/data

其中，`mysql_host`是MySQL服务器的主机名或IP地址，`port`是MySQL服务器监听的端口号，`database_name`是要导入的数据库名称，`mysql_user`和`mysql_password`是连接MySQL需要用到的用户名和密码，`table_name`是要导入的表名，`/hdfs/path/to/store/data`是HDFS中存储数据的路径。

2. 使用Hadoop的MapReduce程序来读取MySQL中的数据进行处理。

如果你已经将数据存储在MySQL中，并且想要使用Hadoop进行数据处理，可以编写一个MapReduce程序来读取MySQL中的数据。你需要使用Java编写MapReduce程序，并使用JDBC连接MySQL数据库。下面是一个简单的示例代码，可以读取MySQL中的数据并输出到控制台：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;

public class ReadFromMySQL {

  public static class MyMapper extends Mapper<Object, Text, Text, IntWritable> {
    private final static IntWritable one = new IntWritable(1);
    private Text word = new Text();

    public void map(Object key, Text value, Context context) throws IOException, InterruptedException {
      // JDBC连接MySQL数据库
      String url = "jdbc:mysql://mysql_host:port/database_name";
      String user = "mysql_user";
      String password = "mysql_password";
      Connection conn = DriverManager.getConnection(url, user, password);

      Statement stmt = conn.createStatement();
      ResultSet rs = stmt.executeQuery("SELECT * FROM table_name");

      // 逐行读取数据并输出到控制台
      while (rs.next()) {
        word.set(rs.getString("column_name"));
        context.write(word, one);
      }

      rs.close();
      stmt.close();
      conn.close();
    }
  }

  public static void main(String[] args) throws Exception {
    Configuration conf = new Configuration();
    Job job = Job.getInstance(conf, "read from mysql");
    job.setJarByClass(ReadFromMySQL.class);
    job.setMapperClass(MyMapper.class);
    job.setOutputKeyClass(Text.class);
    job.setOutputValueClass(IntWritable.class);
    FileOutputFormat.setOutputPath(job, new Path(args[0]));
    System.exit(job.waitForCompletion(true) ? 0 : 1);
  }
}

其中，`mysql_host`是MySQL服务器的主机名或IP地址，`port`是MySQL服务器监听的端口号，`database_name`是要读取的数据库名称，`mysql_user`和`mysql_password`是连接MySQL需要用到的用户名和密码，`table_name`是要读取的表名。你需要将上面的代码保存为一个Java文件，并使用Hadoop的`hadoop jar`命令来运行MapReduce程序。