黑马程序员python mysql
时间: 2025-07-15 16:00:17 浏览: 5
### Python连接和操作MySQL数据库教程
#### 安装MySQL数据库系统
在开始Python与MySQL的整合开发之前,需要先安装MySQL数据库系统。可以在[MySQL官网](https://dev.mysql.com/downloads/installer/)下载并安装适合你操作系统的版本。安装完成后,确保MySQL服务已经启动,并配置好环境变量以便于后续操作。
#### 安装PyMySQL或mysql-connector-python驱动程序
Python通过特定的数据库驱动程序来连接MySQL数据库。常用的驱动程序有`PyMySQL`和`mysql-connector-python`。
##### 使用pip安装PyMySQL
```bash
pip install pymysql
```
##### 使用pip安装mysql-connector-python
```bash
python -m pip install mysql-connector-python
```
#### Python编程连接MySQL数据库
安装完所需的库之后,可以使用Python代码来连接MySQL数据库。
##### 使用PyMySQL连接MySQL数据库
```python
import pymysql
# 打开数据库连接
conn = pymysql.connect(
host='127.0.0.1', # 连接名称,默认127.0.0.1
user='root', # 用户名
password='666666', # 密码
port=3306, # 端口,默认为3306
database='test', # 数据库名称
charset='utf8' # 字符编码
)
# 使用 cursor() 方法创建一个游标对象
cursor = conn.cursor()
# 使用 execute() 方法执行 SQL 查询
sql = '''SELECT * FROM table1''' # SQL语句
try:
cursor.execute(sql) # 执行SQL语句
data = cursor.fetchall() # 通过fetchall方法获得数据
for row in data[:10]: # 获得10条数据
print(row)
except Exception as e:
cursor.rollback() # 如果出错就回滚并且抛出错误收集错误信息
print("Error!: {}".format(e))
finally:
cursor.close() # 关闭数据库连接
```
##### 使用mysql-connector-python连接MySQL数据库
```python
import mysql.connector
# 创建连接
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
password="yourpassword"
)
print(mydb) # 输出连接对象以确认是否成功
```
#### 基本的数据库操作
一旦建立了数据库连接,就可以进行基本的数据操作,包括增删改查等。
##### 创建表
```python
# 使用pymysql创建表
cursor.execute("""
CREATE TABLE IF NOT EXISTS users (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(255),
email VARCHAR(255)
)
""")
```
##### 插入数据
```python
# 插入单条记录
sql = "INSERT INTO users (name, email) VALUES (%s, %s)"
val = ("John", "[email protected]")
cursor.execute(sql, val)
conn.commit() # 提交事务
```
##### 查询数据
```python
# 查询所有用户
cursor.execute("SELECT * FROM users")
result = cursor.fetchall()
for row in result:
print(row)
```
##### 更新数据
```python
# 更新用户的邮箱
sql = "UPDATE users SET email = %s WHERE name = %2%"
val = ("[email protected]", "John")
cursor.execute(sql, val)
conn.commit()
```
##### 删除数据
```python
# 删除用户
sql = "DELETE FROM users WHERE name = %s"
val = ("John",)
cursor.execute(sql, val)
conn.commit()
```
#### 总结
以上步骤涵盖了从安装MySQL数据库到使用Python连接和操作MySQL数据库的基本流程。无论是使用`PyMySQL`还是`mysql-connector-python`,都可以实现对MySQL数据库的有效管理[^3]。
阅读全文
相关推荐

















