jupyter使用Spark SQL方式读入数据库表

使用Jupyter Notebook和Spark SQL读取MySQL数据库表的步骤如下：

1. 安装并启动Jupyter Notebook。在终端中输入以下命令：

jupyter notebook

2. 在Jupyter Notebook中创建一个新的notebook。选择“New” -> “Python 3”。

3. 导入必要的Python库。例如：

from pyspark.sql import SparkSession

4. 创建一个SparkSession对象。例如：

spark = SparkSession.builder \
    .appName("Read from MySQL") \
    .master("local[*]") \
    .getOrCreate()

5. 使用SparkSession对象的read方法读取MySQL表中的数据，并将其存储为DataFrame。例如：

jdbcUrl = "jdbc:mysql://localhost:3306/mydatabase"
connectionProperties = {"user": "myusername", "password": "mypassword"}

df = spark.read.jdbc(jdbcUrl, "mytable", properties=connectionProperties)

在这个例子中，我们创建了一个JDBC连接器，指定MySQL数据库的URL，用户名和密码。然后，我们使用SparkSession的read方法来读取MySQL表中的数据，并将结果作为DataFrame返回。我们可以使用DataFrame的show方法打印结果。

注意：需要将“mydatabase”和“mytable”替换为实际的数据库名称和表名称。另外，在导入必要的Python库时，也需要安装PyMySQL库。可以使用以下命令在终端中安装：

pip install PyMySQL