threadsafety都为1所有值无论设置为多少_maxcached永远为0所以永远是所有链接都共享。

blockingTrue,

连接池中如果没有可用连接后是否阻塞等待。

True等待False不等待然后报错maxusageNone,

一个链接最多被重复使用的次数None表示无限制setsession[],

ping

MySQL服务端检查是否服务可用。

host127.0.0.1,port3306,userroot,password123,databaseluffy,charsetutf8)-第二步:使用from

sql_pool

conn.cursor()curser.execute(select

from

id2)rescurser.fetchall()print(res)实例

from

conn.cursor()curser.execute(select

from

老版本基于flask-script新版本基于flask-click写的###

使用步骤-1

Flask(__name__)app.cli.command(create-user)

click.argument(name)

conn.commit()print(name)app.route(/)

def

app.config.from_mapping(config)

cache

内置信号--》flask请求过程中--》源码中定义的---》不需要我们定义和触发---》只要写了函数跟它对应--》执行到这就会触发函数执行

Flask框架中的信号基于blinker其主要就是让开发者可是在flask请求过程中定制一些用户行为request_started

_signals.signal(request-started)

请求到来前执行

_signals.signal(request-finished)

_signals.signal(before-render-template)

模板渲染前执行

_signals.signal(template-rendered)

_signals.signal(got-request-exception)

请求执行出现异常时执行request_tearing_down

_signals.signal(request-tearing-down)

请求执行完毕后自动执行无论成功与否

_signals.signal(appcontext-tearing-down)#

应用上下文执行完毕后自动执行无论成功与否appcontext_pushed

_signals.signal(appcontext-pushed)

应用上下文push时执行

_signals.signal(appcontext-popped)

应用上下文pop时执行

_signals.signal(message-flashed)

调用flask在其中添加数据时自动触发#

**kwargs):print(args)print(kwargs)#

谁ip

访问了哪个页面(template)print(记录日志模板要渲染了)#

跟内置信号绑定

before_render_template.connect(before_render)

源码中触发信号执行(我们不需要动)

render_template(index.html)app.route(/login)

def

**kwargs):print(args)print(kwargs)print(表数据插入了)#

跟自定义置信号绑定

render_template(index.html)app.route(/create_article)

def

conn.cursor()cursor.execute(insert

into

手动触发信号db_save.send(table_namearticle,info{title:测试测试标题,author:测试作者测试})return

插入成功if

**kwargs):print(args)print(kwargs)print(表数据插入了)#

跟自定义置信号绑定

需要在代码中写可以传参数传入的参数--》db_save_fun

能拿到sqlalchemy原生操作

create_engine(mysqlpymysql://root:1234127.0.0.1:3306/cnblogs,

max_overflow0,

池中没有线程最多等待的时间否则报错pool_recycle-1

使用引擎拿到链接

cursorconn.cursor(pymysql.cursors.DictCursor)

from

conn.cursor()cursor.execute(select

from

cursor.fetchall()print(result)cursor.close()conn.close()for

range(20):t

args(i,))t.start()sqlalchemy操作表

models.py

datetime.datetime.now不能加括号加了括号以后永远是当前时间ctime

Column(DateTime,

defaultdatetime.datetime.now)extra

Column(Text)#

create_engine(mysqlpymysql://root:123456127.0.0.1:3306/sqlalchemy01,max_overflow0,

连接池大小pool_timeout30,

池中没有线程最多等待的时间否则报错pool_recycle-1

3.2

Base.metadata.create_all(engine)

3.3

create_engine(mysqlpymysql://root:1234127.0.0.1:3306/sqlalchemy01,max_overflow0,

连接池大小pool_timeout30,

池中没有线程最多等待的时间否则报错pool_recycle-1

orm操作--》借助于

resconn.query(User).filter_by(id1).all()

print(res)##

conn.query(User).filter_by(namelqz).delete()

print(res)

resconn.query(User).filter_by(name9999).update({extra:xxsss})

一对一只需要关联字段加上

hobby指的是tablename而不是类名uselistFalse#

Column(Integer,

create_engine(mysqlpymysql://root:123456127.0.0.1:3306/sqlalchemy01,max_overflow0,

连接池大小pool_timeout30,

池中没有线程最多等待的时间否则报错pool_recycle-1

)Session

简便方式增加person---》增加Person直接新增Hobby

hobby1

session.query(Person).filter_by(name彭于晏).first()

print(per)

hobbysession.query(Hobby).filter_by(caption乒乓球).first()

print(hobby)#

hobbysession.query(Hobby).filter_by(caption乒乓球).first()

print(hobby.pers)

与生成表结构无关仅用于查询方便,放在哪个单表中都可以--等同于manytomanygirls

relationship(Girl,

create_engine(mysqlpymysql://root:123456127.0.0.1:3306/sqlalchemy01,max_overflow0,

连接池大小pool_timeout30,

池中没有线程最多等待的时间否则报错pool_recycle-1

3.2

把表模型同步到数据库中Base.metadata.create_all(engine)#

3.3

Base.metadata.drop_all(engine)#

视图类中

create_engine(mysqlpymysql://root:123456127.0.0.1:3306/sqlalchemy01,max_overflow0,

连接池大小pool_timeout30,

池中没有线程最多等待的时间否则报错pool_recycle-1

)Session

session.query(Boy).filter_by(name张小勇).first()

girlsession.query(Girl).filter_by(name张亦菲).first()

print(girl.boys)#

session.add_all([boy,boy2,boy3])

session.commit()#

session.query(Users).filter_by(id1).delete()

2.1

session.query(User).filter_by(id1).first()

session.delete(user)

session.query(Boy).filter_by(id1).update({name:lqz})

session.commit()#

session.query(Boy).filter_by(id4).update({Boy.name:lqz1})

session.commit()#

session.query(User).filter_by(id2).update({name:User.name_nb},synchronize_sessionFalse)

字符串拼接

session.query(User).filter_by(id2).update({id:User.id6},

数字之间加

boysession.query(Boy).filter_by(id1).first()

boy.namexxzzyy