Python 数据库骚操作 -- MySQL-阿里云开发者社区

开发者社区> 技术小能手> 正文

Python 数据库骚操作 -- MySQL

简介: 今天这篇主要介绍 MySQL 的 orm 库 SQLAlchemy 。
+关注继续查看

目录

 ●  前言
 ●  MySQL GUI 工具
 ●  MySQL 遇上 Docker
 ●  增删改查
 ●  一对多
 ●  一对一
 ●  多对多

 ●  后记

前言

今天这篇是三大数据库的结尾篇,前面两篇分别是:

Python 数据库骚操作 -- MongoDB

Python 数据库骚操作 -- Redis

今天这篇主要介绍 MySQL 的 orm 库 SQLAlchemy 。那什么是 orm 呢?Object Relational Mapper,描述程序中对象和数据库中数据记录之间的映射关系的统称。介绍完了,那就走起呗!

MySQL GUI 工具

首先介绍一款 MySQL 的 GUI 工具 Navicat for MySQL,初学 MySQL 用这个来查看数据真的很爽。可以即时看到数据的增删改查,不用操作命令行来查

975c1dc83434219af433310d9f843cced634363e

MySQL 遇上 Docker

继续分享一下 Docker compose 代码片段,用过 docker 之后,我相信你再也不会为了配置各种开发环境而烦恼了。

version: '3'
services:
mysql_container:
image: mysql
ports:
- "3306:3306"
volumes:
- /usr/local/db/mysql:/var/lib/mysql
# - /root/docker/test-mysql/conf.d:/etc/mysql/conf.d
environment:
- MYSQL_DATABASE=dbname
- MYSQL_ROOT_PASSWORD=your_password
增删改查
首先定义表结构
# 创建单表
class Users(Base):
# 表名
__tablename__ = 'users'
id = Column(BIGINT, primary_key=True, autoincrement=True)
# 定义字段
name = Column(String(32))
age = Column(Integer())
# 初始化数据库
def init_db():
Base.metadata.create_all(engine)
# 删除数据库
def drop_db():
Base.metadata.drop_all(engine)
连接
from sqlalchemy import create_engine, Column, Integer, String, BIGINT, ForeignKey, UniqueConstraint, Index, and_, or_, inspect
from sqlalchemy.orm import sessionmaker, relationship,contains_eager
# echo 为 True 将会打印 SQL 原生语句
engine = create_engine('mysql+pymysql://username:password@localhost:3306/db_name',echo=True)
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
Session = sessionmaker(bind=engine)
session = Session()
增加
new_user = Users(name='zone', age=18)
session.add(new_user)
# 批量添加
session.add_all([
User(name='zone2', age=25),
User(name='zone3', age=32)
])
# 提交
session.commit()

cb27af987659c9eefaeb654b030bf7472a502c21
删除
session.query(User).filter_by(name="zone").delete()
# 提交
session.commit()
修改
session.query(User).filter(User.name == 2).update({"name": "new name"})
session.query(User).filter(User.id >= 3).update({User.name: "关注公众号【zone7】"}, synchronize_session=False)
session.query(User).filter(User.age == 50).update({"age": 123}, synchronize_session="evaluate")
session.commit()

查找

查找的需求会比较多变,我这边就列出比较常见的查询需求。

result = session.query(User).all() # 结果为一个列表 
result = session.query(User.id, User.age).all() 
result = session.query(User).filter_by(name='zone').first() 
result = session.query(User).filter_by(name='zone2').all() 
# 与、或 
result = session.query(User).filter_by(and_(name='zone5',age="23")).all() 
result = session.query(User).filter_by(or_(name='zone5',age="23")).all() 
# 模糊查询 
result = session.query(User).filter(User.name.like('zon%')).all() 
# 排序 
result = session.query(User).order_by(User.age.desc()).all()
# 分页查询
result = session.query(User).offset(1).limit(1).all() 

一对多

关系型数据库,少不了各种表与表的关系。back_populates 在一对多的关系中建立双向的关系,这样的话在对方看来这就是一个多对一的关系。

def one_to_many():
class Parent(Base):
__tablename__ = 'parent'
id = Column(Integer, primary_key=True)
children = relationship("Child", back_populates="parent")

class Child(Base):
__tablename__ = 'child'
id = Column(Integer, primary_key=True)
parent_id = Column(Integer, ForeignKey('parent.id'))
parent = relationship("Parent", back_populates="children")
name = Column(String(32))

# 子表类中附加一个 relationship() 方法
# 并且在(父)子表类的 relationship() 方法中使用 relationship.back_populates 参数

drop_db()
init_db()

child1 = Child(name="zone1")
child2 = Child(name="zone2")
parent = Parent(children=[child1, child2])
session.add(parent)
session.commit()
result = session.query(Parent).join(Child).first()
print(object_as_dict(result.children[0]))

one_to_many()

运行结果

d881b583a1457b4e755602eeacd2c48fbdce7774

一对一

参数 back_populates 指定双向关系,参数 uselist=False 需要在一对多关系基础上,父表中使用 uselist 参数来表示。

