sqlAlchemy是python中最著名的ORM(Object Relationship Mapping)框架了。
什么是ORM？
一句話解釋的話就是，一種可以把model中的模型和數(shù)據(jù)庫中的一條數(shù)據(jù)相互轉(zhuǎn)換的工具。
初始化數(shù)據(jù)庫連接
# 初始化數(shù)據(jù)庫鏈接
engine = create_engine('mysql+mysqlconnector://root:123456@localhost:3306/test')
create_engine()函數(shù)中的字符串的意義是，數(shù)據(jù)庫+數(shù)據(jù)庫連接框架://用戶名:密碼@IP地址:端口號/數(shù)據(jù)庫名稱。
那么不難看出，我使用了mysql數(shù)據(jù)庫，數(shù)據(jù)庫連接框架用的mysqlconnector，用戶名root，密碼123456，ip地址是localhost(會被解析為127.0.0.1)，端口號3306(這是mysql服務(wù)器默認(rèn)端口號)，test是數(shù)據(jù)庫的名字。
數(shù)據(jù)庫建表
在test數(shù)據(jù)庫中，創(chuàng)建user表。sql如下
create table user (id varchar(20) primary key, name varchar(20))
創(chuàng)建表，表名為user，表中有兩個字段。一個是id，varchar類型，最多支持20個字符，設(shè)置為主鍵，另一個是name，varchar類型，最多支持20個字符。
ps：主鍵是唯一的，當(dāng)你重復(fù)插入時會報錯，并終止插入操作。
創(chuàng)建User模型
在model.py中創(chuàng)建一個User類，用來和User表中的字段進(jìn)行關(guān)聯(lián)。
# 定義User對象
class User(Base):
# 表的名字
__tablename__ = 'user'
# 表的結(jié)構(gòu)
id = Column(String(20), primary_key=True)
name = Column(String(20))
這里可以發(fā)現(xiàn)，User類的字段名和表中完全一致，而且字段的屬性也一樣。以id字段為例，表中id的屬性是varchar(20)，primary key，模型中String(20), primary_key=True。我們可以清晰的看到varchar在程序中對應(yīng)String，primary_key對應(yīng)程序中的primary_key屬性，而且是個bool類型。
ps：這里的String是sqlAlchemy中的一個類，這樣類似的類我們還會用到Column。
CRUD(Create Read Update Delete, 增查改刪)
在sqlAlchemy中，增刪改查操作是通過一個session對象(DBSession,是由sessionmaker創(chuàng)建的)來完成的。如果你和我一樣是新手，估計也完全不懂，但是至少讀一遍有個印象，我們一步一步來。
所以，我們需要創(chuàng)建session。
# 創(chuàng)建DBSession類型
DBSession = sessionmaker(bind=engine)
在此基礎(chǔ)之上我們就能進(jìn)行增刪改查的操作了。先從增加開始。
# 創(chuàng)建Session對象
session = DBSession()
# 創(chuàng)建User對象
new_user = User(id='1', name='Bob')
# 添加到session
session.add(new_user)
# 提交
session.commit()
# 關(guān)閉session
session.close()
還有查詢
# 創(chuàng)建session
session = DBSession()
# 利用session創(chuàng)建查詢，query(對象類).filter(條件).one()/all()
user = session.query(User).filter(User.id=='1').one()
print('type:{0}'.format(type(user)))
print('name:{0}'.format(user.name))
# 關(guān)閉session
session.close()
更新操作
要多一步，就是要先根據(jù)篩選條件拿到要更改的對象，然后給對象賦值，再次提交(commit)即可。
# 更新
session = DBSession()
user_result = session.query(User).filter_by(id='1').first()
user_result.name = "jack"
session.commit()
session.close()
刪除操作
# 刪除
session = DBSession()
user_willdel = session.query(User).filter_by(id='5').first()
session.delete(user_willdel)
session.commit()
session.close()
代碼整合
把上面零零散散的代碼片段合起來
# 導(dǎo)入依賴
from sqlalchemy import Column, String, create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
# 創(chuàng)建對象的基類
Base = declarative_base()
# 定義User對象
class User(Base):
# 表的名字
__tablename__ = 'user'
# 表的結(jié)構(gòu)
id = Column(String(20), primary_key=True)
name = Column(String(20))
# 初始化數(shù)據(jù)庫鏈接
engine = create_engine('mysql+mysqlconnector://root:123456@localhost:3306/test')
# 創(chuàng)建DBSession類型
DBSession = sessionmaker(bind=engine)
# 添加
# 創(chuàng)建Session對象
session = DBSession()
# 創(chuàng)建User對象
new_user = User(id='5', name='Bob')
# 添加到session
session.add(new_user)
# 提交
session.commit()
# 關(guān)閉session
session.close()
# 查詢
# 創(chuàng)建session
session = DBSession()
# 利用session創(chuàng)建查詢，query(對象類).filter(條件).one()/all()
user = session.query(User).filter(User.id=='5').one()
print('type:{0}'.format(type(user)))
print('name:{0}'.format(user.name))
# 關(guān)閉session
session.close()
# 更新
session = DBSession()
user_result = session.query(User).filter_by(id='1').first()
user_result.name = "jack"
session.commit()
session.close()
# 刪除
session = DBSession()
user_willdel = session.query(User).filter_by(id='5').first()
session.delete(user_willdel)
session.commit()
session.close()
如果運(yùn)行代碼發(fā)現(xiàn)報錯了，你也許是因?yàn)橐韵聨讉€原因：
- 1.test數(shù)據(jù)庫中沒有User表
- 2.檢查數(shù)據(jù)庫連接語句中，create_engine中的字符串是否正確
-
3.表中數(shù)據(jù)重復(fù)，如果你像我一樣設(shè)置了主鍵的話，是不能重復(fù)插入數(shù)據(jù)的，所以程序會報錯
暫時只想到這幾個原因，具體原因還要運(yùn)行窗口中的報錯信息。
image.png
以上內(nèi)容參考廖雪峰老師的博客，傳送門
還有一個哥們的博客的查詢操作寫的很詳細(xì)，也可以看一下，傳送門。
到此為止，也只能是了解了sqlAlchemy的基本操作，下一章再深入一些了解，傳送門
