sqlchemy

     　　　　　　　　　　　　　     session

    直接上代码，创建表结构，初始化部分数据。

from sqlalchemy import create_engine

engine = create_engine("mysql+pymysql://root:max123@127.0.0.1/test?charset=utf8", echo=True)

from sqlalchemy import *
from sqlalchemy.orm import relationship
from sqlalchemy.ext.declarative import declarative_base
from datetime import datetime, date
from sqlalchemy.orm import deferred
Base = declarative_base()


class Parent(Base):
    __tablename__ = 'parent'

    id = Column(Integer(), primary_key=True)
    name = Column(String(50))
    summary = deferred(Column(Text))
    children = relationship('ParentChild', back_populates='parent', cascade='all,delete-orphan')


class Child(Base):
    __tablename__ = 'child'

    id = Column(Integer(), primary_key=True)
    name = Column(String(50))
    parents = relationship('ParentChild', back_populates='child')


class ParentChild(Base):
    __tablename__ = 'parent_child'

    id = Column(Integer(), primary_key=True)
    child_id = Column(Integer(), ForeignKey('child.id'), nullable=False)
    parent_id = Column(Integer(), ForeignKey('parent.id'), nullable=False)
    description = Column(String(100))

    parent = relationship('Parent', back_populates='children')
    child = relationship('Child', back_populates='parents')


Base.metadata.drop_all(engine)
Base.metadata.create_all(engine)


from sqlalchemy.orm import sessionmaker

Session = sessionmaker(bind=engine)

db = Session()

child_one = Child(name='purk1')
child_two = Child(name='purk2')
child_three = Child(name='purk3')
child_four = Child(name='purk4')
parent_one = Parent(name='Wu1')
parent_two = Parent(name='Wu2')
parent_child_one = ParentChild(description='association one')
parent_child_two = ParentChild(description='association two')
parent_child_one.child = child_one
parent_child_two.child = child_two
parent_one.children.extend([parent_child_one, parent_child_two])

db.add_all([parent_one, parent_two, child_four])
db.commit()

   由简入难的开始

1. update

parent_one = db.query(Parent).filter_by(name='wu1').first()
parent_one.name='wu_test'
db.merge(parent_one)   # update or insert
db.commit()

parent_one = db.query(Parent).filter_by(name='wu1').first()
parent_one.name='wu_test'
db.bulk_save_objects([parent_one])
db.commit()

 结果

 

 2. add

parent_three =Parent(name='Wu3')
db.add(parent_three)
db.commit()

parent_three =Parent(name='Wu3')
db.add_all([parent_three])
db.commit()

parent_three =Parent(name='Wu3')
db.merge(parent_three)
db.commit()

parent_three =Parent(name='Wu3')
db.bulk_save_objects([parent_three])
db.commit()

上面四种方式都可以得到下面的结果。

 3. delete

db.delete(parent_two)
db.commit()

 parent_two 被删除了。

 

4. select

查的内容就是涉及到query了，留到下一章节来讲。

注：

class sqlalchemy.orm.session.Session(bind=None, autoflush=True, expire_on_commit=True,_enable_transaction_accounting=True, autocom-mit=False, twophase=False,

weak_identity_map=True,binds=None, extension=None, info=None,query_cls=<class ‘sqlalchemy.orm.query.Query’>)

的expire_on_commit的配置，默认是True

parent = db.query(Parent).filter_by(name='wu1').first()

现在还没有做db.commit()的操作，访问parent的name属性，结果如下。

现在我做一个后台操作，直接数据库里面修改这parent实例对应的记录。

 

现在数据已经变为了wu_test,显然现在parent.name的值还是'Wu1'，现在我在执行下面的代码。当我再次使用parent的时候，parent重新获取了一次数据。

只在commit和rollback的时候才是这样，close的时候是不会的。同时这个特性就要注意了。