资源描述：
《PythonSQLAlchemy基本操作和常用技巧.docx》由会员上传分享，免费在线阅读，更多相关内容在工程资料-天天文库。
1、使用SQLAlchemy871次阅读数据库表是一个二维表，包含多行多列。把一个表的内容用Python的数据结构表示出来的话，可以用一个list表示多行，list的每一个元素是tuple，表示一行记录，比如，包含id和name的user表：[('1','Michael'),('2','Bob'),('3','Adam')]Python的DB-API返回的数据结构就是像上面这样表示的。但是用tuple表示一行很难看出表的结构。如果把一个tuple用class实例来表示，就可以更容易地看出表的结构来：classUser(object):def__ini
2、t__(self,id,name):self.id=idself.name=name[User('1','Michael'),User('2','Bob'),User('3','Adam')]这就是传说中的ORM技术：Object-RelationalMapping，把关系数据库的表结构映射到对象上。是不是很简单？但是由谁来做这个转换呢？所以ORM框架应运而生。在Python中，最有名的ORM框架是SQLAlchemy。我们来看看SQLAlchemy的用法。首先通过easy_install或者pip安装SQLAlchemy：$easy_insta
3、llsqlalchemy然后，利用上次我们在MySQL的test数据库中创建的user表，用SQLAlchemy来试试：第一步，导入SQLAlchemy，并初始化DBSession：#导入:fromsqlalchemyimportColumn,String,create_enginefromsqlalchemy.ormimportsessionmakerfromsqlalchemy.ext.declarativeimportdeclarative_base#创建对象的基类:Base=declarative_base()#定义User对象:clas
4、sUser(Base):#表的名字:__tablename__='user'#表的结构:id=Column(String(20),primary_key=True)name=Column(String(20))#初始化数据库连接:engine=create_engine('mysql+mysqlconnector://root:password@localhost:3306/test')#创建DBSession类型:DBSession=sessionmaker(bind=engine)以上代码完成SQLAlchemy的初始化和具体每个表的clas
5、s定义。如果有多个表，就继续定义其他class，例如School：classSchool(Base):__tablename__='school'id=...name=...create_engine()用来初始化数据库连接。SQLAlchemy用一个字符串表示连接信息：'数据库类型+数据库驱动名称://用户名:口令@机器地址:端口号/数据库名'你只需要根据需要替换掉用户名、口令等信息即可。sessionmaker()会生成一个数据库会话类。这个类的实例可以当成一个数据库连接，它同时还记录了一些查询的数据，并决定什么时候执行SQL语句。由于SQL
6、Alchemy自己维护了一个数据库连接池（默认5个连接），因此初始化一个会话的开销并不大。对其他Web服务器来说，可以使用sqlalchemy.orm.scoped_session，它能保证每个线程获得的session对象都是唯一的。拿到session后，就可以执行SQL了。declarative_base()创建了一个BaseModel类，这个类的子类可以自动与一个表关联。以User类为例，它的__tablename__属性就是数据库中该表的名称，它有id和name这两个字段下面，我们看看如何向数据库表中添加一行记录。由于有了ORM，我们向数据
7、库表中添加一行记录，可以视为添加一个User对象：#创建session对象:session=DBSession()#创建新User对象:new_user=User(id='5',name='Bob')#添加到session:session.add(new_user)#提交即保存到数据库:session.commit()#关闭session:session.close()可见，关键是获取session，然后把对象添加到session，最后提交并关闭。Session对象可视为当前数据库连接。如何从数据库表中查询数据呢？有了ORM，查询出来的可以不再是
8、tuple，而是User对象。SQLAlchemy提供的查询接口如下：#创建Session:session=DBSession()#创建
