sqlalchemy 学习(一)创建Session和Engine
2017-02-04 18:04
190 查看
基本概念
说到数据库,就离不开Session。Session的主要目的是建立与数据库的会话,它维护你加载和关联的所有数据库对象。它是数据库查询(Query)的一个入口。
在Sqlalchemy中,数据库的查询操作是通过Query对象来实现的。而Session提供了创建Query对象的接口。
Query对象返回的结果是一组同一映射(Identity Map)对象组成的集合。事实上,集合中的一个对象,对应于数据库表中的一行(即一条记录)。所谓同一映射,是指每个对象有一个唯一的ID。如果两个对象(的引用)ID相同,则认为它们对应的是相同的对象。
要完成数据库查询,就需要建立与数据库的连接。这就需要用到Engine对象。一个Engine可能是关联一个Session对象,也可能关联一个数据库表。
当然Session最重要的功能还是实现原子操作。
创建Session
代码第4行创建一个Engine对象,我们提供的参数是数据库连接的url。
代码第6行通过sessionmaker方法创建了一个Session工厂。
代码第8行通过调用工厂方法来创建一个Session对象。
Session的生命期
Session通常在我们需要对数据库进行操作时创建。
一旦一个Session创建成功,我们在这个Session下完成多个事务(transaction)。
究竟何时创建和关闭session,不能一概而论。但是一个原则是session不应该在操作事务的方法中创建。
例如下面的方法定义就是不规范的。
我们应该做如下改正。
class SomeThing(object):
def go(self, session):
# Do something
def run_my_program():
session = Session()
try:
SomeThing().go(session)
session.commit()
except:
session.rollback()
raise
finally:
session.close()
说到数据库,就离不开Session。Session的主要目的是建立与数据库的会话,它维护你加载和关联的所有数据库对象。它是数据库查询(Query)的一个入口。
在Sqlalchemy中,数据库的查询操作是通过Query对象来实现的。而Session提供了创建Query对象的接口。
Query对象返回的结果是一组同一映射(Identity Map)对象组成的集合。事实上,集合中的一个对象,对应于数据库表中的一行(即一条记录)。所谓同一映射,是指每个对象有一个唯一的ID。如果两个对象(的引用)ID相同,则认为它们对应的是相同的对象。
要完成数据库查询,就需要建立与数据库的连接。这就需要用到Engine对象。一个Engine可能是关联一个Session对象,也可能关联一个数据库表。
当然Session最重要的功能还是实现原子操作。
创建Session
from sqlalchemy import create_engine from sqlalchemy.orm import sessionmaker some_engine = create_engine('nysql://username:password@localhost/mydb?charset=utf8') ession = sessionmaker(bind=some_engine) session = Session()
代码第4行创建一个Engine对象,我们提供的参数是数据库连接的url。
代码第6行通过sessionmaker方法创建了一个Session工厂。
代码第8行通过调用工厂方法来创建一个Session对象。
Session的生命期
Session通常在我们需要对数据库进行操作时创建。
一旦一个Session创建成功,我们在这个Session下完成多个事务(transaction)。
究竟何时创建和关闭session,不能一概而论。但是一个原则是session不应该在操作事务的方法中创建。
例如下面的方法定义就是不规范的。
class SomeThing(object): def go(self): session = Session() try: # Do something session.commit() except: session.rollback() raise
我们应该做如下改正。
class SomeThing(object):
def go(self, session):
# Do something
def run_my_program():
session = Session()
try:
SomeThing().go(session)
session.commit()
except:
session.rollback()
raise
finally:
session.close()
相关文章推荐
- Tomcat源码学习--Session创建销毁
- Struts学习笔记:request,session,application的创建
- Struts2.0学习笔记--Session的创建和使用方法
- Python ORM框架SQLAlchemy学习笔记之映射类使用实例和Session会话介绍
- mybatis底层原理学习(一):SqlSessionFactory和SqlSession的创建过程
- 创建session学习-request.getSession()
- mybatis源码学习之执行过程分析(1)——SqlSessionFactory及SqlSession的创建
- [AndEngine学习教程] 第2节 使用AndEngine.jar创建工程
- spark学习-55-源代码:SparkSession的的创建
- 工作流Activiti的学习总结(二)activiti中ProcessEngine的创建和数据库表命名规则
- 创建session学习-request.getSession()
- python-SQLAlchemy之Engine、Connection、Session
- [AndEngine学习教程] 第2节 使用AndEngine.jar创建工程
- 创建session学习-request.getSession()
- mybatis学习笔记 - SqlSessionFactory的创建
- [原创]java WEB学习笔记31:会话与状态管理 session机制 概述(定义,session机制,session的声明周期,保存session的方式,Session的创建与删除)
- sqlalchemy学习(三):创建数据库表格
- php学习笔记(二十六)创建session
- (转)[AndEngine学习教程] 第2节 使用AndEngine.jar创建工程
- Hadoop-1.2.1学习之Job创建和提交源码分析