西北乱跑娃 --- python with方法处理sqlalchemy回话连接超时问题

一、数据库问题

：

(sqlalchemy.exc.InvalidRequestError) Can't reconnect until invalid transaction is rolled back

二、代码设计

from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import create_engine

class DbManager:
    def __init__(self):
        self.databases = {'ENGINE': 'mysqlconnector', 'USER': 'root', 'PASSWORD': 'root', 'NAME': 'paytools', 'HOST': '127.0.0.1'}
        self.db_config = f'mysql+{self.databases["ENGINE"]}://{self.databases["USER"]}:{self.databases["PASSWORD"]}@{self.databases["HOST"]}/{self.databases["NAME"]}?charset=utf8mb4&autocommit=true'
        self.engine = create_engine(self.db_config, echo=True, pool_size=100, pool_recycle=3600)
        self.Session = sessionmaker(autocommit=False, autoflush=False, bind=self.engine)

    def create_session(self, status):
        db = self.Session()
        if status == 0:
            return db
        else:
            db.rollback()
            db.expire_all()
            self.engine.dispose()
            engine = create_engine(self.db_config, echo=True, pool_size=100, pool_recycle=3600)
            Session = sessionmaker(autocommit=False, autoflush=False, bind=self.engine)
            db = Session()
            return db

    def __enter__(self):
        print("connect access link...")
        try:
            return self.create_session(status=0)
        except:
            return self.create_session(status=1)

    def __exit__(self, exc_type, exc_val, exc_tb):
        print("close access link...")
        db = self.Session()
        db.close()


db_manage = DbManager()
def session():
    with db_manage as manager:
        return manager

engin = db_manage.engine
db = session()
Base = declarative_base()

print(db.execute("select * from psyorder").first())

三、查询效果

四、编者言

以上数据库管理方法是使用python的with方法操作sqlalchemy查询，

def __enter__(self):
    pass

def __exit__(self, exc_type, exc_val, exc_tb):
   	pass

这两个类内置方法，会在调用类方法自动先进入最后退出，with方法的理解可以参考with open():
最后，您有数据库连接、接口开发、爬虫开发，图像识别等需求，务必联系我哦！嘻嘻！

淘口令：

6€5fHXXlFLGOb€ https://m.tb.cn/h.4A1Q55J  我在闲鱼发布了【python程序开发（非中介）】

最后

以上就是沉静冰淇淋为你收集整理的西北乱跑娃 --- python with方法处理sqlalchemy回话连接超时问题的全部内容，希望文章能够帮你解决西北乱跑娃 --- python with方法处理sqlalchemy回话连接超时问题所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。