sqlalchemy连接mysql_Python的SQLalchemy模块连接与操作MySQL的基础示例

# 1. 导入模块

from sqlalchemy import *

from sqlclchemy.orm import *

# 2. 建立数据库引擎

mysql_engine &＃61; create_engine("$address", echo, module)

#address 数据库://用户名:密码(没有密码则为空)&＃64;主机名&＃xff1a;端口/数据库名

#echo标识用于设置通过python标准日志模块完成的SQLAlchemy日志系统&＃xff0c;当开启日志功能&＃xff0c;我们将能看到所有的SQL生成代码

# 3. 设置metadata并将其绑定到数据库引擎

metadata &＃61; Metadata(mysql_engine)

# 4. 定义需新建的表

users &＃61; Table(&＃39;users&＃39;, metadata,Column(&＃39;user_id&＃39;, Integer, primary_key&＃61;True),

Column(&＃39;name&＃39;, String(40)),

Column(&＃39;age&＃39;, Integer),

Column(&＃39;password&＃39;, String),)

#Table实现方式与SQL语言中的CRETE TABLE类似

# 5. 在数据库中创建表

metadata.create_all(mysql_engine)

#向数据库发出CREATE TABLE命令&＃xff0c;由此数据库新建名为users的表

#调用时会检查已经存在的表结构&＃xff0c;因此可重复调用

# 6. 创建一个与数据库中的users表匹配的python类

class user():

def __int__(self, name, fullname, password):

self.name &＃61; name

self.fullname &＃61; fullname

self.passwd &＃61; passwd

#python类的属性需与users表的列名一致

# 7. 设置映射

from sqlalchemy.orm import mapper

mapper(user, users)

# mapper()创建一个新的Mapper对象&＃xff0c;与定义的类相关联

#需要注意的是&＃xff0c;通过mapper建立映射的数据表必须带有主键&＃xff0c;如果没有主键就无法定位某个table的某行row,

#如果无法定位某行row, 就无法做Object-relational mapping这样的映射

# 8. 创建session

Session &＃61; sessionmaker(bind&＃61;mysql_egnine)

session &＃61; Session()

#由此我们只需对python的user类的操作&＃xff0c;后台数据库的具体实现交由session完成

# 9. 执行

session.commit()

#实现与数据库的交互

# 10. 查询

usr_info &＃61; session.query(user).filter_by(age&＃61;12).first()

#返回数据库中年纪12岁的第一条数据

上面结合SQLAlchemy中ORM部分实现一个Mapper对象&＃xff0c;将类的实例对应表中的记录&＃xff0c;实例的属性对应字段。实现一个Data Mapping需要三个元素&＃xff1a;Tabella Metadata, user-defined class, mapper对象&＃xff0c;这三个是实现对象对表映射的基本元素&＃xff0c;在此基础上&＃xff0c;可实现一对多的映射&＃xff0c;实现类似多表查询的问题

首先创建两个相关联的表Student, Score&＃xff0c;表Score中以主表的id字段为外键

Student &＃61; Table(&＃39;student&＃39;, engine,

column(‘id&＃39;, Interger, primary_key &＃61; True),

column(&＃39;name&＃39;, String, nullable&＃61;False),

column(&＃39;age&＃39;, Interger)

)

Score &＃61; Table(&＃39;score&＃39;, engine,

column(&＃39;id&＃39;, Integer, primary_key&＃61;True),

column(&＃39;student_id&＃39;, Integer, ForeignKey(student.id))

column(&＃39;category&＃39;, String, nullable&＃61;False),

column(&＃39;score&＃39;, Integer)

)

两表中&＃xff0c;Score表以Student表中id项为外键&＃xff0c;一般称Student表为主表&＃xff0c;Score表为从表

表创建好后&＃xff0c;那同样&＃xff0c;在python中需定义两个与表相对应的类

class student_type(object):

def __init__(self):

self.name &＃61; None

class score_type(object):

def __init__(self):

self.category &＃61; None

在建立mapping时&＃xff0c;我们只需要体现两个表间又相互关联关系&＃xff0c;

并不关心表中具体的主键与外键等关系(由SQLAlchemy处理)&＃xff0c;

当需要体现表student与表score间的关联关系&＃xff0c;mapper具体的定义方法如&＃xff1a;

mapper(student_type, student, properties&＃61;{&＃39;_scores&＃39;: relation(score_type, Score)})

通过properties中参数&＃xff0c;实现score_type 与Score的映射&＃xff0c;

由此可以通过访问student中的&＃39;_scores&＃39;属性来查询Score表中的值

另外&＃xff0c;properties是一个字典&＃xff0c;可以添加多个属性&＃xff0c;SQLAlchemy中有些模块如backref, 也可导入

综上&＃xff0c;使用关系映射可以方便地从一个对象直接找到相对应的其他的对象