mysql八：ORM框架SQLAlchemy
SQLAlchemy是Python編程語言下的一款ORM框架，該框架建立在數據庫API之上，使用關系對象映射進行數據庫操作，簡言之便是：將對象轉換成SQL，然後使用數據API執行SQL並獲取執行結果。
1、安裝
pip3 install sqlalchemy
2、架構與流程
第一步：使用者通過ORM對象提交命令
第二步：將命令交給SQLAlchemy Core（Schema/Types SQL Expression Language）轉換成SQL
第三步：使用 Engine/ConnectionPooling/Dialect 進行數據庫操作
1）匹配使用者事先配置好的egine
2）egine從連接池中取出一個鏈接
3）基於該鏈接通過Dialect調用DB API，將SQL轉交給它去執行
上述流程分析，可以大致分為兩個階段：
第一個階段（流程1-2）：將SQLAlchemy的對象換成可執行的sql語句
第二個階段（流程3）：將sql語句交給數據庫執行
如果我們不依賴於SQLAlchemy的轉換而自己寫好sql語句，那意味著可以直接從第二個階段開始執行了；我們完全可以只用SQLAlchemy執行純sql語句，代碼如下：
from sqlalchemy import create_engine
#1、準備
#需要事先安裝好pymysql
#需要事先創建好數據庫:create database db1 charset utf8;
#2、創建引擎
egine=create_engine('mysql+pymysql://[email protected]/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-Python
mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>
2）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創建出它們，並建立好它們直接的關系
三、增刪改查
表結構
1、增
2、刪
3、改
4、查
四、其他查詢相關
1、準備表和數據
2、條件、通配符、limit、排序、分組、連表、組合
3、子查詢
有三種形式的子查詢，註意：子查詢的sql必須用括號包起來,尤其在形式三中需要註意這一點
形式一:子查詢當做一張表來用,調用subquery()
形式二:子查詢當做in的範圍用,調用in_
形式三:子查詢當做select後的字段,調用as_scalar()
五、正查、反查
1、表修改
2、標準連表查詢
#示例:查詢員工名與其部門名
res=session.query(Emp.ename,Dep.dname).join(Dep) #叠代器
for row in res:
print(row[0],row[1]) #等同於print(row.ename,row.dname)
3、基於relationship的正查、反查
#SQLAlchemy的relationship在內部幫我們做好表的鏈接
#查詢員工名與其部門名(正向查)
res=session.query(Emp)
for row in res:
print(row.ename,row.id,row.depart.dname)
#查詢部門名以及該部門下的員工(反向查)
res=session.query(Dep)
for row in res:
# print(row.dname,row.xxoo)
print(row.dname,[r.ename for r in row.xxoo])
mysql八：ORM框架SQLAlchemy