python和mysql、Python与MySQL数据交互
Python与MySQL数据交互：让数据处理更简单便捷
随着数据时代的到来，数据处理成为了各个领域中不可或缺的一部分。而Python作为一门高效、简洁的编程语言，已经成为了数据科学领域中的重要工具。而MySQL作为一款高性能、可靠的关系型数据库管理系统，也是数据处理中常用的数据库之一。Python与MySQL数据交互的技术，可以让数据处理更加简单便捷，为数据分析、数据挖掘等领域提供了强有力的支持。
一、连接MySQL数据库
使用PyMySQL连接MySQL数据库
在Python中，可以使用PyMySQL模块来连接MySQL数据库。该模块提供了一个connect()函数，用于连接MySQL数据库。在连接MySQL数据库之前，需要先安装PyMySQL模块。安装完成后，可以使用以下代码来连接MySQL数据库：
import pymysql# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","testdb" )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 关闭数据库连接
db.close()
使用MySQLdb连接MySQL数据库
除了PyMySQL模块，还可以使用MySQLdb模块来连接MySQL数据库。MySQLdb模块是Python中一个比较老的连接MySQL数据库的模块，但是仍然被广泛使用。使用MySQLdb模块连接MySQL数据库的代码如下：
import MySQLdb# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","testdb" )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 关闭数据库连接
db.close()
二、执行MySQL查询
执行SELECT语句
在Python中，可以使用execute()方法来执行MySQL查询语句。对于SELECT语句，可以使用fetchall()方法来获取查询结果。以下是一个使用execute()方法执行SELECT语句的示例代码：
import pymysql# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","testdb" )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE
WHERE INCOME > %s" % (1000)
try:
# 执行SQL语句
cursor.execute(sql)
# 获取所有记录列表
results = cursor.fetchall()
for row in results:
fname = row[0]
lname = row[1]
age = row[2]
sex = row[3]
income = row[4]
# 打印结果
print ("fname=%s,lname=%s,age=%d,sex=%s,income=%d" %
(fname, lname, age, sex, income ))
except:
print ("Error: unable to fetch data")
# 关闭数据库连接
db.close()
执行INSERT语句
在Python中，可以使用execute()方法执行INSERT语句来向MySQL数据库中插入数据。以下是一个使用execute()方法执行INSERT语句的示例代码：
import pymysql# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","testdb" )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 插入语句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME,
LAST_NAME, AGE, SEX, INCOME)
VALUES ('%s', '%s', '%d', '%c', '%d' )" %
('Mac', 'Mohan', 20, 'M', 2000)
try:
# 执行SQL语句
cursor.execute(sql)
# 提交到数据库执行
db.commit()
except:
# 如果发生错误则回滚
db.rollback()
# 关闭数据库连接
db.close()
三、使用ORM框架操作MySQL数据库
使用SQLAlchemy操作MySQL数据库
SQLAlchemy是Python中一个流行的ORM框架。ORM（Object-Relational Mapping）是一种将关系型数据库中的数据映射到对象的编程技术。使用ORM框架可以让开发者更加方便地操作数据库。以下是一个使用SQLAlchemy操作MySQL数据库的示例代码：
from sqlalchemy import create_engine, Column, Integer, Stringfrom sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
# 创建连接到MySQL数据库的引擎
engine = create_engine('mysql+pymysql://testuser:test123@localhost/testdb')
# 创建一个会话工厂
Session = sessionmaker(bind=engine)
# 创建一个ORM基类
Base = declarative_base()
# 定义一个ORM模型
class User(Base):
__tablename__ = 'users'
id = Column(Integer, primary_key=True)
name = Column(String(50))
age = Column(Integer)
# 创建所有的表
Base.metadata.create_all(engine)
# 创建一个会话
session = Session()
# 插入数据
user = User(name='John', age=20)
session.add(user)
session.commit()
# 查询数据
users = session.query(User).all()
for user in users:
print(user.name, user.age)
# 关闭会话
session.close()
使用Django操作MySQL数据库
Django是Python中一个流行的Web框架，它也集成了ORM框架。使用Django可以快速地开发Web应用程序，并且可以方便地操作数据库。以下是一个使用Django操作MySQL数据库的示例代码：
# 安装Djangopip install django
# 创建一个Django项目
django-admin startproject myproject
# 进入项目目录
cd myproject
# 创建一个Django应用
python manage.py startapp myapp
# 修改settings.py文件，配置MySQL数据库
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.mysql',
'NAME': 'testdb',
'USER': 'testuser',
'PASSWORD': 'test123',
'HOST': 'localhost',
'PORT': '3306',
}
# 创建一个ORM模型
from django.db import models
class User(models.Model):
name = models.CharField(max_length=50)
age = models.IntegerField()
# 创建数据库表
python manage.py makemigrations
python manage.py migrate
# 插入数据
user = User(name='John', age=20)
user.save()
# 查询数据
users = User.objects.all()
for user in users:
print(user.name, user.age)
四、
Python与MySQL数据交互是数据处理中的重要技术，可以让数据处理更加简单便捷。Python中有多种方法可以连接MySQL数据库，包括使用PyMySQL模块、MySQLdb模块以及ORM框架。对于不同的应用场景，可以选择不同的方法来操作MySQL数据库。掌握Python与MySQL数据交互的技术，可以让开发者更加高效地处理数据，为数据分析、数据挖掘等领域提供强有力的支持。
文章来源网络，作者：运维，如若转载，请注明出处：https://shuyeidc.com/wp/78322.html<
