一.SQLAlchemy
1.sqlalchemy是一个ORM框架,它本身无法操作数据库,需要依赖pymysql.MySQLdb,mssql等第三方插件
2.安装:
pip install SQLAlchemy
二.基本示例
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
'''
create_engine() 会返回一个数据库引擎,
mysql+pymysql”指定了使用 pymysql 来连接,
使用用户名test和密码123456来链接数据库
127.0.0.1是数据库链接地址
test是数据库名
max_overflow是最大连接数
其他方法:
“charset”指定了连接时使用的字符集(可省略)=utf8
echo 参数为 True 时,会显示每条执行的 SQL 语句,生产环境下可关闭。
'''
engine = create_engine('mysql+pymysql://test:[email protected]/test', max_overflow=5)
DBSession = sessionmaker(bind=engine)
session = DBSession()
class Test(Base):
__tablename__ = 'test'
id = Column(Integer, primary_key=True)
name = Column(String(100))
# 增加数据
test = Test(name='102')
# 增加一个
session.add(test)
# 增加多个
session.add_all([test])
session.commit()
# 查询数据
test = session.query(Test).filter_by(id=224).first()
print(test.name, test.id)
# 删除数据
test = session.query(Test).filter_by(id=225).delete()
session.commit()
# 更新数据
session.query(Test).filter_by(id=224).update({'name': 5000})
session.query(Test).filter(Test.id>224).update({'name': 5000})
session.commit()
# 关闭连接
session.close()