一、SQLAlchemy簡介 SQLAlchemy是Python SQL工具包和對象關係映射器，是python中最著名的ORM(Object Relationship Mapping)框架，它簡化了應用程式開發人員在原生SQL上的操作，使開發人員將主要精力都放在程式邏輯上，從而提高開發效率。它提供了 ...
一、SQLAlchemy簡介
SQLAlchemy是Python SQL工具包和對象關係映射器，是python中最著名的ORM(Object Relationship Mapping)框架，它簡化了應用程式開發人員在原生SQL上的操作，使開發人員將主要精力都放在程式邏輯上，從而提高開發效率。它提供了一整套著名的企業級持久性模式，設計用於高效和高性能的資料庫訪問。
使用ORM操作資料庫：
優勢 ：代碼易讀，隱藏底層原生SQL語句，提高了開發效率。
劣勢 ：執行效率低 ，將方法轉換為原生SQL後 原生SQL不一定是最優的。
環境：
Windows 7 x64 python 3.7.1 SQLAlchemy 1.3.5 pymysql 0.9.3 mysqld 5.6.43
關於如何安裝上述環境，這裡不做演示，相信大家能搜到這篇文章，想必這種小問題不在話下。
二、簡單的操作
1、準備資料庫sql_demo
mysql> create database sql_demo;
2、在sql_demo中創建表
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column, Integer, String from sqlalchemy import create_engine Base = declarative_base() # 導出官方基礎類 class SQLDemo(Base): __tablename__ = 'SqlDemo' # 表名 # 創建欄位 id = Column(Integer,primary_key=True,autoincrement=True) name = Column(String(32)) # 創建資料庫引擎 engine = create_engine('mysql+pymysql://資料庫用戶:資料庫密碼@127.0.0.1:3306/資料庫名?charset=utf8') # 創建表 Base.metadata.create_all(engine)
運行上面的代碼後會在資料庫sql_demo中創建一個名為sqldemo的表。
3、向表中添加數據。
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column, Integer, String from sqlalchemy import create_engine from sqlalchemy.orm import sessionmaker Base = declarative_base() # 導出官方基礎類 class SQLDemo(Base): __tablename__ = 'SqlDemo' # 表名 # 創建欄位 id = Column(Integer,primary_key=True,autoincrement=True) name = Column(String(32)) # 創建資料庫引擎 engine = create_engine('mysql+pymysql://root:[email protected]:3306/sql_demo?charset=utf8') # 創建表 # Base.metadata.create_all(engine) # 向表中添加數據 obj = SQLDemo(name='小明') # 創建會話 obj_session = sessionmaker(engine) # 打開會話 db_session = obj_session() # 向表中添加數據,此時數據保存在記憶體中 db_session.add(obj) # 提交數據，將數據保存到資料庫中 db_session.commit() # 關閉會話 db_session.close()
3.1向表中添加多條數據。
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column, Integer, String from sqlalchemy import create_engine from sqlalchemy.orm import sessionmaker Base = declarative_base() # 導出官方基礎類 class SQLDemo(Base): __tablename__ = 'SqlDemo' # 表名 # 創建欄位 id = Column(Integer,primary_key=True,autoincrement=True) name = Column(String(32)) # # 創建資料庫引擎 engine = create_engine('mysql+pymysql://root:[email protected]:3306/sql_demo?charset=utf8') # # 創建表 # Base.metadata.create_all(engine) # 添加多條數據 obj = [ SQLDemo(name='小紅'), SQLDemo(name='小剛'), SQLDemo(name='小虎'), ] # 創建會話 obj_session = sessionmaker(engine) # 打開會話 db_session = obj_session() # 向表中添加數據,此時數據保存在記憶體中 db_session.add_all(obj) # 提交數據，將數據保存到資料庫中 db_session.commit()向表中添加多條數據
添加後的數據如下：
4、查詢表中數據
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column, Integer, String from sqlalchemy import create_engine from sqlalchemy.orm import sessionmaker Base = declarative_base() # 導出官方基礎類 class SQLDemo(Base): __tablename__ = 'SqlDemo' # 表名 # 創建欄位 id = Column(Integer,primary_key=True,autoincrement=True) name = Column(String(32)) # # 創建資料庫引擎 engine = create_engine('mysql+pymysql://root:[email protected]:3306/sql_demo?charset=utf8') # 創建會話 obj_session = sessionmaker(engine) # 打開會話 db_session = obj_session() # 查詢表中所有數據 all_list = db_session.query(SQLDemo).all() for obj in all_list: print(obj.id,obj.name) # 提交數據，將數據保存到資料庫中 db_session.commit() # 關閉會話 db_session.close()
最終列印結果如下：
4.1使用filter過濾查詢條件
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column, Integer, String from sqlalchemy import create_engine from sqlalchemy.orm import sessionmaker Base = declarative_base() # 導出官方基礎類 class SQLDemo(Base): __tablename__ = 'SqlDemo' # 表名 # 創建欄位 id = Column(Integer,primary_key=True,autoincrement=True) name = Column(String(32)) # # 創建資料庫引擎 engine = create_engine('mysql+pymysql://root:[email protected]:3306/sql_demo?charset=utf8') # 創建會話 obj_session = sessionmaker(engine) # 打開會話 db_session = obj_session() # 使用filter過濾查詢條件 all_list = db_session.query(SQLDemo).filter(SQLDemo.name=='小明') for obj in all_list: print(obj.id,obj.name) # 提交數據，將數據保存到資料庫中 db_session.commit() # 關閉會話
5、 修改數據
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column, Integer, String from sqlalchemy import create_engine from sqlalchemy.orm import sessionmaker Base = declarative_base() # 導出官方基礎類 class SQLDemo(Base): __tablename__ = 'SqlDemo' # 表名 # 創建欄位 id = Column(Integer,primary_key=True,autoincrement=True) name = Column(String(32)) # 創建資料庫引擎 engine = create_engine('mysql+pymysql://root:[email protected]:3306/sql_demo?charset=utf8') # 創建會話 obj_session = sessionmaker(engine) # 打開會話 db_session = obj_session() # 更改id是2的name為娃哈哈 all_list = db_session.query(SQLDemo).filter(SQLDemo.id==2).update({'name':'娃哈哈'}) # 提交數據，將數據保存到資料庫中 db_session.commit() # 關閉會話 db_session.close()
6、刪除數據
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column, Integer, String from sqlalchemy import create_engine from sqlalchemy.orm import sessionmaker Base = declarative_base() # 導出官方基礎類 class SQLDemo(Base): __tablename__ = 'SqlDemo' # 表名 # 創建欄位 id = Column(Integer,primary_key=True,autoincrement=True) name = Column(String(32)) # # 創建資料庫引擎 engine = create_engine('mysql+pymysql://root:[email protected]:3306/sql_demo?charset=utf8') # 創建會話 obj_session = sessionmaker(engine) # 打開會話 db_session = obj_session() # 刪除id是2的行 all_list = db_session.query(SQLDemo).filter(SQLDemo.id==2).delete() # 提交數據，將數據保存到資料庫中 db_session.commit() # 關閉會話 db_session.close()
好了SQLAlchemy先簡單介紹這裡，關於SQLAlchemy的一些高級操作待更新。。。。。
