一, sqlalchemy 与数据库连接
安装：
pip install sqlalchemy
sqlalchemy 查看版本：
import sqlalchemy
sqlalchemy.__version__
sqlalchemy 连接数据库：
from sqlalchemy import create_engine
HOST='127.0.0.1'
PORT='3306'
DATABASE='test'
USERNAME='test'
PASSWORD='pass'
DB_URL = 'mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8'.format(
USERNAME, PASSWORD, HOST, PORT, DATABASE
)
engin = create_engine(DB_URL, echo=False)
sqlalchemy创建表的简单过程：
1. 创建一个基类
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base(）
2. 创建一个类
from sqlalchemy import Column, Integer, String
class User(Base):
__tablemame__ = 'users' # 数据表的名子
id = Column(Integer, Sequence('user_id_seq'), Primary_key=True) # 设置为主键
name = Column(String(20), nullable=False) #非空
password = Column(String(255), nullable=False)
创建表：
Base.metadata.create_all(engine)
创建一个对象
zs_user = User(name='zs', fullname='ZhangSan', password='password')
zs.name
zs
创建 Session
from sqlalchemy.orm import sessionmaker
Session = sessionmaker(bind=engine)
添加更新对象
将 zs_user 对象添加到会话中
session.add(zs_user)
通过条件查询
zs = session.query(User).filter_by(name='zs').first()
可以使用 add_all() 函数一次性添加多个User 对象、
session.add_all(
User(name='ls', fullname='lisi', password='pass'),
User(name='ww', fullname='wangwu', password='pass'),
)
查看等待提交的状态：
session.new
将更改提交到数据库：
session.commit()
本文转自 tianshuai369 51CTO博客，原文链接:http://blog.51cto.com/songqinglong/1939828
