首页
学习
活动
专区
圈层
工具
发布
社区首页 >专栏 >Python ORM - pymysql&sqlalchemy

Python ORM - pymysql&sqlalchemy

作者头像
十毛
发布2021-01-21 06:24:17
发布2021-01-21 06:24:17
9290
举报

Python3主要是面向对象的编码风格,访问数据库也可以使用ORM框架来实现面向对象,本文介绍pymysql和sqlalchemy

安装组件

代码语言:javascript
复制
pip3 install pymysql
pip3 install sqlalchemy

定义数据对象

  • user表结构
代码语言:javascript
复制
CREATE TABLE `user` (
  `id` int NOT NULL AUTO_INCREMENT,
  `name` varchar(64) NOT NULL,
  `age` int DEFAULT NULL,
  `deleted` int DEFAULT '0',
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_name` (`name`),
  KEY `idx_age` (`age`),
  KEY `idx_name_age` (`name`,`age`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8
  • User对象
代码语言:javascript
复制
# coding=utf-8
from sqlalchemy import Column, String, Integer
from sqlalchemy.ext.declarative import declarative_base

# 创建对象的基类:
Base = declarative_base()

# 定义User对象:
class User(Base):
    # 表的名字:
    __tablename__ = 'user'

    # 表的结构:
    id = Column(Integer, primary_key=True)
    name = Column(String)
    age = Column(Integer)
    deleted = Column(Integer)

    def __str__(self):
        return "id: {}, name: {}, age: {}, deleted: {}" \
            .format(self.id, self.name, self.age, self.deleted)

操作

创建数据

代码语言:javascript
复制
# 创建记录
tenmao = User(name = 'tenmao', age = 100)
session.add(tenmao)
session.commit()

更新数据

代码语言:javascript
复制

查询数据

  • 查询一条数据
代码语言:javascript
复制
# coding=utf-8

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from model.user import User

# 数据库配置
db_user = 'maibao'
db_password = 'maibao123'
db_host_port = '9.134.77.51:3306'

# 初始化数据库连接:
engine = create_engine(
    'mysql+pymysql://{db_user}:{db_password}@{db_host_port}/tenmao'.format(db_user=db_user,
                                                                                       db_password=db_password,
                                                                                       db_host_port=db_host_port))
# 创建DBSession类型:
DBSession = sessionmaker(bind=engine)

# 创建Session:
session = DBSession()

# 创建Query查询,filter是where条件,最后调用one()返回唯一行,如果调用all()则返回所有行:
user = session.query(User).filter(User.id==1).one()

# 打印类型和对象的name属性:
print(user)

# 关闭Session:
session.close()
  • 查询所有数据
代码语言:javascript
复制
# 查询所有User
users = session.query(User).all()

print("there are {} users".format(len(users)))
  • 条件过滤
代码语言:javascript
复制
# 条件查询
users = session.query(User)\
    .filter(User.name == 'timxia')\
    .filter(User.age < 10)\
    .filter(User.name.like('%tim%'))\
    .order_by(User.name.desc(), User.id.asc())\
    .all()

print("there are {} users for given condition".format(len(users)))

常见问题

  • sqlalchemy.exc.InvalidRequestError: SQL expression, column, or mapped entity expected - got '<class 'model.user.User'>' 实体表需要继承declarative_base()
代码语言:javascript
复制
Base = declarative_base()
class User(Base):
  • 创建或修改没有生效

因为没有提交,需要调用commit方法session.commit()

参考

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 安装组件
  • 定义数据对象
  • 操作
    • 创建数据
    • 更新数据
    • 查询数据
  • 常见问题
  • 参考
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档