Python中的MySQL数据库连接|极客笔记

Python中的MySQL数据库连接

在Python开发中，经常会涉及到与MySQL数据库进行交互，比如查询数据、插入数据等操作。为了实现这些操作，我们需要使用到Python中的MySQL连接库。本文将详细介绍在Python中如何连接MySQL数据库，并进行一些基本的操作。

安装MySQL连接库

在Python中，有多个第三方库可以用于连接MySQL数据库，比较常用的有pymysql、mysql-connector-python等。接下来我们以mysql-connector-python为例，来演示如何安装并使用MySQL连接库。

首先，我们需要使用pip来安装mysql-connector-python库，命令如下：

pip install mysql-connector-python

安装完成后，我们就可以在Python脚本中使用这个库来连接MySQL数据库了。

连接MySQL数据库

在使用mysql-connector-python库连接MySQL数据库之前，我们需要先准备好数据库的连接信息，比如数据库的主机地址、端口号、用户名、密码以及要连接的数据库名。接下来我们会通过以下代码来连接MySQL数据库：

import mysql.connector

# 数据库连接信息
host = 'localhost'
user = 'root'
password = 'your_password'
database = 'your_database'

# 建立数据库连接
conn = mysql.connector.connect(host=host, user=user, password=password, database=database)

# 获取游标
cursor = conn.cursor()

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

在以上代码中，我们首先导入mysql.connector库，然后指定了数据库的连接信息，包括主机地址、用户名、密码和数据库名。接着，我们调用mysql.connector.connect()函数来建立数据库连接，返回一个Connection对象，然后调用conn.cursor()方法获取一个游标对象，用于执行SQL查询或操作。

执行SQL查询

连接上数据库之后，我们就可以执行各种SQL查询语句了。下面是一个简单的示例，演示如何查询数据库中的数据：

import mysql.connector

# 数据库连接信息
host = 'localhost'
user = 'root'
password = 'your_password'
database = 'your_database'

# 建立数据库连接
conn = mysql.connector.connect(host=host, user=user, password=password, database=database)

# 获取游标
cursor = conn.cursor()

# 执行查询
sql = 'SELECT * FROM your_table'
cursor.execute(sql)

# 获取查询结果
result = cursor.fetchall()
for row in result:
    print(row)

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

在以上代码中，我们首先建立数据库连接，然后执行了一条查询语句SELECT * FROM your_table，将查询结果保存在变量result中，并对其进行遍历输出。

执行SQL操作

除了查询数据外，我们还可以执行插入、更新、删除等操作。下面是一个示例代码，演示如何向数据库中插入数据：

import mysql.connector

# 数据库连接信息
host = 'localhost'
user = 'root'
password = 'your_password'
database = 'your_database'

# 建立数据库连接
conn = mysql.connector.connect(host=host, user=user, password=password, database=database)

# 获取游标
cursor = conn.cursor()

# 执行插入操作
sql = 'INSERT INTO your_table (column1, column2) VALUES (%s, %s)'
values = ('value1', 'value2')
cursor.execute(sql, values)

# 提交操作
conn.commit()

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

在以上代码中，我们执行了一条插入数据的操作，将数据插入到表your_table中，其中%s表示占位符，通过元组values传入要插入的值。

异常处理

在实际开发中，可能会遇到各种错误，比如数据库连接失败、执行SQL查询错误等。为了保证程序的稳定性，我们需要做好异常处理。下面是一个示例代码：

import mysql.connector

try:
    # 数据库连接信息
    host = 'localhost'
    user = 'root'
    password = 'your_password'
    database = 'your_database'

    # 建立数据库连接
    conn = mysql.connector.connect(host=host, user=user, password=password, database=database)

    # 获取游标
    cursor = conn.cursor()

    # 执行查询
    sql = 'SELECT * FROM your_table'
    cursor.execute(sql)

    # 获取查询结果
    result = cursor.fetchall()
    for row in result:
        print(row)

except mysql.connector.Error as e:
    print('数据库错误：', e)

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

在以上代码中，我们使用try-except-finally语句块来处理可能发生的异常，保证程序的稳定性。如果执行过程中出现了数据库错误，程序会捕获异常并输出错误信息，最后会关闭游标和连接。