python 如何连mysql数据库_将Spark作业结果存储在MySQL数据库中，缺少pymysql模块，如何使用python脚本访问MySQL数据库？

要使用Python脚本访问MySQL数据库，首先需要安装pymysql模块，可以使用以下命令安装：

pip install pymysql

接下来，我们将分步骤介绍如何使用Python脚本连接到MySQL数据库并执行查询。

1. 导入所需模块

在Python脚本中，我们需要导入pymysql模块以连接到MySQL数据库。

import pymysql

2. 创建数据库连接

使用pymysql.connect()函数创建一个数据库连接，需要提供以下参数：

host：数据库服务器的地址（’localhost’）

user：用于连接数据库的用户名

password：用户的密码

database：要连接的数据库名称

connection = pymysql.connect(
    host='localhost',
    user='your_username',
    password='your_password',
    database='your_database'
)

3. 创建游标对象

使用connection.cursor()方法创建一个游标对象，用于执行SQL查询和获取结果。

cursor = connection.cursor()

4. 执行SQL查询

使用游标对象的execute()方法执行SQL查询，要查询名为your_table的表中的所有数据，可以使用以下代码：

sql = "SELECT * FROM your_table"
cursor.execute(sql)

5. 获取查询结果

使用游标对象的fetchall()方法获取查询结果，这将返回一个包含所有行的列表，每行表示为一个元组。

results = cursor.fetchall()

6. 处理查询结果

现在可以处理查询结果，例如将其打印到控制台或将其存储在变量中。

for row in results:
    print(row)

7. 关闭游标和连接

完成查询后，记得关闭游标和数据库连接。

cursor.close()
connection.close()

将以上代码片段组合在一起，完整的Python脚本如下：

import pymysql
创建数据库连接
connection = pymysql.connect(
    host='localhost',
    user='your_username',
    password='your_password',
    database='your_database'
)
创建游标对象
cursor = connection.cursor()
执行SQL查询
sql = "SELECT * FROM your_table"
cursor.execute(sql)
获取查询结果
results = cursor.fetchall()
处理查询结果
for row in results:
    print(row)
关闭游标和连接
cursor.close()
connection.close()