// 默認(rèn)從官網(wǎng)下載安裝PyMySQL庫(kù)
pip3 install sqlalchemy
// 從豆瓣源下載安裝PyMySQL庫(kù)
pip3 install sqlalchemy -i https://pypi.douban.com/simple
// 從清華源下載安裝PyMySQL庫(kù)
pip3 install sqlalchemy -i https://pypi.tuna.tsinghua.edu.cn/simple

SQLAlchemy ORM組成部分如下：
Object Relation Mapping(ORM)：對(duì)象關(guān)系映射

SQLAlchemy Core組成部分如下：
Engine：框架的引擎
Connection Pooling：數(shù)據(jù)庫(kù)連接池
Dialect：選擇連接數(shù)據(jù)庫(kù)的DB API種類
Schema/Types：架構(gòu)和類型
SQL Exprression Language：SQL表達(dá)式語(yǔ)言

SQLAlchemy本身無(wú)法操作數(shù)據(jù)庫(kù)，其必須以來(lái)PYMYSQL等第三方插件驅(qū)動(dòng)，
Dialect用于和數(shù)據(jù)API進(jìn)行交流，根據(jù)配置文件的不同調(diào)用不同的數(shù)據(jù)庫(kù)API，
從而實(shí)現(xiàn)對(duì)數(shù)據(jù)庫(kù)的操作

MySQL-Python
    mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>
pymysql
    mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>]
MySQL-Connector
    mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname>
cx_Oracle
    oracle+cx_oracle://user:pass@host:port/dbname[?key=value&key=value...]
更多：http://docs.sqlalchemy.org/en/latest/dialects/index.html

uri: dialect[+driver]://user:password@host/dbname[?key=value..]
- dialect：數(shù)據(jù)庫(kù)，如：sqlite、mysql、oracle、postgresql等
- driver：數(shù)據(jù)庫(kù)驅(qū)動(dòng)，用于連接數(shù)據(jù)庫(kù)，比如pymysql、mysqldb等
- username：數(shù)據(jù)庫(kù)用戶
- password：數(shù)據(jù)庫(kù)密碼
- host：數(shù)據(jù)庫(kù)服務(wù)IP地址
- port：數(shù)據(jù)庫(kù)服務(wù)端口
- database：數(shù)據(jù)庫(kù)名

# 實(shí)例：MySQL + PyMySQL
# MySQL服務(wù)端配置信息
DB_INFO = dict(
    host="127.0.0.1",
    port=6379,
    user="admin",
    password="123456",
    database="test",
    charset="utf8"
)
# 數(shù)據(jù)庫(kù)連接URL格式化
DB_URI = 'mysql+pymysql://{user}:{password}@{host}:{port}/{database}?charset={charset}'.format(**DB_INFO)

engine = create_engine("mysql+pymysql://root:123456@localhost:3306/db4?charset=utf8",
                        max_overflow=0,  # 超過(guò)連接池大小外最多創(chuàng)建的連接
                        pool_size=5,  # 連接池大小
                        pool_timeout=30,  # 池中沒(méi)有線程最多等待的時(shí)間，否則報(bào)錯(cuò)
                        pool_recycle=-1  # 多久之后對(duì)線程池中的線程進(jìn)行一次連接的回收（重置）
                        echo = True    # echo參數(shù)為True時(shí)，會(huì)顯示每條執(zhí)行的SQL語(yǔ)句，可以關(guān)閉 ",max_overflow = 5)

from sqlalchemy import create_engine
# 連接地址
DB_URI = 'mysql+pymysql://{user}:{password}@{host}:{port}/{database}?charset={charset}'
# 創(chuàng)建引擎
engine = create_engine(DB_URI)
# 打開(kāi)連接
conn = engine.connect() 
# 執(zhí)行查詢
result = conn.execute('select * from user limit %s offset %s', 10, 2)
# 獲取單條數(shù)據(jù)
data_line = result.fetchone()
# 獲取多條數(shù)據(jù)
data_list = result.fetchmany(2)
# 獲取全部數(shù)據(jù)
data_list = result.fetchall()
# 插入數(shù)據(jù)操作，獲取最后行ID
last_row_id = result.lastrowid
# 關(guān)閉連接
conn.close()  

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.orm import sessionmaker
# 數(shù)據(jù)庫(kù)連接地址
DB_URI = 'mysql+pymysql://{user}:{password}@{host}:{port}/{database}?charset={charset}'
# 創(chuàng)建數(shù)據(jù)庫(kù)引擎
engine = create_engine(DB_URI)
# 模型基類
Base = declarative_base(engine)
session = sessionmaker(engine)()
class Student(Base):
    """功能：學(xué)生映射模型類"""
    __tablename__ = 'Student'
    id = Column(Integer, primary_key=True, autoincrement=True, comment="主鍵ID")
    name = Column(String(50), index=True, nullable=True, comment="學(xué)生名稱")
    age = Column(Integer, comment="學(xué)生年齡")
    sex = Column(String(10), comment="學(xué)生性別")
# 創(chuàng)建全部表，默認(rèn)自動(dòng)跳過(guò)已存在表
Base.metadata.create_all()
# 創(chuàng)建指定表，默認(rèn)自動(dòng)跳過(guò)已存在表
Base.metadata.create_all(tables=[Student.__table__])
# 刪除全部表，默認(rèn)自動(dòng)跳過(guò)不存在的表
Base.metadata.drop_all()
# 刪除指定表，默認(rèn)自動(dòng)跳過(guò)不存在的表
Base.metadata.drop_all(tables=[Student.__table__])