如何在缺少pymysql模块的情况下使用Python脚本访问MySQL数据库以存储Spark作业结果？

要在Python中访问MySQL数据库，可以使用pymysql模块。首先需要安装pymysql模块，可以使用以下命令进行安装：，，“bash，pip install pymysql，`

，，然后在Python脚本中导入pymysql模块，并使用它来连接到MySQL数据库。以下是一个简单的示例：，，

python，import pymysql，，# 连接到MySQL数据库，connection = pymysql.connect(host='localhost',，                             user='your_username',，                             password='your_password',，                             db='your_database')，，try:，    # 创建一个游标对象，    cursor = connection.cursor()，，    # 执行SQL查询，    cursor.execute('SELECT * FROM your_table')，，    # 获取查询结果，    result = cursor.fetchall()，，    # 打印查询结果，    for row in result:，        print(row)，，finally:，    # 关闭游标和连接，    cursor.close()，    connection.close()，

“

在Python中，我们可以使用pymysql模块来访问MySQL数据库，如果缺少pymysql模块，我们还有其他的选择，mysqlconnectorpython，这是一个由MySQL官方提供的纯Python驱动。

以下是如何在Python中使用mysqlconnectorpython访问MySQL数据库的步骤：

1、安装mysqlconnectorpython：你可以使用pip来安装这个模块，命令如下：

pip install mysqlconnectorpython

2、连接到MySQL数据库：使用mysql.connector.connect()函数，你需要提供数据库的主机名、用户名、密码和数据库名。

import mysql.connector
cnx = mysql.connector.connect(user='username', password='password',
                              host='127.0.0.1',
                              database='database_name')
cnx.close()

3、创建游标对象：使用conn.cursor()方法创建一个游标对象，然后使用游标对象的execute()方法执行SQL查询。

import mysql.connector
cnx = mysql.connector.connect(user='username', password='password',
                              host='127.0.0.1',
                              database='database_name')
cursor = cnx.cursor()
query = ("SELECT * FROM table_name")
cursor.execute(query)
for (column1, column2) in cursor:
  print("{} got {}".format(column1, column2))
cursor.close()
cnx.close()

4、获取和处理结果：使用游标对象的fetchall()或fetchone()方法获取查询结果，然后进行处理。

import mysql.connector
cnx = mysql.connector.connect(user='username', password='password',
                              host='127.0.0.1',
                              database='database_name')
cursor = cnx.cursor()
query = ("SELECT * FROM table_name")
cursor.execute(query)
for (column1, column2) in cursor:
  print("{} got {}".format(column1, column2))
cursor.close()
cnx.close()

5、提交事务：如果你执行的是INSERT、UPDATE或DELETE等改变数据库状态的操作，需要使用conn.commit()方法提交事务。

import mysql.connector
cnx = mysql.connector.connect(user='username', password='password',
                              host='127.0.0.1',
                              database='database_name')
cursor = cnx.cursor()
add_employee = ("INSERT INTO employees "
               "(first_name, last_name, hire_date, gender, birth_date) "
               "VALUES (%s, %s, %s, %s, %s)")
data_employee = ('John', 'Doe', '20060101', 'M', '19770630')
cursor.execute(add_employee, data_employee)
emp_no = cursor.lastrowid
cnx.commit()
print("Employee {} added.".format(emp_no))
cursor.close()
cnx.close()

6、错误处理：使用try…except…finally结构进行错误处理和资源清理。

import mysql.connector
from mysql.connector import Error
try:
    connection = mysql.connector.connect(host='localhost',
                                         database='python_db',
                                         user='pynative',
                                         password='pynative@#285')
    if connection.is_connected():
        db_Info = connection.get_server_info()
        print("Connected to MySQL Server version ", db_Info)
        cursor = connection.cursor()
        cursor.execute("select database();")
        record = cursor.fetchone()
        print("You're connected to database: ", record)
except Error as e:
    print("Error while connecting to MySQL", e)
finally:
    if (connection.is_connected()):
        cursor.close()
        connection.close()
        print("MySQL connection is closed")

注意：在执行完数据库操作后，一定要记得关闭游标和连接，以释放资源。