已完本玄幻小说排行榜,唐家三少

主頁 > 知識(shí)庫 > python實(shí)現(xiàn)sqlalchemy的使用概述

python實(shí)現(xiàn)sqlalchemy的使用概述

使用概述

在使用sqlalchemy訪問數(shù)據(jù)庫的時(shí)候，以類的形式表示表格，因此在使用之前，需要先定義類。

類的定義有三種：基類BASE、父類、子類

基類是sqlalchemy底層的；當(dāng)需要一份數(shù)據(jù)切分為多個(gè)子表的時(shí)候，或多個(gè)表的字段一致時(shí)，可以使用一個(gè)父類定義字段的類型，多個(gè)子表繼承父類的屬性。

一、創(chuàng)建引擎和會(huì)話

通過創(chuàng)建引擎、綁定引擎來創(chuàng)建會(huì)話，實(shí)現(xiàn)數(shù)據(jù)庫的訪問。

from sqlalchemy import create_engine                          # 引擎
from sqlalchemy.orm import sessionmaker                       # 創(chuàng)建orm的會(huì)話池，orm和sql均可以管理對(duì)象關(guān)系型數(shù)據(jù)庫，需要綁定引擎才可以使用會(huì)話，

# 創(chuàng)建連接
engine = create_engine("mysql+pymysql://root:1234;@127.0.0.1/test", # 需要安裝mysql和pymysql的模塊，用戶名:密碼@ip地址/某個(gè)數(shù)據(jù)庫
                       #echo=True,         # 打印操作對(duì)應(yīng)的SQL語句
                       pool_size=8,       # 連接個(gè)數(shù)
                       pool_recycle=60*30 # 不使用時(shí)斷開
                       )

# 創(chuàng)建session
DbSession = sessionmaker(bind=engine)  # 會(huì)話工廠，與引擎綁定。
session = DbSession()                  # 實(shí)例化

session.close()  # 關(guān)閉會(huì)話

二、定義類來表示虛擬表格

在使用sqlalchemy訪問數(shù)據(jù)庫的時(shí)候，以類的形式表示表格，因此在使用之前，需要先定義類。使用類的名稱而不是tablename實(shí)現(xiàn)之后的增刪改查。

# 導(dǎo)入定義類需要的模塊
from sqlalchemy.ext.declarative import declarative_base       # 調(diào)用sqlalchemy的基類
from sqlalchemy import Column, Index, distinct, update        # 指定字段屬性，索引、唯一、DML
from sqlalchemy.types import *                                # 所有字段類型

1. 直接建立一個(gè)可調(diào)用的表格

需要先繼承基類，在定義__init__函數(shù)，設(shè)置輸入?yún)?shù)。

# 創(chuàng)建庫表類型
Base = declarative_base()  # 調(diào)用sqlalchemy的基類

class Users(Base):
    '''繼承基類'''
    __tablename__ = "users"                     # 數(shù)據(jù)表的名字
    __table_args__ = {'extend_existing': True}  # 當(dāng)數(shù)據(jù)庫中已經(jīng)有該表時(shí)，或內(nèi)存中已聲明該表，可以用此語句重新覆蓋聲明。
    id = Column(Integer, primary_key=True)
    name = Column(String(64), unique=True)
    #email = Column(String(64))

    def __init__(self, name, email):
        self.name = name
        self.email = email                      # 聲明需要調(diào)用的特征，可以只聲明數(shù)據(jù)庫中表格列的子集
        
Base.metadata.create_all(engine)                # 表生效：將所有定義的類，使用引擎創(chuàng)建，此時(shí)可以在數(shù)據(jù)庫中看到這些表。

2. 創(chuàng)建多個(gè)相同列屬性的表格先建立一個(gè)表格的父類，指定列的屬性，再通過繼承父類

不同的表

# 創(chuàng)建庫表類型
Base = declarative_base()  # 調(diào)用sqlalchemy的基類

class model_data(BASE):  
    '''創(chuàng)建數(shù)據(jù)庫表類：模型所需的基本字段'''
    __abstract__ = True                         # 輔助sqlAlchemy實(shí)現(xiàn)類的繼承，自動(dòng)繼承屬性，省去super()
    __table_args__ = {'extend_existing': True}  # 若表的聲明在內(nèi)存中已存在，則重新聲明表的名稱，不然會(huì)報(bào)錯(cuò)
    ai_xdr_id = Column(BigInteger(), primary_key=True, unique=True, autoincrement= True)
    ai_sdk_id = Column(BigInteger())

