python SQLAchemy常用語法

SQLAlchemy是Python編程語言下的一款ORM框架，該框架建立在數據庫API之上，使用關系對象映射進行數據庫操作，簡言之便是：將對象轉換成SQL，然后使用數據API執行SQL並獲取執行結果。

SQLAchemy下載

 pip3 install sqlalchemy

SQLAchemy使用

SQLAlchemy本身無法操作數據庫，其必須以來pymsql等第三方插件，Dialect用於和數據API進行交流，根據配置文件的不同調用不同的數據庫API，從而實現對數據庫的操作，如：

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

 1、用sqlalchemy建表

import sqlalchemy
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String

# 連接方式 mysql+pymysql 用戶名 root 密碼 123456 主機 localhost 庫 testdb encoding 字符集
engine = create_engine("mysql+pymysql://root:123456@localhost/testdb",encoding='utf-8', echo=True)

Base = declarative_base()  # 生成orm基類

class User(Base):
    __tablename__ = 'user'  # 表名
    id = Column(Integer, primary_key=True)
    name = Column(String(32))
    password = Column(String(64))


Base.metadata.create_all(engine)  # 創建表結構

 

如果數據庫已經有了這個表了就不會創建了，也不會報錯。

添加數據

先導入sessionmaker

from sqlalchemy.orm import sessionmaker

 

Session_class = sessionmaker(bind=engine)  # 創建與數據庫的會話session class ,注意,這里返回給session的是個class,不是實例
Session = Session_class()  # 生成session實例 cursor

user_obj1 = User(name="alex", password="alex3714")  # 生成你要創建的數據對象
user_obj2 = User(name="jack", password="122") # 生成你要創建的數據對象
print(user_obj.name, user_obj.id)  # 此時還沒創建對象呢，不信你打印一下id發現還是None

Session.add(user_obj1)  # 把要創建的數據對象添加到這個session里， 一會統一創建
Session.add(user_obj2) # 把要創建的數據對象添加到這個session里， 一會統一創建
print(user_obj.name, user_obj.id)  # 此時也依然還沒創建

Session.commit()  # 現此才統一提交，創建數據

 

數據查詢

Session_class = sessionmaker(bind=engine)  # 創建與數據庫的會話session class ,注意,這里返回給session的是個class,不是實例
Session = Session_class()  # 生成session實例 cursor
data = Session.query(User).filter_by(name="alex").all() #filter_by 查出來的是一個列表
print(data)

 

data = Session.query(User).filter_by().all()

如果filter_by沒有設置條件就把表中的數據都查出來了。

雖然是4條數據，但是完全看不懂，轉換下數據顯示格式。

在User類中添加一個方法：

class User(Base):
    __tablename__ = 'user'  # 表名
    id = Column(Integer, primary_key=True)
    name = Column(String(32))
    password = Column(String(64))

    def __repr__(self):         #添加的方法
        return "<%s name:%s>" % (self.id,self.name)

 

 first() 取數據的第一條 ， 沒有last()方法

data = Session.query(User).filter_by().first()  

filter_by和filter的小區別

某些條件下用filter_by：

data = Session.query(User).filter_by(id=2).all()

 轉成filter就要寫成：

data = Session.query(User).filter(User.id==2).all()

 還有就是filter_by不能直接寫 > <這種條件 要用filter。

data = Session.query(User).filter(User.id>2).all()

 多個條件

data = Session.query(User).filter(User.id>2).filter(User.id<5).all()

 修改數據

還是通過面向對象的方式修改。

data = Session.query(User).filter(User.id>2).filter(User.id<5).first()
print(data)
data.name = 'Jack Liu'
data.password = 'Shit happens'
Session.commit()

 原數據的name

回滾

原理和事務的回滾是一樣的。

my_user = Session.query(User).filter_by(id=1).first()
my_user.name = "Jack"

fake_user = User(name='Rain', password='12345')
Session.add(fake_user)

print(Session.query(User).filter(User.name.in_(['Jack', 'rain'])).all())  # 這時看session里有你剛添加和修改的數據

Session.rollback()  # 此時你rollback一下
print('after rollback')
print(Session.query(User).filter(User.name.in_(['Jack', 'rain'])).all())  # 再查就發現剛才添加的數據沒有了。

 

 

統計和分組

統計 count()

Session.query(User).filter(User.name.in_(['Jack', 'rain'])).count()

 分組

from sqlalchemy import func
Session.query(func.count(User.name),User.name).group_by(User.name).all()

 

 

第二種建表方式 不常用 了解即可

from sqlalchemy import Table, MetaData, Column, Integer, String, ForeignKey
from sqlalchemy.orm import mapper

metadata = MetaData()
#表結構 通過Table創建表
user = Table('user', metadata,
             Column('id', Integer, primary_key=True),
             Column('name', String(50)),
             Column('fullname', String(50)),
             Column('password', String(12))
             )


class User(object):  #不繼承Base 自定義類
    def __init__(self, name, fullname, password):
        self.name = name
        self.fullname = fullname
        self.password = password


mapper(User,  user)  #把這個類和表結果關聯一下