### query可用参数:
1. 模型对象。指定查找这个模型中所有的对象。
2. 模型中的属性。可以指定只查找某个模型的其中几个属性。
3. 聚合函数。
    * func.count:统计行的数量。
    * func.avg:求平均值。
    * func.max:求最大值。
    * func.min:求最小值。
    * func.sum:求和。
    `func`上,其实没有任何聚合函数。但是因为他底层做了一些魔术,只要mysql中有的聚合函数,都可以通过func调用。

from sqlalchemy import create_engine,Column,Integer,Float,Boolean,DECIMAL,Enum,Date,DateTime,Time,String,Text,func
from sqlalchemy.dialects.mysql import LONGTEXT
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
# 在Python3中才有这个enum模块,在python2中没有
import enum
from datetime import datetime
import random

HOSTNAME = '127.0.0.1'
PORT = '3306'
DATABASE = 'first_sqlalchemy'
USERNAME = 'root'
PASSWORD = 'root'

# dialect+driver://username:password@host:port/database
DB_URI = "mysql+pymysql://{username}:{password}@{host}:{port}/{db}?charset=utf8mb4".format(username=USERNAME,password=PASSWORD,host=HOSTNAME,port=PORT,db=DATABASE)

engine = create_engine(DB_URI)

Base = declarative_base(engine)

session = sessionmaker(engine)()

class Article(Base):
    __tablename__ = 'article'
    id = Column(Integer,primary_key=True,autoincrement=True)
    title = Column(String(50),nullable=False)
    price = Column(Float,nullable=False)

    def __repr__(self):
        return "<Article(title:%s)>" % self.title
# 删除表中的所有数据
Base.metadata.drop_all()
# 创建表
Base.metadata.create_all()

# 随机生成数据,并且保存到数据库
for x in range(6):
    article = Article(title='title%s'%x,price=random.randint(50,100))
    session.add(article)
session.commit()

# 模型对象,
# articles = session.query(Article).all()
# 列表类型输出,每一个数据元素是一个对象。
# print(articles)

# 模型中的属性
# articles = session.query(Article.title,Article.price).all()
# 列表类型输出,每一个数据元素是一个模型中的属性
# print(articles)

# 聚合函数--统计行的数量
# result = session.query(func.count(Article.id)).first()
# print(result)
# 聚合函数--求平均值
# result = session.query(func.avg(Article.price)).first()
# print(result)
# 聚合函数--求最大值
# result = session.query(func.max(Article.price)).first()
# print(result)
# 聚合函数--求最小值
# result = session.query(func.min(Article.price)).first()
# print(result)
# 聚合函数--求和
# result = session.query(func.sum(Article.price)).first()
# print(result)
print(func.sum(Article.price))
# select sum(price) from article

 

Logo

欢迎加入 MCP 技术社区!与志同道合者携手前行,一同解锁 MCP 技术的无限可能!

更多推荐