class TrainData(model_data): # 訓(xùn)練集表
    '''繼承model_data的屬性，并將表的名字定義為：'xxx_train_data'存入數(shù)據(jù)庫 '''
    __tablename__ = 'xxx_train_data'
    
class DevData(model_data):   # 開發(fā)集表
    '''表的名字定義為：'xxx_dev_data' '''
    __tablename__ = 'xxx_dev_data'

class TestData(model_data):  # 測(cè)試集表
    __tablename__ = 'xxx_test_data'

Base.metadata.create_all(engine)                # 表生效：將所有定義的類，使用引擎創(chuàng)建，此時(shí)可以在數(shù)據(jù)庫中看到這些表。

三、增刪改查

因?yàn)槭菚?huì)話操作，當(dāng)某個(gè)語句，例如增加數(shù)據(jù)時(shí)，不成功的時(shí)候需要回滾。

增加數(shù)據(jù)

# 增加數(shù)據(jù)
add_user = Users("test3", "test123@qq.com")
session.add(add_user)
session.commit()

# add_users = Users(("test", "test123@qq.com"),('a','b')))
# session.add(add_users)
# session.commit()

# 當(dāng)上述語句出現(xiàn)執(zhí)行錯(cuò)誤時(shí)，需要執(zhí)行回滾語句，才能繼續(xù)操作
session.rollback()

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

delete_users = session.query(Users).filter(Users.name == "test").first()
if delete_users:
    session.delete(delete_users)
    session.commit()
    
session.query(Users).filter(Users.name == "test").delete()
session.commit()

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

# 改
session.query(Users).filter_by(id=1).update({'name': "Jack"})

users = session.query(Users).filter_by(name="Jack").first()
users.name = "test"

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

users = session.query(Users).filter_by(id=5).all()
for item in users:
    print(item.name)
    print(item.email)   # 若未在類中聲明，則無法訪問數(shù)據(jù)庫中該表的屬性。

四、進(jìn)階技能

1. 將DataFrame格式的數(shù)據(jù)導(dǎo)入數(shù)據(jù)庫

class DataAccessLayer:# 數(shù)據(jù)連接層、定義了連接和關(guān)閉。
    '''數(shù)據(jù)連接層、定義了連接和關(guān)閉。'''
    def __init__(self):
        self.ENGINE = None                 # 引擎
        self.SESSION = None                # 會(huì)話
        self.conn_string = "mysql+pymysql://root:1234;@127.0.0.1/test"  ## 需要安裝mysql和pymysql的模塊，用戶名:密碼@ip地址/某個(gè)數(shù)據(jù)庫

    def connect(self):
        '''連接時(shí)建立引擎和會(huì)話。'''
        self.ENGINE = create_engine(self.conn_string, encoding='utf-8',isolation_level="AUTOCOMMIT", connect_args={'connect_timeout': 7200})
        # self.ENGINE = create_engine(self.conn_string, encoding='utf-8',connect_args={'connect_timeout': 7200})
        self.SESSION = sessionmaker(bind=self.ENGINE)()

    def disconnect(self):
        '''斷開時(shí)，關(guān)閉引擎。'''
        self.ENGINE.close()

def df_save_db(df,tablename):
    '''將數(shù)據(jù)集DataFrame保存到數(shù)據(jù)庫'''
    db_ac = DataAccessLayer()
    db_ac.connect()
    conn = db_ac.ENGINE.connect()
    df.to_sql(name=tablename, con=conn, if_exists='append', index=False)
    conn.close()
    print('%s updated.'%tablename)

df = pd.read_csv('traindata_jiangsu_donghai.csv')
df_save_db(df,'traindata_jiangsu_donghai')

到此這篇關(guān)于python實(shí)現(xiàn)sqlalchemy的使用的文章就介紹到這了,更多相關(guān)python sqlalchemy使用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

python數(shù)據(jù)庫如何連接SQLite詳解
Python流行ORM框架sqlalchemy的簡單使用
python中的mysql數(shù)據(jù)庫LIKE操作符詳解
Python3 MySQL 數(shù)據(jù)庫連接的使用示例
python配置mssql連接的方法
python 操作sqlite數(shù)據(jù)庫的方法
適合Python項(xiàng)目的五大SQL連接器

標(biāo)簽：普洱林芝寧夏大同海南盤錦南平漯河

巨人網(wǎng)絡(luò)通訊聲明：本文標(biāo)題《python實(shí)現(xiàn)sqlalchemy的使用概述》，本文關(guān)鍵詞 python,實(shí)現(xiàn),sqlalchemy,的,使用,；如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題，煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們，我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò)，涉及言論、版權(quán)與本站無關(guān)。