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:123456@127.0.0.1/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()