SQLAlchemy簡介

1、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

關於如何安裝上述環境，這裏不作演示，相信你們能搜到這篇文章，想必這種小問題不在話下。

2、簡單的操做

一、準備數據庫sql_demo

mysql> create database sql_demo;

二、在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的表。

 三、向表中添加數據。

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:123@127.0.0.1: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:123@127.0.0.1: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()

向表中添加多條數據

 添加後的數據以下：

 四、查詢表中數據

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:123@127.0.0.1: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:123@127.0.0.1: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()
# 關閉會話

 

五、 修改數據

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:123@127.0.0.1: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()

 六、刪除數據

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:123@127.0.0.1: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的一些高級操做待更新。。。。。