SQLAlchemy是Python程式語言下的一款ORM框架，該框架建立在資料庫API之上，使用關係物件對映進行資料庫操作，簡言之便是：將物件轉換成SQL，然後使用資料庫API執行SQL並獲取執行結果。

安裝：

pip3 install SQLAlchemy

版本檢查：

import sqlalchemy
sqlalchemy.__version__

不同資料庫配置：

根據配置檔案的不同調用不同的資料庫API，從而實現對資料庫的操作：

格式：'資料庫型別+資料庫驅動名稱://使用者名稱:口令@機器地址:埠號/資料庫名'

MySQL-Python
    mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>
 
pymysql
    mysql+pymysql://<username>:<password>@<host>[:<port>]/<dbname>[?<options>]
 
MySQL-Connector
    mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname>
 
cx_Oracle
    oracle+cx_oracle://user:
 
[email protected]:port/dbname[?key=value&key=value...]

連線資料庫：

from sqlalchemy import create_engine
engine = create_engine("mysql+pymysql://root:[email protected]/school",encoding='utf-8',echo=True)

宣告對映：

declaractive用來表示類與表的關係。

宣告基類，將類對映到資料表，自定義資料表類必須繼承這個基類。

from sqlalchemy.ext.declaractive import  declaractive_base
Base = declaractive_base()

建立表結構類：

一個表結構類必須包含一個__tablename__和primary_key的欄位

欄位的型別：

SmallInteger
Integer
BigInteger
Float
Numeric(precision=None, scale=None, decimal_return_scale=None, asdecimal=True)

Boolean
Enum

Date
DateTime
Time
Interval(native=True, second_precision=None, day_precision=None)

LargeBinary(length=None)
MatchType(create_constraint=True, name=None, _create_events=True)
PickleType(protocol=4, pickler=None, comparator=None)
SchemaType(name=None, schema=None, metadata=None, inherit_schema=False, quote=None, _create_events=True)
String(length=None, collation=None, convert_unicode=False, unicode_error=None, _warn_on_bytestring=False)
Text(length=None, collation=None, convert_unicode=False, unicode_error=None, _warn_on_bytestring=False)
Unicode(length=None, **kwargs)

欄位的選項：

Column(
nullable=True,      # 可以為空

autoincrement=True, # 數值自增

default='red'       # 指定預設值

primary_key = True  # 設為主鍵

ForeignKey = 'table_name.id'    # 指定外來鍵，ForeignKey需要匯入
)

建立sqlalchemy連線：

from sqlalchemy import create_engine
engine = create_engine()

宣告表結構：

class School(Base):
    __tablename__ = "school"                # 這個才是表名
    id = Column(Integer, primary_key = True)
    sch_name = Column(String(32))
    sch_addr = Column(String(255))
    sch_tel = Column(Integer)
    
    def __repr__(self):
        # 查詢的時候顯示的是值，需不是一個記憶體地址。
        return "school name:{},tel:{}".format(self.sch_name,self.sch_tel)

動態新增表字段。

def add_filed(table_name,):
for i in range(3):

    setattr(table_class,'Col'+str(i),(Column('Col'+str(i), String(50),comment='Col'+str(i))))

Base.metadata.create_all(engine)

建立表：

Base.metadata.create_all(engine)
# 刪除表 Base.metadata.drop_all(engine)

增加一條記錄：

from sqlalchemy.orm import sessionmaker
Session = sessionmaker(bind=engine)        # 建立一個與資料庫的會話，生成的物件是類
session = Session()                        # 例項化這個會話類

class AddRecord(object):
    # 互動新增記錄類。
    def __init__(self,*args):
        # self.table_name = table_name
        self.school_feild = {'sch_name':'學校名：','sch_addr':'學校地址：','sch_tel':'學校電話：'}
    
    def school(self):
        f = {}
        for k,v in self.school.items():
            f[k] = input('{}'.format(v)).strip()
        return f            # 返回一個字典
        
add = AddRecord()
school_attr = add.school()    # 獲取輸入的值
# 下面a1是建立一條記錄
a1 = School(sch_name = school_attr[sch_name],sch_addr= school_attr[sch_addr],sch_tel = school_attr[sch_tel])
session.add(a1)                # 把記錄新增到資料庫
session.commit()               # 提交到資料庫，最終對資料庫更改。

 增、查、改、刪：

這四個操作都需要匯入sessionmaker ，用sessionmaker建立一個會話，除了建庫外，所有操作都在會話中完成。

from sqlalchemy.orm import sessionmaker
Session = sessionmaker()
session =Session()

 增：

 查：

 這三個操作都需要用到query

改：

刪：

一個基本表的建立與操作：

from sqlalchemy import create_engine, ForeignKey, Table, Column, String, Integer, Boolean, Enum

from sqlalchemy.orm import sessionmaker, relationship
from sqlalchemy.ext.declarative import declarative_base
mysql_name = 'david'
mysql_pw = 'Yaotiao&shunv666'
mysql_server = '192.168.2.120'
database_name = 'test'


# 1、連線資料庫
engine = create_engine("mysql+pymysql://{name}:{pw}@{server}/{database}".
                        format(mysql_name,mysql_pw,mysql_server,database_name),
                        encoding ='utf-8'
                        )

# 2、生成ORM基類
Base = declarative_base()


# 3、繼承基類，定義表結構
class Product(Base):
    # 建立orm物件
    __tablename__ = 'products'                # 資料表名
    id = Column(Integer, primary_key = True)    # 欄位，設為主鍵，預設不用賦值，此欄位會自增
    name = Column(String(32))
    price = Column(Integer)

    def __repr__(self):
        # 列印查詢結果例項顯示結果，不加此項顯示的是類的記憶體地址
        return "name:{},price:{}".format(self.name,self.price)
    
# 4、建立資料表
Base.metadata.create_all(engine)                # 在資料庫中建立表，已存在則不建立


# 5、新增多條資料
product1 = Product(name = '華為100', price = 999) # 建立兩個例項
product2 = Product(name = '華為400', price = 1999)
session.add_all([product1,product2 ])    # add_all把例項列表新增到資料庫

# 6、新增單條資料
product = Product(name = '一條', price = 9999)
session.add(product)


# 7、查詢資料

query_data = session.query(Product).all()       # 查所有，如果不加__repr__,結果是記憶體地址列表，使用for檢視

for i in query_data:
    # 檢視結果
    print (i.id,i.name,i.price)

# 8、修改一項資料
query_data = session.query(Product).filter(Product.name=='一條').first()
query_data.name = 'yitiao'        # 只改name一個數據

# 9、批量更新：把所有華為開頭的產品價格改成10000
session.query(Product).filter(Product.name.like('華為%')).update({Product.price:10000},synchronize_session =False)


# 10、通過主鍵改內容merge：
update_name = Product(id=3,price=3651) 
session.merge(update_name)                # id 和 name不變，只修改了價格price = 3651

# 11、刪除一條資料：把華為開頭的價格最高的一條資料刪掉
del_product = session.query(Product).fileter(Product.price.like('華為%'))).order_by(Product.price.desc()).first()
session.delete(del_product)

# 12、刪除所有符合條件的資料：
session.query(Product).filter(Product.name.like('華為%')).delete(synchronize_session = False)

 問題集：http://blog.51cto.com/13914991/2235437