【Python模塊】sqlalchemy orm模塊--基礎(chǔ)（連接數(shù)據(jù)庫(kù)，建表，增刪改查）

SQLAlchemy是Python編程語(yǔ)言下的一款ORM框架，該框架建立在數(shù)據(jù)庫(kù)API之上，使用關(guān)系對(duì)象映射進(jìn)行數(shù)據(jù)庫(kù)操作，簡(jiǎn)言之便是：將對(duì)象轉(zhuǎn)換成SQL，然后使用數(shù)據(jù)庫(kù)API執(zhí)行SQL并獲取執(zhí)行結(jié)果。

?

安裝：

pip3?install?SQLAlchemy

版本檢查：

import?sqlalchemy
sqlalchemy.__version__

不同數(shù)據(jù)庫(kù)配置：

根據(jù)配置文件的不同調(diào)用不同的數(shù)據(jù)庫(kù)API，從而實(shí)現(xiàn)對(duì)數(shù)據(jù)庫(kù)的操作：

格式：'數(shù)據(jù)庫(kù)類(lèi)型+數(shù)據(jù)庫(kù)驅(qū)動(dòng)名稱(chēng)://用戶名:口令@機(jī)器地址:端口號(hào)/數(shù)據(jù)庫(kù)名'

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:pass@host:port/dbname[?key=value&key=value...]

?

連接數(shù)據(jù)庫(kù)：

from?sqlalchemy?import?create_engine
engine?=?create_engine("mysql+pymysql://root:a13896321z@127.0.0.1/school",encoding='utf-8',echo=True)

聲明映射：

declaractive用來(lái)表示類(lèi)與表的關(guān)系。

聲明基類(lèi)，將類(lèi)映射到數(shù)據(jù)表，自定義數(shù)據(jù)表類(lèi)必須繼承這個(gè)基類(lèi)。

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

創(chuàng)建表結(jié)構(gòu)類(lèi)：

一個(gè)表結(jié)構(gòu)類(lèi)必須包含一個(gè)__tablename__和primary_key的字段

字段的類(lèi)型：

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)

#?常用的類(lèi)型：
類(lèi)型名????????python類(lèi)型????????????說(shuō)明
Integer???????int????????????????普通整數(shù)，32位????
Float?????????float??????????????浮點(diǎn)數(shù)????
String????????str????????????????變長(zhǎng)字符串????
Text??????????str????????????????變長(zhǎng)字符串，對(duì)較長(zhǎng)字符串做了優(yōu)化????
Boolean???????bool???????????????布爾值????
PickleType????任何python對(duì)象??????自動(dòng)使用Pickle序列化

字段的選項(xiàng)：

Column(
nullable=True,??????#?可以為空

autoincrement=True,?#?數(shù)值自增

default='red'???????#?指定默認(rèn)值

primary_key?=?True??#?設(shè)為主鍵

ForeignKey?=?'table_name.id'????#?指定外鍵，F(xiàn)oreignKey需要導(dǎo)入

unique?=?True???????#?設(shè)定此字段鍵值唯一，不允許出現(xiàn)重復(fù)值。
)

?

建立sqlalchemy連接：

?

from?sqlalchemy?import?create_engine
engine?=?create_engine()

聲明表結(jié)構(gòu)：

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

?

?

動(dòng)態(tài)添加表字段。

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)

?

?

創(chuàng)建表：

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

增加一條記錄：

from?sqlalchemy.orm?import?sessionmaker
Session?=?sessionmaker(bind=engine)????????#?創(chuàng)建一個(gè)與數(shù)據(jù)庫(kù)的會(huì)話，生成的對(duì)象是類(lèi)
session?=?Session()????????????????????????#?實(shí)例化這個(gè)會(huì)話類(lèi)

