Python的數據庫操作（Sqlalchemy）

ORM 全稱 Object Relational Mapping, 翻譯過來叫對象關系映射。簡單的說，ORM 將數據庫中的表與面向對象語言中的類建立了一種對應關系。這樣，我們要操作數據庫，數據庫中的表或者表中的一條記錄就可以直接通過操作類或者類實例來完成。

SQLAlchemy 是Python 社區最知名的 ORM 工具之一，為高效和高性能的數據庫訪問設計，實現了完整的企業級持久模型。支持多數據庫，如mysql、Oracle等

安裝：

pip3 install sqlalchemy

使用步驟：

 
 
 
         l   
  
  
  
          建立數據庫連接

 
 
 
         l   
  
  
  
          描述表結構（如果表不存在則會新建表）

 
 
 
         l   
  
  
  
          得到數據庫操作游標（會話session）

 
 
 
         l   
  
  
  
          操作數據表，提供了兩種方法，分別為原生SQL語句操作（execute）和類方式操作

通過原生SQL語句操作

#導入必要模塊
from sqlalchemy import create_engine

#得到連接對象
#參數：mysql+pymysql://用戶名:密碼@地址/數據庫名
#添加參數 echo=True 表示打印日志到控制台
connal = create_engine("mysql+pymysql://root2:proot2@192.168.1.175/dongdb",encoding='utf-8')

#查詢
resselect=connal.execute("select * from tb_dong")
print(resselect.rowcount) #輸出查詢到的值
print(resselect.fetchall()) #輸出列表數據

#插入，輸出影響行數
resinsert=connal.execute("insert into tb_dong(namex,sex) values('%s','%s')"%("東小東xx","F")).rowcount
print(resinsert)

類方式操作

描述表結構時：

設置為主鍵【primary_key=True】、

是否可為空【nullable=False】、

外鍵【ForeignKey(“另一個表名.字段名”)】 #表名與字段名的點不可去掉

#導入必要模塊
import sqlalchemy
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy.orm import sessionmaker


#-------------得到連接對象--------------------
#參數：mysql+pymysql://用戶名:密碼@地址/數據庫名
#添加參數 echo=True 表示打印日志到控制台
connal = create_engine("mysql+pymysql://root2:proot2@192.168.1.175/dongdb",
                       encoding='utf-8')

#----------------創建表，描述表結構-----------------------
#得到基類
classal = declarative_base()
class tb_dong3(classal):
    __tablename__ = "tb_dong3"  # 表名為 tb_dong3
    id = Column(Integer, primary_key=True)  # 設置列為主鍵，默認不可為空且自增
    name = Column(String(15))
    password = Column(String(15))

    def __repr__(self):
        return "<id=%s ; name=%s ; password=%s>"%(self.id,self.name,self.password)

#提交創建表命令
classal.metadata.create_all(connal)

#------------------ 游標獲取  ------------------

#得到數據庫游標
cousession=sessionmaker(bind=connal)()

#--------------------插入數據------------------
#設置要插入的數據
dataobj1=tb_dong3(name="dong",password="dongpp東1")
dataobj2=tb_dong3(name="dong",password="dongpp東2")

#添加數據，參數可為列表：add([dataobj1, dataobj1])
cousession.add(dataobj1)
cousession.add(dataobj2)

#提交數據
cousession.commit()

#--------------------查詢數據---------------------
#filter(tb_dong3.id>1)為條件查詢
#多條件查詢可以使用多個 filter 拼接
#查詢所有：all()  查詢一個：first()  計數：count()
resdata=cousession.query(tb_dong3).filter(tb_dong3.id>0).filter(tb_dong3.name=="dong").all() #查詢所有
print(resdata) #輸出全部查詢結果
#print(cousession.query(tb_dong3).filter(tb_dong3.id>0).filter(tb_dong3.name=="dong").count()) #查詢所有
print(len(resdata)) #得到查詢結果的數量,相當於上面一句
print(resdata[0].name) #取出name值

#-----------------  更新--------------------------
#先查詢，然后賦值，然后提交
resupdate=cousession.query(tb_dong3).filter(tb_dong3.id==3).first()
resupdate.name="ddddddddd"
resupdate.password="xxxxxx"
cousession.commit()

#-------------------  刪除  -----------------------
resdel=cousession.query(tb_dong3).filter(tb_dong3.id==73).first()
cousession.delete(resdel)
cousession.commit()

連表操作：

重點在於需要描述兩張表

#導入必要模塊
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy.orm import sessionmaker


#-------------得到連接對象--------------------
#參數：mysql+pymysql://用戶名:密碼@地址/數據庫名
#添加參數 echo=True 表示打印日志到控制台
connal = create_engine("mysql+pymysql://root2:proot2@192.168.1.175/dongdb",
                       encoding='utf-8')

#----------------創建表，描述表結構-----------------------
#得到基類
classal = declarative_base()
#建立tb_dong3表描述
class tb_dong3(classal):
    __tablename__ = "tb_dong3"  # 表名為 tb_dong3
    id = Column(Integer, primary_key=True)  # 設置列為主鍵，默認不可為空且自增
    name = Column(String(15))
    password = Column(String(15))

    def __repr__(self):
        return "<id=%s ; name=%s ; password=%s>"%(self.id,self.name,self.password)

#建立tb_dong2表描述
class tb_dong2(classal):
    __tablename__ = "tb_dong2"  # 表名為 tb_dong3
    id = Column(Integer, primary_key=True)  # 設置列為主鍵，默認不可為空且自增
    name = Column(String(10))
    sex = Column(String(1))

    def __repr__(self):
        return "<id=%s ; name=%s ; sex=%s>"%(self.id,self.name,self.sex)

#提交創建表命令
classal.metadata.create_all(connal)

#------------------ 游標獲取  ------------------

#得到數據庫游標
cousession=sessionmaker(bind=connal)()

#-------------------- 連表查詢 ---------------------
#tb_dong3.name==tb_dong2.name 兩表的name字段值相等
#得到單表數據（tb_dong2）
#resdata=cousession.query(tb_dong2).filter(tb_dong3.id>0).filter(tb_dong3.name==tb_dong2.name).all()
#輸出兩張表的數據（tb_dong2,tb_dong3）
resdata=cousession.query(tb_dong2,tb_dong3).filter(tb_dong3.id>0).filter(tb_dong3.name==tb_dong2.name).all()
print(resdata) #輸出全部查詢結果
print(len(resdata)) #得到查詢結果的數量,相當於上面一句
print(resdata[0][0].name) #取出name值