一、基本介绍
以下介绍来自维基百科,自由的百科全书。
SQLAlchemy是Python编程语言下的一款开源软件。提供了SQL工具包及对象关系映射(ORM)工具,使用MIT许可证发行。
SQLAlchemy“采用简单的Python语言,为高效和高性能的数据库访问设计,实现了完整的企业级持久模型”。SQLAlchemy的理念是,SQL数据库的量级和性能重要于对象集合;而对象集合的抽象又重要于表和行。因此,SQLAlchmey采用了类似于Java里Hibernate的数据映射模型,而不是其他ORM框架采用的Active Record模型。不过,Elixir和declarative等可选插件可以让用户使用声明语法。
SQLAlchemy首次发行于2006年2月,并迅速地在Python社区中最广泛使用的ORM工具之一,不亚于Django的ORM框架。
SQLAlchemy-- > 第一步:将对象转换成SQL 第二步:使用数据API执行SQL并获取执行结果。
1.安装
# windows pip3 install sqlalchemy # Linux $ easy_install sqlalchemy
2.流程介绍
#1、使用者通过ORM对象提交命令 #2、将命令交给SQLAlchemy Core(Schema/Types SQL Expression Language)转换成SQL语句 #3、使用 Engine/ConnectionPooling/Dialect 进行数据库操作 # 3.1、匹配使用者事先配置好的egine # 3.2、egine从连接池中取出一个链接 # 3.3、基于该链接通过Dialect调用DB API,将SQL转交给它去执行
简而言之:
#第一个阶段(流程1-2):将SQLAlchemy的对象换成可执行的sql语句 #第二个阶段(流程3):将sql语句交给数据库执行
可跳过第一阶段,即自己写sql语句,直接给数据库执行。
from sqlalchemy import create_engine #1 准备 # 需要事先安装好pymysql # 需要事先创建好数据库:create database db1 charset utf8; #2 创建引擎 egine=create_engine(‘mysql+pymysql://root@127.0.0.1/db1?charset=utf8‘) #3 执行 自己写的sql语句 # egine.execute(‘create table if not EXISTS t1(id int PRIMARY KEY auto_increment,name char(32));‘) # cur=egine.execute(‘insert into t1 values(%s,%s);‘,[(1,"egon1"),(2,"egon2"),(3,"egon3")]) #按位置传值 # cur=egine.execute(‘insert into t1 values(%(id)s,%(name)s);‘,name=‘egon4‘,id=4) #按关键字传值 #4 新插入行的自增id # print(cur.lastrowid) #5 查询 cur=egine.execute(‘select * from t1‘) cur.fetchone() #获取一行 cur.fetchmany(2) #获取多行 cur.fetchall() #获取所有行
3. DB API 介绍
SQLAlchemy本身无法操作数据库,其必须以来pymsql等第三方插件,Dialect用于和数据API进行交流,根据配置文件的不同调用不同的数据库API,从而实现对数据库的操作,常见的几种配置如下:
#1、MySQL-mysqldb mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname> #2、MySQL-pymysql mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options> #3、MySQL-Connector mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname> #4、cx_Oracle oracle+cx_oracle://user:pass@host:port/dbname[?key=value&key=value...]
二、创建表
ORM中:
# 类名 ===> 表名 # 对象 ===> 表中的一行记录
需求:
创建四张表:业务线,服务,用户,角色,利用ORM创建出它们,并建立好它们直接的关系