Python 中的 MySQL-Connector-Python 模块

MySQL-Connector-Python 是一个用于在Python中连接和操作MySQL数据库的模块。它提供了一种简单且高效的方法来与MySQL数据库进行交互。本文将为程序员介绍 MySQL-Connector-Python 模块的基本用法以及一些常见的示例。

安装

可以使用 pip 命令来安装 MySQL-Connector-Python 模块：

pip install mysql-connector-python

确保在安装之前已经安装了 Python，并且具有 pip 包管理工具。

连接到数据库

要连接到MySQL数据库，首先需要导入 mysql.connector 模块，并使用 connect() 函数来建立与数据库的连接。下面是连接到数据库的示例代码：

import mysql.connector

# 创建数据库连接
cnx = mysql.connector.connect(user='username', password='password',
                              host='hostname',
                              database='database_name')

# 关闭数据库连接
cnx.close()

执行SQL查询

一旦与数据库建立了连接，就可以通过创建游标对象并使用 execute() 方法来执行SQL查询。下面是一个简单的示例，演示如何执行SQL查询并获取结果：

import mysql.connector

# 创建数据库连接
cnx = mysql.connector.connect(user='username', password='password',
                              host='hostname',
                              database='database_name')

# 创建游标
cursor = cnx.cursor()

# 执行SQL查询
query = "SELECT * FROM table_name"
cursor.execute(query)

# 获取结果
result = cursor.fetchall()

# 打印结果
for row in result:
    print(row)

# 关闭游标和数据库连接
cursor.close()
cnx.close()

执行SQL语句

MySQL-Connector-Python 还允许执行除查询语句之外的SQL语句，如插入、更新和删除数据。下面是一个示例，演示如何执行插入语句并获取受影响的行数：

import mysql.connector

# 创建数据库连接
cnx = mysql.connector.connect(user='username', password='password',
                              host='hostname',
                              database='database_name')

# 创建游标
cursor = cnx.cursor()

# 执行插入语句
insert_query = "INSERT INTO table_name (column1, column2) VALUES (%s, %s)"
data = ('value1', 'value2')
cursor.execute(insert_query, data)

# 获取受影响的行数
row_count = cursor.rowcount
print(f"插入了 {row_count} 行数据。")

# 提交事务
cnx.commit()

# 关闭游标和数据库连接
cursor.close()
cnx.close()

处理异常

在使用 MySQL-Connector-Python 进行数据库操作时，可能会出现各种异常错误。为了更好地处理这些异常，可以使用 try/except 块来捕获并处理它们。下面是一个简单的异常处理示例：

import mysql.connector

try:
    # 创建数据库连接
    cnx = mysql.connector.connect(user='username', password='password',
                                  host='hostname',
                                  database='database_name')

    # 创建游标
    cursor = cnx.cursor()

    # 执行SQL查询
    query = "SELECT * FROM table_name"
    cursor.execute(query)

    # 获取结果
    result = cursor.fetchall()

    # 打印结果
    for row in result:
        print(row)

except mysql.connector.Error as err:
    print(f"发生错误：{err}")

finally:
    # 关闭游标和数据库连接
    cursor.close()
    cnx.close()

总结

MySQL-Connector-Python 是一个功能强大且易于使用的模块，可帮助程序员在Python中连接和操作MySQL数据库。本文介绍了它的基本用法，包括连接到数据库、执行SQL查询和语句、处理异常等。希望这些示例能够帮助你更好地使用 MySQL-Connector-Python 进行数据库操作。