class?AddRecord(object):
????#?交互添加記錄類(lèi)。
????def?__init__(self,*args):
????????#?self.table_name?=?table_name
????????self.school_feild?=?{'sch_name':'學(xué)校名：','sch_addr':'學(xué)校地址：','sch_tel':'學(xué)校電話：'}
????
????def?school(self):
????????f?=?{}
????????for?k,v?in?self.school.items():
????????????f[k]?=?input('{}'.format(v)).strip()
????????return?f????????????#?返回一個(gè)字典
????????
add?=?AddRecord()
school_attr?=?add.school()????#?獲取輸入的值
#?下面a1是創(chuàng)建一條記錄
a1?=?School(sch_name?=?school_attr[sch_name],sch_addr=?school_attr[sch_addr],sch_tel?=?school_attr[sch_tel])
session.add(a1)????????????????#?把記錄添加到數(shù)據(jù)庫(kù)
session.commit()???????????????#?提交到數(shù)據(jù)庫(kù)，最終對(duì)數(shù)據(jù)庫(kù)更改。

表的參數(shù)__table_args__：

__table_args__:參數(shù)需要導(dǎo)入。

from?sqlalchemy?import?UniqueConstraint,?PrimaryKeyConstraint,?Index

?增、查、改、刪：

這四個(gè)操作都需要導(dǎo)入sessionmaker ，用sessionmaker創(chuàng)建一個(gè)會(huì)話，除了建庫(kù)外，所有操作都在會(huì)話中完成。

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

?

?增：

?

?查：

?這三個(gè)操作都需要用到query

?

改：

?

刪：

?

?

一個(gè)基本表的創(chuàng)建與操作：

?

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、連接數(shù)據(jù)庫(kù)
engine?=?create_engine("mysql+pymysql://{name}:{pw}@{server}/{database}".
????????????????????????format(mysql_name,mysql_pw,mysql_server,database_name),
????????????????????????encoding?='utf-8'
????????????????????????)

#?2、生成ORM基類(lèi)
Base?=?declarative_base()


#?3、繼承基類(lèi)，定義表結(jié)構(gòu)
class?Product(Base):
????#?創(chuàng)建orm對(duì)象
????__tablename__?=?'products'????????????????#?數(shù)據(jù)表名
????id?=?Column(Integer,?primary_key?=?True)????#?字段，設(shè)為主鍵，默認(rèn)不用賦值，此字段會(huì)自增
????name?=?Column(String(32))
????price?=?Column(Integer)

????def?__repr__(self):
????????#?打印查詢結(jié)果實(shí)例顯示結(jié)果，不加此項(xiàng)顯示的是類(lèi)的內(nèi)存地址
????????return?"name:{},price:{}".format(self.name,self.price)
????
#?4、創(chuàng)建數(shù)據(jù)表
Base.metadata.create_all(engine)????????????????#?在數(shù)據(jù)庫(kù)中創(chuàng)建表，已存在則不創(chuàng)建


#?5、添加多條數(shù)據(jù)
product1?=?Product(name?=?'華為100',?price?=?999)?#?創(chuàng)建兩個(gè)實(shí)例
product2?=?Product(name?=?'華為400',?price?=?1999)
session.add_all([product1,product2?])????#?add_all把實(shí)例列表添加到數(shù)據(jù)庫(kù)

#?6、添加單條數(shù)據(jù)
product?=?Product(name?=?'一條',?price?=?9999)
session.add(product)


#?7、查詢數(shù)據(jù)

query_data?=?session.query(Product).all()???????#?查所有，如果不加__repr__,結(jié)果是內(nèi)存地址列表，使用for查看

for?i?in?query_data:
????#?查看結(jié)果
????print?(i.id,i.name,i.price)

#?8、修改一項(xiàng)數(shù)據(jù)
query_data?=?session.query(Product).filter(Product.name=='一條').first()
query_data.name?=?'yitiao'????????#?只改name一個(gè)數(shù)據(jù)

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


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

#?11、刪除一條數(shù)據(jù)：把華為開(kāi)頭的價(jià)格最高的一條數(shù)據(jù)刪掉
del_product?=?session.query(Product).fileter(Product.price.like('華為%'))).order_by(Product.price.desc()).first()
session.delete(del_product)

#?12、刪除所有符合條件的數(shù)據(jù)：
session.query(Product).filter(Product.name.like('華為%')).delete(synchronize_session?=?False)

?

?問(wèn)題集：https://blog.51cto.com/yishi/2335554

?