python使用SQLAlchemy操作MySQL

發布時間: 2020-01-02 17:26:58 來源: 互聯網 欄目: Mysql 點擊:

這篇文章主要介紹了python使用SQLAlchemy操作MySQL,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧

SQLAlchemy是Python編程語言下的一款開源軟件,提供了SQL工具包及對象關系映射(ORM)工具,使用MIT許可證發行。SQLAlchemy首次發行于2006年2月,并迅速地在Python社區中最廣泛使用的ORM工具之一,不亞于Django的ORM框架。

本文將介紹如何使用SQLAlchemy操作MySQL,完成基礎的表創建,表格數據的新增、查詢、修改、刪除(CRUD)等操作。

首先我們需要確認當前的Python環境下已經安裝sqlalchemy和pymysql模塊。

新建表格

我們使用本地的MySQL數據庫,數據庫為orm_test。新建一張users表,字段為id,name,age,place。完整的Python代碼(create_table.py)如下:

# -*- coding: utf-8 -*-
# author: Jclian91
# place: Sanya, Hainan
# time: 12:46

from sqlalchemy.dialects.mysql import INTEGER, VARCHAR
from sqlalchemy import Column
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()


# users表結構
class Users(Base):
  __tablename__ = 'users'

  id = Column(INTEGER, primary_key=True)
  name = Column(VARCHAR(256), nullable=False)
  age = Column(INTEGER)
  place = Column(VARCHAR(256), nullable=False)


  def __init__(self, id, name, age, place):
    self.id = id
    self.name = name
    self.age = age
    self.place = place

def init_db():
  engine = create_engine(
    "mysql+pymysql://root:@localhost:3306/orm_test",
    encoding= "utf-8",
    echo=True
  )
  Base.metadata.create_all(engine)
  print('Create table successfully!')

if __name__ == '__main__':
  init_db()

運行后,生成的users表結構如下:

數據插入

接著我們插入幾條測試數據,完整的代碼(db_insert.py)如下:

# -*- coding: utf-8 -*-
# author: Jclian91
# place: Sanya, Hainan
# time: 12:52

from create_table import Users
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

def insert_data():
  # 初始化數據庫連接
  engine = create_engine("mysql+pymysql://root:@localhost:3306/orm_test", encoding="utf-8")
  # 創建DBSession類型
  DBSession = sessionmaker(bind=engine)

  # 創建session對象
  session = DBSession()
  # 插入單條數據
  # 創建新User對象
  new_user = Users(id=1, name='Jack', age=25, place='USA')
  # 添加到session
  session.add(new_user)
  # 提交即保存到數據庫
  session.commit()

  # 插入多條數據
  user_list= [Users(id=2, name='Green', age=26, place='UK'),
        Users(id=3, name='Alex', age=31, place='GER'),
        Users(id=4, name='Chen', age=52, place='CHN'),
        Users(id=5, name='Zhang', age=42, place='CHN')
        ]
  session.add_all(user_list)
  session.commit()
  # 關閉session
  session.close()
  print('insert into db successfully!')

if __name__ == '__main__':
  insert_data()

運行程序后,表格中的數據如下:

數據查詢

接下來演示如何進行簡單的查詢。我們需要查詢place為CHN的人名,完整的Python代碼(db_query)如下:

# -*- coding: utf-8 -*-
# author: Jclian91
# place: Sanya, Hainan
# time: 12:52

from create_table import Users
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

def query_data():
  # 初始化數據庫連接
  engine = create_engine("mysql+pymysql://root:@localhost:3306/orm_test", encoding="utf-8")
  # 創建DBSession類型
  DBSession = sessionmaker(bind=engine)

  # 創建session對象
  session = DBSession()

  # 查詢所有place是CHN的人名
  # 創建Query查詢,filter是where條件
  # 調用one()返回唯一行,如果調用all()則返回所有行:
  users = session.query(Users).filter(Users.place == 'CHN').all()
  print([use.name for use in users])
  # 輸出:['Chen', 'Zhang']

  # 或者用如下查詢
  users = session.query(Users.name).filter(Users.place == 'CHN').all()
  print(users)
  # 輸出:[('Chen',), ('Zhang',)]

  session.close()


if __name__ == '__main__':
  query_data()

輸出結果如下:

['Chen', 'Zhang']
[('Chen',), ('Zhang',)]

數據更新

接下來我們演示數據更新。我們需要將Jack的place修改為CHN,完整的Python代碼(db_update)如下:

# -*- coding: utf-8 -*-
# author: Jclian91
# place: Sanya, Hainan
# time: 12:52

from create_table import Users
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

def update_data():
  # 初始化數據庫連接
  engine = create_engine("mysql+pymysql://root:@localhost:3306/orm_test", encoding="utf-8")
  # 創建DBSession類型
  DBSession = sessionmaker(bind=engine)

  # 創建session對象
  session = DBSession()

  # 數據更新,將Jack的place修改為CHN
  update_obj = session.query(Users).filter(Users.name=='Jack').update({"place":"CHN"})
  session.commit()

  session.close()
  print("Update data successfully!")


if __name__ == '__main__':
  update_data()

更新后的表格數據如下:

數據刪除

接著我們演示數據刪除。我們需要將Jack的記錄刪除,完整的Python代碼(db_delete.py)如下:

# -*- coding: utf-8 -*-
# author: Jclian91
# place: Sanya, Hainan
# time: 12:52

from create_table import Users
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

def delete_data():
  # 初始化數據庫連接
  engine = create_engine("mysql+pymysql://root:@localhost:3306/orm_test", encoding="utf-8")
  # 創建DBSession類型
  DBSession = sessionmaker(bind=engine)

  # 創建session對象
  session = DBSession()

  # 數據更新,將Jack的記錄刪除
  update_obj = session.query(Users).filter(Users.name=='Jack').delete()
  session.commit()

  session.close()
  print("Delete data successfully!")


if __name__ == '__main__':
  delete_data()

運行程序后,表格中的數據如下:

本次分享到此結束,感謝大家閱讀~

本文的示例代碼已經上傳至Github,網址為:https://github.com/percent4/ORM_test。

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持我們。

本文標題: python使用SQLAlchemy操作MySQL
本文地址: http://www.1921352.live/shujuku/mysql/296859.html

如果認為本文對您有所幫助請贊助本站

支付寶掃一掃贊助微信掃一掃贊助

  • 支付寶掃一掃贊助
  • 微信掃一掃贊助
  • 支付寶先領紅包再贊助
    聲明:凡注明"本站原創"的所有文字圖片等資料,版權均屬編程客棧所有,歡迎轉載,但務請注明出處。
    mybatis統計每條SQL的執行時間的方法示例mysql外鍵的三種關系實例詳解
    Top 网上挖矿机赚钱