python orm 框架中sqlalchemy用法例項詳解
阿新 • • 發佈：2020-02-03
本文例項講述了python orm 框架中sqlalchemy用法。分享給大家供大家參考，具體如下：
一.ORM簡介
1. ORM(Object-Relational Mapping,物件關係對映):作用是在關係型資料庫和業務實體物件之間做一個對映.
2. ORM優點:
向開發者遮蔽了資料庫的細節,使開發者無需與SQL語句打交道,提高了開發效率;
便於資料庫的遷移,由於每種資料庫的SQL語法有差別,基於Sql的資料訪問層在更換資料庫時通過需要花費時間除錯SQL時間,而ORM提供了獨立於SQL的介面,ORM的引擎會處理不同資料庫之間的差異,所以遷移資料庫時無需更改程式碼.
應用快取優化等技術有時可以提高資料庫操作的效率.
3. SQLALchemy:是python中最成熟的ORM框架,資源和文件很豐富,大多數python web框架對其有很好的主持,能夠勝任大多數應用場合,SQLALchemy被認為是python事實上的ORM標準.
二、程式碼
1.建表
"""
Created on 19-10-22
@author: apple
@description:建表
"""
import pymysql
server = '127.0.0.1'
user = 'root'
# dev
password = '123456'
conn = pymysql.connect(server,user,password,database='DataSave') # 獲取連線
cursor = conn.cursor() # 獲取遊標
# "**ENGINE=InnoDB DEFAULT CHARSET=utf8**"-建立表的過程中增加這條，中文就不是亂碼
# 建立表
cursor.execute ("""
CREATE TABLE if not exists lamp_result(
result_id INT NOT NULL auto_increment primary key,product_number VARCHAR(100),record_time VARCHAR(100),lamp_color INT NOT NULL,detect_result VARCHAR(100),old_pic_path VARCHAR(100),result_pic_path VARCHAR(100)
)
ENGINE=InnoDB DEFAULT CHARSET=utf8mb4
""")
# 查詢資料
cursor.execute('SELECT * FROM lamp_result')
row = cursor.fetchone()
print(row)
# cursor.execute("INSERT INTO user VALUES('%d','%s','%s')" % ('xiaoming','qwe','ming','@163.com'))
# 提交資料，才會寫入表格
conn.commit()
# 關閉遊標關閉資料庫
cursor.close()
conn.close()
2. 資料儲存
""" Created on 19-10-22 @author: apple @requirement:Anaconda 4.3.0 (64-bit) Python3.6 @description:資料儲存 """ from sqlalchemy.exc import SQLAlchemyError from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column,String,Integer,create_engine from sqlalchemy.orm import sessionmaker Base = declarative_base() # 連線資料庫 # alter table students convert to character set utf8; conn = "mysql+pymysql://root:[email protected]:3306/DataSave" engine = create_engine(conn,encoding='UTF8',echo=False) # echo=True 列印日誌 # 建立session物件 Session = sessionmaker(bind=engine) session = Session() # 資料庫表模型ORM class DataSaveSystem(Base): """ 員工自助資訊採集系統 """ __tablename__ = 'lamp_result' # 定義表名 # 定義列名 result_id = Column(Integer,primary_key=True,autoincrement=True,nullable=False) product_number = Column(String(50),nullable=True) record_time = Column(String(50),nullable=False) lamp_color = Column(Integer,nullable=False) detect_result = Column(String(100),nullable=False) old_pic_path = Column(String(100),nullable=False) result_pic_path = Column(String(100),nullable=False) def __repr__(self): """ 引用該類別，輸出結果 :return: """ return str(self.__dict__) # return '<detect_result:{}>'.format(self.detect_result) # 插入資料 def insert_to_db(product_number=None,record_time=None,lamp_color=None,detect_result=None,old_pic_path=None,result_pic_path=None): ''' :param product_number: 產品編號 :param record_time: 取原圖時間 :param lamp_color: 燈的顏色:1 2 3 4 :param detect_result: 檢測結果 :param old_pic_path: 原圖路徑 :param result_pic_path: 結果圖路徑 :return: 資料是否寫入成功 ''' information_system_instance = DataSaveSystem( product_number=product_number,record_time=record_time,lamp_color=lamp_color,detect_result=detect_result,old_pic_path=old_pic_path,result_pic_path=result_pic_path) # session.add_all([ # lamp_result(id=2,name="張2",age=19),# lamp_result(id=3,name="張3",age=20) # ]) session.add(information_system_instance) try: session.commit() # 嘗試提交資料庫事務 # print('資料庫資料提交成功') return { "code": 200,"status": True,"message": "寫入資料庫成功",} except SQLAlchemyError as e: session.rollback() print(e) return { "code": 500,"status": False,"message": str(e) } # url = "mysql+pymysql://root:[email protected]:3306/DataSave" # # echo為True時，列印sql,可用於除錯 # engine = create_engine(url,echo=False,encoding='utf-8',pool_size=5) # sessionClass = sessionmaker(bind=engine) # # 建立會話 # session = sessionClass() # # 查所有,並排序 # stuList = session.query(DataSaveSystem).order_by(DataSaveSystem.result_id).all() # print(stuList) # stu = DataSaveSystem(product_number='id1',record_time='20191022170400',lamp_color='1',detect_result='ok',old_pic_path='picture/',result_pic_path='d') # session.add(stu) stuList = [DataSaveSystem(product_number='id1',result_pic_path='d'),DataSaveSystem(product_number='id1',result_pic_path='d')] # session.add_all(stuList) # session.commit() # print('資料成功') if __name__ == '__main__': result = insert_to_db(stu) print(result)
3.資料函式呼叫
""" Created on 19-10-31 @author: apple @requirement:Anaconda 4.3.0 (64-bit) Python3.6 @description:調取函式基類 """ from data_sql.airconditioning_lamp_datasave.datasave import DataSaveSystem from sqlalchemy.exc import SQLAlchemyError from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column,create_engine from sqlalchemy.orm import sessionmaker Base = declarative_base() # 連線資料庫 # alter table students convert to character set utf8; conn = "mysql+pymysql://root:[email protected]:3306/DataSave" engine = create_engine(conn,echo=False) # echo=True 列印日誌 # 建立session物件 Session = sessionmaker(bind=engine) session = Session() stuList = [DataSaveSystem(product_number='id1',result_pic_path='F'),result_pic_path='F')] session.add_all(stuList) session.commit() print('資料成功') # # 根據主建查詢資料 # result = session.query(DataSaveSystem).get(3) # print(result.old_pic_path) # # 查詢第一條 # result = session.query(DataSaveSystem).first() # print(result) #列印物件屬性 # 查詢表關鍵字的資料 result = session.query(DataSaveSystem).filter_by(result_pic_path='a/').first() print(result) #修改 session.query(DataSaveSystem).filter(DataSaveSystem.result_pic_path=='a/').update({"detect_result":"不合格"}) session.commit()
更多關於Python相關內容感興趣的讀者可檢視本站專題：《Python常見資料庫操作技巧彙總》、《Python數學運算技巧總結》、《Python資料結構與演算法教程》、《Python函式使用技巧總結》、《Python字串操作技巧彙總》、《Python入門與進階經典教程》及《Python檔案與目錄操作技巧彙總》
希望本文所述對大家Python程式設計有所幫助。