【Python模塊】sqlalchemy orm模塊--基礎（連接數據庫，建表，增刪改查）

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

?

連接數據庫：

from?sqlalchemy?import?create_engine
engine?=?create_engine("mysql+pymysql://root:a13896321z@127.0.0.1/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)

#?常用的類型：
類型名????????python類型????????????說明
Integer???????int????????????????普通整數，32位????
Float?????????float??????????????浮點數????
String????????str????????????????變長字符串????
Text??????????str????????????????變長字符串，對較長字符串做了優化????
Boolean???????bool???????????????布爾值????
PickleType????任何python對象??????自動使用Pickle序列化

字段的選項：

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

autoincrement=True,?#?數值自增

default='red'???????#?指定默認值

primary_key?=?True??#?設為主鍵

ForeignKey?=?'table_name.id'????#?指定外鍵，ForeignKey需要導入

unique?=?True???????#?設定此字段鍵值唯一，不允許出現重復值。
)

?

建立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()???????????????#?提交到數據庫，最終對數據庫更改。

表的參數__table_args__：

__table_args__:參數需要導入。

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

?增、查、改、刪：

這四個操作都需要導入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)

?

?問題集：https://blog.51cto.com/yishi/2335554

?