# 导入:
import traceback

from sqlalchemy import create_engine
from sqlalchemy.exc import NoResultFound
from sqlalchemy.orm import sessionmaker, scoped_session

# 初始化数据库连接:
import thread_pool
from models import TChat

engine = create_engine('mysql+mysqlconnector://root:123456@localhost:3306/gitchat',
                       max_overflow=0,  # 超过连接池大小外最多创建的连接
                       pool_size=120,  # 连接池大小
                       pool_timeout=30,  # 池中没有线程最多等待的时间，否则报错
                       pool_recycle=-1  # 多久之后对线程池中的线程进行一次连接的回收（重置）
                       )
# 创建DBSession类型:
SessionFactory = sessionmaker(bind=engine)
DBSession = scoped_session(SessionFactory)

def one(i):
    print('申请到' + str(i))
    db_session = DBSession()
    try:
        s = db_session.query(TChat).filter(TChat._id == '1').one()
    except NoResultFound as e:
        print(e)
    db_session.commit()
    db_session.close()


if __name__ == '__main__':
    for i in range(100):
        thread_pool.global_thread_pool.executor.submit(one, i)

    while True:
        pass