链接: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)
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()