def one_to_one():
class Parent(Base):
__tablename__ = 'parent'
id = Column(Integer, primary_key=True)
child = relationship("Child", uselist=False, back_populates="parent")

class Child(Base):
__tablename__ = 'child'
id = Column(Integer, primary_key=True)
parent_id = Column(Integer, ForeignKey('parent.id'))
parent = relationship("Parent", back_populates="child")
name = Column(String(32))

# 清空数据库,并且重新初始化
drop_db()
init_db()
child = Child(name="zone")
parent = Parent(child=child)
session.add(parent)
session.commit()

result = session.query(Parent).join(Child).first()
print(object_as_dict(result.child))

one_to_one()

1afea1997e129d9c34be380694953ae59d6ed33e
多对多

多对多关系会在两个类之间增加一个关联的表来表示其中的关系。这个关联的表在 relationship() 方法中通过 secondary 参数来表示。通常,这个表会通过 MetaData 对象来与声明基类关联。

def many_to_many():
association_table = Table('association', Base.metadata,
Column('left_id', Integer, ForeignKey('left.id')),
Column('right_id', Integer, ForeignKey('right.id'))
)

class Parent(Base):
__tablename__ = 'left'
id = Column(Integer, primary_key=True,autoincrement=True)
children = relationship(
"Child",
secondary=association_table,
back_populates="parents")

class Child(Base):
__tablename__ = 'right'
id = Column(Integer, primary_key=True,autoincrement=True)
name = Column(String(32))
parents = relationship(
"Parent",
secondary=association_table,
back_populates="children")

# 清空数据库,并且重新初始化
drop_db()
init_db()

child1 = Child(name="zone1")
child2 = Child(name="zone2")
child3 = Child(name="zone3")

parent = Parent()
parent2 = Parent()
# parent 添加 child
parent.children.append(child1)
parent.children.append(child2)
parent2.children.append(child1)
parent2.children.append(child2)
# save
session.add(parent)
session.add(parent2)
session.commit()
# 查询
result = session.query(Parent).first()
print(object_as_dict(result))
print(object_as_dict(result.children[1]))
result2 = session.query(Child).first()
print(object_as_dict(result2))
print(object_as_dict(result2.parents[1]))

many_to_many()

adb96fa5b43a9bcacde5343771a1e2b92f3bc61e

第一红框为 result 第二红框为 result2


原文发布时间为:2018-11-19
本文作者:zone7
本文来自云栖社区合作伙伴“小詹学Python”,了解相关信息可以关注“小詹学Python”。

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
数据库MySQL的基本操作
1.MySQL数据库的安装: CentOS6上mysql服务端和客户端的安装和启动: #使用yum安装mysql数据库的服务端和客户端 yum install -y mysql mysql-server #把mysql服务端加入开机自启动 chkconfig msyqld on #立即启动mysql...
592 0
MySQL 基础---数据操作
数据的操作(CRUD): 插入数据记录(CREATE) 查询数据记录(READ) 更新数据记录(UPDATE) 删除数据记录(DELETE) 插入数据记录("INSERT INTO") 插入数据: 插入完整数据记录、插入数据记录一部分、插入多条数据记录、插入查询结果。
477 0
MySQL数据库的常用操作
添加一个用户dba,密码sql,可以管理db_开头的数据库 GRANT ALL PRIVILEGES ON `db\_`.* TO 'dba'@'localhost' IDENTIFIED BY 'sql' WITH GRANT OPTION; FLUSH PRIVILEGES;   从其他机器访问 如果要允许从其他机器访问,要修改 etc/mysql/my.
690 0
Python:cator查询MySQL和SQLite数据库
Python:cator查询MySQL和SQLite数据库
8 0
MySQL 服务器变量 数据操作DML-视图
原文:MySQL 服务器变量 数据操作DML-视图 SQL语言的组成部分 常见分类: DDL:数据定义语言 DCL:数据控制语言,如授权 DML:数据操作语言 其它分类: 完整性定义语言: DDL的一部分功能约束 约束:包括主键,外...
819 0
python3 django配置数据库(mysql)
python3 django配置数据库(mysql) python3 下的mysql驱动 django 连接mysql默认驱动是MySQLdb,MySQLdb没有支持python3的版本,如果使用python3.
3033 0
python3使用Lxml库操作XPath
download address: http://pypi.python.org/pypi/lxml/2.3 lxml is a Pythonic, mature binding for the libxml2 and libxslt libraries.
844 0
教你如何用python操作数据库mysql ! !
前言首先,安装需要的环境,Mysql和Python就不说了,必备的东西。 主要是安装的MySQLdb,可以去sf.net下载,具体地址是http://sourceforge.net/projects/mysql-python/ 如果用Ubuntu,直接 sudo apt-get install p...
1577 0
python34之殇——DJango连接Mysql数据库
系统环境: 64位 windows 7 + python34 + Django 1.8 问题描述:       因为MySQLdb不兼容python3.x,导致DJango使用django.db.backends.mysql连接mysql数据库时,出现启动网站报错。
890 0
+关注
技术小能手
云栖运营小编~
5951
文章
9
问答
文章排行榜
最热
最新
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载