Spark使用Java读取Mysql

在Apache Spark中，您可以使用DataFrameReader接口来读取MySQL数据库中的数据。以下是使用Java读取MySQL数据的步骤和示例代码：

1. 添加MySQL JDBC驱动程序依赖到项目中。如果您使用的是sbt，可以添加以下依赖：

   
   
   
   libraryDependencies += "mysql" % "mysql-connector-java" % "版本号"

2. 在Spark中创建一个DataFrameReader实例。
3. 使用jdbc方法指定MySQL数据源，并提供连接参数。
4. 设置查询参数来读取数据。

以下是使用Java读取MySQL数据的示例代码：

import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;
 
public class ReadMySQL {
    public static void main(String[] args) {
        SparkSession spark = SparkSession.builder()
                .appName("ReadMySQLExample")
                .master("local")
                .getOrCreate();
 
        // 指定JDBC URL，以及数据库驱动类名
        String jdbcUrl = "jdbc:mysql://hostname:port/database";
        String dbTable = "table_name";
        String connectionString = "com.mysql.jdbc.Driver";
        String user = "username";
        String password = "password";
 
        // 读取MySQL数据
        Dataset<Row> df = spark.read()
                .format("jdbc")
                .option("url", jdbcUrl)
                .option("dbtable", dbTable)
                .option("user", user)
                .option("password", password)
                .option("driver", connectionString)
                .load();
 
        // 显示读取的数据
        df.show();
 
        spark.stop();
    }
}

确保替换hostname:port/database, table_name, username, 和 password 为您的MySQL服务器和数据库的实际信息。您也需要更改connectionString以匹配您使用的MySQL JDBC驱动程序的版本。