如何在python中使用SQLAlchemy對MySQL數(shù)據(jù)庫進行操作？很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細講解，有這方面需求的人可以來學習下，希望你能有所收獲。

成都創(chuàng)新互聯(lián)公司主營梓潼網(wǎng)站建設的網(wǎng)絡公司,主營網(wǎng)站建設方案,重慶APP開發(fā),梓潼h5小程序開發(fā)搭建,梓潼網(wǎng)站營銷推廣歡迎梓潼等地區(qū)企業(yè)咨詢

首先我們需要確認當前的Python環(huán)境下已經(jīng)安裝sqlalchemy和pymysql模塊。

新建表格

我們使用本地的MySQL數(shù)據(jù)庫，數(shù)據(jù)庫為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表結構如下：

數(shù)據(jù)插入

接著我們插入幾條測試數(shù)據(jù)，完整的代碼(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():
  # 初始化數(shù)據(jù)庫連接
  engine = create_engine("mysql+pymysql://root:@localhost:3306/orm_test", encoding="utf-8")
  # 創(chuàng)建DBSession類型
  DBSession = sessionmaker(bind=engine)

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

  # 插入多條數(shù)據(jù)
  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()

運行程序后，表格中的數(shù)據(jù)如下：

數(shù)據(jù)查詢

接下來演示如何進行簡單的查詢。我們需要查詢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():
  # 初始化數(shù)據(jù)庫連接
  engine = create_engine("mysql+pymysql://root:@localhost:3306/orm_test", encoding="utf-8")
  # 創(chuàng)建DBSession類型
  DBSession = sessionmaker(bind=engine)

  # 創(chuàng)建session對象
  session = DBSession()

  # 查詢所有place是CHN的人名
  # 創(chuàng)建Query查詢，filter是where條件
  # 調(diào)用one()返回唯一行，如果調(diào)用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',)]

數(shù)據(jù)更新

接下來我們演示數(shù)據(jù)更新。我們需要將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():
  # 初始化數(shù)據(jù)庫連接
  engine = create_engine("mysql+pymysql://root:@localhost:3306/orm_test", encoding="utf-8")
  # 創(chuàng)建DBSession類型
  DBSession = sessionmaker(bind=engine)

  # 創(chuàng)建session對象
  session = DBSession()

  # 數(shù)據(jù)更新，將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()

更新后的表格數(shù)據(jù)如下：

數(shù)據(jù)刪除

接著我們演示數(shù)據(jù)刪除。我們需要將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():
  # 初始化數(shù)據(jù)庫連接
  engine = create_engine("mysql+pymysql://root:@localhost:3306/orm_test", encoding="utf-8")
  # 創(chuàng)建DBSession類型
  DBSession = sessionmaker(bind=engine)

  # 創(chuàng)建session對象
  session = DBSession()

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

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


if __name__ == '__main__':
  delete_data()

運行程序后，表格中的數(shù)據(jù)如下：

看完上述內(nèi)容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注創(chuàng)新互聯(lián)成都網(wǎng)站設計公司行業(yè)資訊頻道，感謝您對創(chuàng)新互聯(lián)成都網(wǎng)站設計公司的支持。

另外有需要云服務器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務器、裸金屬服務器、網(wǎng)站設計器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。

名稱欄目：如何在python中使用SQLAlchemy對MySQL數(shù)據(jù)庫進行操作-創(chuàng)新互聯(lián)
標題來源：http://chinadenli.net/article38/cohcpp.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供電子商務、商城網(wǎng)站、響應式網(wǎng)站、微信小程序、網(wǎng)站制作、企業(yè)網(wǎng)站制作

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)