Python连接MySQL|极客教程

Python连接MySQL

MySQL是一种常用的关系数据库管理系统。在Python中使用MySQL数据库，可以使用第三方库pymysql或mysql-connector-python。本文将详细介绍如何在Python中连接MySQL数据库并进行数据操作。

安装第三方库

在使用之前，需要安装pymysql或mysql-connector-python库。可以使用pip进行安装：

pip install pymysql

或

pip install mysql-connector-python

连接MySQL数据库

使用pymysql库连接MySQL数据库

import pymysql

# 连接MySQL数据库
conn = pymysql.connect(
    host='localhost',
    user='root',
    password='password',
    database='mydatabase'
)

# 创建游标对象
cursor = conn.cursor()

# 执行SQL语句
cursor.execute("SELECT * FROM mytable")

# 获取查询结果
results = cursor.fetchall()

# 输出结果
for row in results:
    print(row)

# 关闭游标和连接
cursor.close()
conn.close()

使用mysql-connector-python库连接MySQL数据库

import mysql.connector

# 连接MySQL数据库
conn = mysql.connector.connect(
    host='localhost',
    user='root',
    password='password',
    database='mydatabase'
)

# 创建游标对象
cursor = conn.cursor()

# 执行SQL语句
cursor.execute("SELECT * FROM mytable")

# 获取查询结果
results = cursor.fetchall()

# 输出结果
for row in results:
    print(row)

# 关闭游标和连接
cursor.close()
conn.close()

以上代码示例演示了如何连接MySQL数据库并查询数据。在实际项目中，需要根据具体情况修改连接参数和SQL语句。

数据操作

插入数据

import pymysql

# 连接MySQL数据库
conn = pymysql.connect(
    host='localhost',
    user='root',
    password='password',
    database='mydatabase'
)

# 创建游标对象
cursor = conn.cursor()

# 插入数据
sql = "INSERT INTO mytable (name, age) VALUES ('Alice', 25)"
cursor.execute(sql)

# 提交事务
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()

更新数据

import mysql.connector

# 连接MySQL数据库
conn = mysql.connector.connect(
    host='localhost',
    user='root',
    password='password',
    database='mydatabase'
)

# 创建游标对象
cursor = conn.cursor()

# 更新数据
sql = "UPDATE mytable SET age = 26 WHERE name = 'Alice'"
cursor.execute(sql)

# 提交事务
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()

删除数据

import pymysql

# 连接MySQL数据库
conn = pymysql.connect(
    host='localhost',
    user='root',
    password='password',
    database='mydatabase'
)

# 创建游标对象
cursor = conn.cursor()

# 删除数据
sql = "DELETE FROM mytable WHERE name = 'Alice'"
cursor.execute(sql)

# 提交事务
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()

以上示例演示了如何插入、更新和删除数据。在实际项目中，应根据需求编写相应的SQL语句。

异常处理

在连接MySQL数据库时，可能会出现各种异常，如连接失败、SQL语句错误等。为了保证程序的稳定性，应添加适当的异常处理代码。

import pymysql

try:
    # 连接MySQL数据库
    conn = pymysql.connect(
        host='localhost',
        user='root',
        password='password',
        database='mydatabase'
    )

    # 创建游标对象
    cursor = conn.cursor()

    # 执行SQL语句
    cursor.execute("SELECT * FROM mytable")

    # 获取查询结果
    results = cursor.fetchall()

    # 输出结果
    for row in results:
        print(row)

except Exception as e:
    print("Error:", e)

finally:
    # 关闭游标和连接
    cursor.close()
    conn.close()

以上代码示例中，在连接数据库和执行SQL语句时都添加了异常处理代码，确保程序在出现异常情况下能正常处理。