链接:https://www.cnblogs.com/xiaoyuanqujing/articles/11715497.html#_label0

https://www.cnblogs.com/huchong/p/8274510.html

一.介绍

sqlalchmy是一个基于python实现的orm框架,使用关系对象映射进行数据库操作,简言之便是:将类和对象转换成SQL,然后使用数据API执行SQL并获取执行结果。

二.多种使用方式(能创建表,删除表,不能修改表)

前提安装

pip3 install sqlalchemy

1.第一种使用方式:执行原生sql(不常用,类似于pymysql)

sqlalchmy和Flask-SQLAlchemy ,flask-flask-migrate 项目依赖包
import time
import threading
import sqlalchemy
from sqlalchemy import create_engine
from sqlalchemy.engine.base import Engine

#引擎数据库连接池
engine = create_engine(
    # 数据库+连接方式://用户名:密码@ip:端口/数据库?编码
    "mysql+pymysql://root:123@127.0.0.1:3306/tset?charset=utf8",
    max_overflow=0,  # 超过连接池大小外最多创建的连接
    pool_size=5,  # 连接池大小
    pool_timeout=30,  # 池中没有线程最多等待的时间,否则报错
    pool_recycle=-1  # 多久之后对线程池中的线程进行一次连接的回收(重置)
)

# 任务函数
def task(arg):
    # 获取连接池
    conn = engine.raw_connection()
    # 产生游标
    cursor = conn.cursor()
    # 执行原生sql语句
    cursor.execute(
        "select * from user"
    )
    # 获取结果
    result = cursor.fetchall()
    print(result) # (1, '张三', 18), (2, '李四', 20))
    # 关闭游标和连接
    cursor.close()
    conn.close()

for i in range(20):
    t = threading.Thread(target=task, args=(i,))
    t.start()
第一种使用方式

相关文章:

  • 2022-12-23
  • 2022-01-16
  • 2021-12-02
  • 2022-01-22
  • 2022-02-09
猜你喜欢
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-03-07
  • 2022-12-23
  • 2021-06-30
  • 2021-06-17
相关资源
相似解决方案