SQLAlchemy之SQL Expression
SQLAlchemy是一个强大的Python SQL工具箱, 提供了包括ORM在内的各种支持.
首先使用pip安装;
pip install SQLAlchemy
SQL Expression Language 是SQLAlchemy Core的组成部分, 提供了与SQL类似的API而避免了直接书写SQL语句.
连接数据库
使用下列语句连接数据库:
from sqlalchemy import create_engine
engine = create_engine("mysql://root:passwd@localhost:3306/webpy?charset=utf8", echo=True)
create_engine的第一个参数的格式为:
数据库类型://用户名:密码@数据库主机地址/数据库名?编码
没有密码则为空,不填; echo=True则在终端进行回显, 默认为False.
engine可以直接执行sql语句:
engine.execute("SELECT * FROM user")
如果需要事务性操作则需要使用connect:
conn = engine.connect()
result = conn.execute("SELECT * FROM user")
Create Table
使用metadata和Table类来定义表:
from sqlalchemy import create_engine, Table, Column, Integer, String, MetaData, ForeignKey
import MySQLdbengine = create_engine("mysql://root:password@localhost:3306/test?charset=utf8", encoding="utf-8", echo=True)metadata = MetaData()# define
user = Table('user', metadata,Column('user_id', Integer, primary_key=True),Column('name', String(20)),)# do create and commit
metadata.create_all(engine)
回显信息:
...
INFO sqlalchemy.engine.base.Engine
CREATE TABLE user (user_id INTEGER NOT NULL AUTO_INCREMENT, name VARCHAR(20), PRIMARY KEY (user_id)
)
....
INFO sqlalchemy.engine.base.Engine COMMIT
Insert
使用engine.connect()来执行:
from sqlalchemy import create_engine, Table, Column, Integer, String, MetaData, ForeignKey
import MySQLdbengine = create_engine("mysql://root:password@localhost:3306/test?charset=utf8", encoding="utf-8", echo=True)metadata = MetaData()user = Table('user', metadata,Column('user_id', Integer, primary_key=True),Column('name', String(20)),Column('fullname', String(40)),)conn = engine.connect()
i = user.insert()
u = {'name': 'yichya'}
result = conn.execute(i, **u)
select
仍然使用conn对象, 先做一个select * from user
conn = engine.connect()
s = user.select()
result = conn.execute(s)
print (result.fetchall() )
回显:
INFO sqlalchemy.engine.base.Engine SELECT user.user_id, user.name, user.fullname FROM user
INFO sqlalchemy.engine.base.Engine ()
[(1L, u'yichya', None)]
可以使用for-each遍历结果集:
>>>for raw in result:
... print(raw)
INFO sqlalchemy.engine.base.Engine ()
(1L, u'yichya', None)
(2L, u'finley', None)
(3L, u'yy', None)
(4L, u'godess', None)
使用user的column对象可以自定义查询的字段
>>>print(user.c)
['user.user_id', 'user.name', 'user.fullname']
注意select不是从user对象中获得的:
from sqlalchemy.sql import select
conn = engine.connect()
s = select([user.c.user_id, user.c.name])
result = conn.execute(s)
print (result.fetchall() )
可以在终端看到:
INFO sqlalchemy.engine.base.Engine SELECT user.user_id, user.name
FROM user
INFO sqlalchemy.engine.base.Engine ()
[(1L, u'yichya'), (2L, u'finley'), (3L, u'yy'), (4L, u'godess')]
使用where()筛选记录:
from sqlalchemy.sql import select
conn = engine.connect()
s = select([user.c.name]).where(user.c.name == 'yy')
result = conn.execute(s)
print(result.fetchall() )
可以看到回显:
INFO sqlalchemy.engine.base.Engine SELECT user.name
FROM user
WHERE user.name = %sINFO sqlalchemy.engine.base.Engine ('yy',)
[(u'yy',)]
实际上user.c重载了各种运算符:
>>>print(user.c.name == None)
"user".name IS NULL
where支持的运算符包括: >
<
<=
>=
==
和 !=
, 逻辑符and
,or
, not
需要用下述方法:
>>>from sqlalchemy.sql import and_
>>>print(and_(user.c.user_id == address.c.user_id, address.c.city == 'New York') )
"user".user_id = address.user_id AND address.city = :city_1
顺便展示了多表连接查询, 也可以使用join进行查询:
>>>s = select([user.c.name, address.c.email]).select_from(user.join(address, user.c.user_id==address.c.user_id))
>>>print s
SELECT "user".name, address.email
FROM "user" JOIN address ON "user".user_id = address.user_id
更多的查询请参见,文末的参考链接.
Update
仍然使用connect执行:
conn = engine.connect()
u = user.update().where(user.name == 'yichya').values(name='aa')
result = conn.execute(u)
Delete
delete也很简单:
>>>d = user.delete().where(user.c.name == 'yichya')
>>>conn.execute(d)
INFO sqlalchemy.engine.base.Engine DELETE FROM user WHERE user.name = %s
INFO sqlalchemy.engine.base.Engine ('yichya',)
INFO sqlalchemy.engine.base.Engine COMMIT
参考资料:
sqlalchemy docs latest
SQLAlchemy 简单笔记
使用SQLAlchemy-廖雪峰
SQLAlchemy之SQL Expression相关推荐
- 解决 Textual SQL expression ‘id‘ should be explicitly declared as text(‘id‘)的问题
使用python编写Flask架构:使用到SQLalchemy :其中报错Textual SQL expression '-id' should be explicitly declared as t ...
- 【Flask项目】sqlalchemy原生sql查询,返回字典形式数据
在原生sql查询的时候,返回一个list,内部是tuple,他们看似是tuple,实则并不是 而是一个特殊的类型"<class 'sqlalchemy.util._collection ...
- python使用sqlalchemy执行sql查询语句
代码如下: from sqlalchemy import create_engineif __name__ == '__main__':# engine = create_engine("m ...
- Python: SQLAlchemy 打印 SQL语句
目录 一.数据模型定义 二.打印简单的 SQL 三.打印稍微复杂的 SQL 四.打印和方言相关的SQL 五.显示参数 一.数据模型定义 在文件 models.py 中定义表 cat 的模型: impo ...
- SqlAlchemy个人学习笔记完整汇总
使用 sqlalchemy 有3种方式: 方式1, 使用raw sql; 方式2, 使用SqlAlchemy的sql expression; 方式3, 使用ORM. 前两种方式可以统称为 core ...
- Python面试题解析之前端、框架和其他
python面试题解析(前端.框架和其他) 答: HTTP是一个属于应用层的面向对象的协议,由于其简捷.快速的方式,适用于分布式超媒体信息系统.它于1990年提出,经过几年的使用与发展,得到不断地完善 ...
- python面试题解析(前端、框架和其他)
答: HTTP是一个属于应用层的面向对象的协议,由于其简捷.快速的方式,适用于分布式超媒体信息系统.它于1990年提出,经过几年的使用与发展,得到不断地完善和扩展.目前在WWW中使用的是HTTP/1. ...
- Python操作 RabbitMQ、Redis、Memcache、SQLAlchemy
Memcached Memcached 是一个高性能的分布式内存对象缓存系统,用于动态Web应用以减轻数据库负载.它通过在内存中缓存数据和对象来减少读取数据库的次数,从而提高动态.数据库驱动网站的速度 ...
- Python SQLAlchemy
SQLAlchemy介绍 SQLAlchemy是一个基于Python的ORM框架.该框架是建立在DB-API之上,使用关系对象映射进行数据库操作. 简而言之就是,将类和对象转换成SQL,然后使用数据A ...
最新文章
- c 各种编译器(gcc clang)
- 如何测试ASP.NET Core Web API
- python3 print设置不换行
- 华硕笔记本,宽带连上,可以上网, 但收到不无线
- MySQL审计特性调研
- HDU 2604 Queuing(矩阵高速幂)
- JAVA 使用Dom4j 解析XML
- User Manual
- 老男孩Python高级全栈开发工程师【高清全套完整】
- java毕业生设计药品管理系统演示录像2021计算机源码+系统+mysql+调试部署+lw
- 大数据审计的发展_大数据时代对审计发展的影响
- ICPC-Tic Tac Toe
- QQ 正在尝试读取你的浏览记录?这是“火绒拦截腾讯产品,腾讯道歉”的历史重现吗?
- Java 使用redis 设计一个每天重新开始计数的计数器
- 视频编码第一节:H.265/HEVC原理——入门
- 值得珍藏的免费观影网站
- Unity学习笔记-I2 localization
- 自定义View的OnMeasure问题
- MySQL之binlog
- java 数字转化为汉字_工具类_java 数字转化为汉字大写
热门文章
- 我的日常工具——gdb篇
- QT中树控件QTreeView开发实例
- PowerShell-1.入门及其常用
- 【Flutter】插件包选择 ( 查看文档是否全面 | 查看插件包的更新版本次数 | 查看使用示例 | 查看 GitHub 项目的 Star Fork Issues )
- 【Flutter】StatefulWidget 组件 ( FloatingActionButton 组件 | RefreshIndicator 组件 )
- 【鸿蒙 HarmonyOS】界面跳转 ( AbilitySlice 之间的界面跳转 | AbilitySlice 之间的值传递 )
- 【组合数学】生成函数 ( 正整数拆分 | 无序 | 有序 | 允许重复 | 不允许重复 | 无序不重复拆分 | 无序重复拆分 )
- 【Android 异步操作】AsyncTask 异步任务 ( AsyncTask 异步任务执行方法 execute 方法相关源码解析 )
- 【TarsosDSP】TarsosDSP 简介 ( TarsosDSP 功能 | 相关链接 | 源码和相关资源收集 | TarsosDSP 示例应用 | TarsosDSP 源码路径解析 )
- Mysql 8.0安装