目录
MySQL简介
MySQL是一种开源的关系型数据库管理系统（RDBMS），广泛用于各种应用程序，特别是Web应用。它使用结构化查询语言（SQL）进行数据库管理和操作，具有高性能、高可靠性和易用性等特点。
安装与配置
在开始操作MySQL之前，需要确保在你的系统中已安装MySQL服务器和客户端工具。可以从MySQL官方网站下载并安装适用于你操作系统的版本。安装完成后，启动MySQL服务并创建一个用于测试的数据库。
sudo service mysql start
mysql -u root -p
在MySQL命令行中创建一个测试数据库：
CREATE DATABASE test_db;
使用MySQL Connector/Python
连接数据库
MySQL Connector/Python是MySQL官方提供的Python连接器，可以通过以下命令安装：
pip install mysql-connector-python
以下是一个连接到MySQL数据库的示例：
import mysql.connector
# 创建数据库连接
conn = mysql.connector.connect(
host='localhost',
user='root',
password='your_password',
database='test_db'
)
# 创建游标对象
cursor = conn.cursor()
print("数据库连接成功")
执行SQL语句
可以使用游标对象执行各种SQL语句，包括插入、查询、更新和删除。
# 创建表
cursor.execute("""
CREATE TABLE IF NOT EXISTS users (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(255) NOT NULL,
age INT NOT NULL
)
""")
# 插入数据
cursor.execute("INSERT INTO users (name, age) VALUES (%s, %s)", ('Alice', 30))
cursor.execute("INSERT INTO users (name, age) VALUES (%s, %s)", ('Bob', 25))
# 提交事务
conn.commit()
处理查询结果
使用fetchall()或fetchone()方法获取查询结果。
# 查询数据
cursor.execute("SELECT * FROM users")
# 获取所有结果
results = cursor.fetchall()
# 处理结果
for row in results:
print(f"ID: {row[0]}, Name: {row[1]}, Age: {row[2]}")
事务管理
可以使用commit()和rollback()方法进行事务管理。
try:
# 开始事务
conn.start_transaction()
# 执行插入操作
cursor.execute("INSERT INTO users (name, age) VALUES (%s, %s)", ('Charlie', 35))
# 提交事务
conn.commit()
except mysql.connector.Error as err:
# 回滚事务
conn.rollback()
print(f"Error: {err}")
使用SQLAlchemy
安装SQLAlchemy
SQLAlchemy是一个功能强大的Python SQL工具包和对象关系映射（ORM）库。可以通过以下命令安装：
pip install sqlalchemy
连接数据库
使用SQLAlchemy连接MySQL数据库。
from sqlalchemy import create_engine
# 创建数据库引擎
engine = create_engine('mysql+mysqlconnector://root:your_password@localhost/test_db')
print("数据库连接成功")
定义模型
使用SQLAlchemy定义数据模型。
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
# 创建基类
Base = declarative_base()
# 定义User模型
class User(Base):
__tablename__ = 'users'
id = Column(Integer, primary_key=True, autoincrement=True)
name = Column(String(255), nullable=False)
age = Column(Integer, nullable=False)
# 创建表
Base.metadata.create_all(engine)
执行查询
使用SQLAlchemy执行查询。
from sqlalchemy.orm import sessionmaker
# 创建会话
Session = sessionmaker(bind=engine)
session = Session()
# 插入数据
new_user = User(name='Alice', age=30)
session.add(new_user)
session.commit()
# 查询数据
users = session.query(User).all()
for user in users:
print(f"ID: {user.id}, Name: {user.name}, Age: {user.age}")
事务管理
SQLAlchemy会自动管理事务，但你也可以手动控制事务。
try:
# 开始事务
session.begin()
# 执行插入操作
new_user = User(name='Charlie', age=35)
session.add(new_user)
# 提交事务
session.commit()
except:
# 回滚事务
session.rollback()
raise
使用Django ORM
安装Django
Django是一个高级Python Web框架，内置了强大的ORM。可以通过以下命令安装：
pip install django
配置数据库
在Django项目的settings.py文件中配置MySQL数据库。
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.mysql',
'NAME': 'test_db',
'USER': 'root',
'PASSWORD': 'your_password',
'HOST': 'localhost',
'PORT': '3306',
}
}
定义模型
在Django应用的models.py文件中定义数据模型。
from django.db import models
class User(models.Model):
name = models.CharField(max_length=255)
age = models.IntegerField()
def __str__(self):
return self.name
执行查询
使用Django ORM执行查询。
# 创建数据
user = User(name='Alice', age=30)
user.save()
# 查询数据
users = User.objects.all()
for user in users:
print(f"ID: {user.id}, Name: {user.name}, Age: {user.age}")
事务管理
Django ORM也支持事务管理，可以使用transaction模块。
from django.db import transaction
try:
with transaction.atomic():
# 执行插入操作
user = User(name='Charlie', age=35)
user.save()
except Exception as e:
print(f"Error: {e}")
总结
本文详细介绍了使用Python操作MySQL的多种方式，包括MySQL Connector/Python、SQLAlchemy和Django ORM。每种方式都有其独特的优点和适用场景，开发者可以根据具体需求选择合适的工具。希望本文能够帮助读者全面了解和掌握Python操作MySQL的技巧和方法，提高开发效率。
标签：多种,name,Python,数据库,Django,user,MySQL,age From： https://blog.csdn.net/fudaihb/article/details/141018739