python3使用SQLAlchemy操作数据库

/

软硬件环境

  • Windows 10
  • Python 3.5.1
  • mysql 5.6
  • sqlalchemy

前言

前文python3中的mysql数据库操作已经介绍过利用pymysql来操作mysql数据库,本文介绍一个ORM框架SQLAlchemy,它可以帮助我们更加优雅、更加高效的实现数据库操作,而且还不限于mysql。

什么是ORM

ORM即Object Rational Mapping,对象关系映射。百度百科中是这样解释的

对象-关系映射(OBJECT RELATIONAL MAPPING,简称ORM),是随着面向对象的软件开发方法发展而产生的。用来把对象模型表示的对象映射到基于SQL的关系模型数据库结构中去。这样,我们在具体的操作实体对象的时候,就不需要再去和复杂的SQL语句打交道,只需简单的操作实体对象的属性和方法。ORM技术是在对象和关系之间提供了一条桥梁,前台的对象型数据和数据库中的关系型的数据通过这个桥梁来相互转化。

用一句话来概括就是,把关系数据库的表结构映射到对象上。操作对象的属性就等于操作数据库中的记录。

SQLAlchemy实践

在写代码之前,我们先准备下数据库,这里还是以mysql为例,其它的数据库也类似,可以参靠sqlalchemy的官方文档。利用mysql-workbench图形化工具创建,表结构如下图所示,

sqlalchemy_01

接下来,安装相关的工具包

  1. pip3 install mysql-connector
  2. pip3 install pymsql
  3. pip3 install sqlalchemy

最后来写代码

  1. # -*- coding: utf-8 -*-
  2. """
  3. @version: ??
  4. @author: djstava
  5. @license: MIT Licence
  6. @contact: [email protected]
  7. @site: http://www.xugaoxiang.com/blog
  8. @software: PyCharm
  9. @file: SQLAlchemy.py
  10. @time: 2017/3/22 10:42
  11. """
  12. from sqlalchemy import Column, String, create_engine
  13. from sqlalchemy.orm import sessionmaker
  14. from sqlalchemy.ext.declarative import declarative_base
  15. # 创建对象的基类:
  16. Base = declarative_base()
  17. # 定义Channel对象:
  18. class Channel(Base):
  19. # 表名
  20. __tablename__ = 'playback'
  21. # 表结构
  22. id = Column(String(20),primary_key=True)
  23. channel_name = Column(String(45))
  24. address = Column(String(80))
  25. service_name = Column(String(45))
  26. def __init__(self,id,channel_name,address,service_name):
  27. self.id = id
  28. self.channel_name = channel_name
  29. self.address = address
  30. self.service_name = service_name
  31. # 初始化数据库连接,:
  32. engine = create_engine('mysql+mysqlconnector://root:[email protected]:3306/troutling')
  33. # 创建DBSession类型:
  34. DBSession = sessionmaker(bind=engine)
  35. session = DBSession()
  36. # 增操作,增加3条记录
  37. item1 = Channel(id='1',channel_name='catv1',address='http://10.10.10.188/catv1',service_name='news')
  38. session.add(item1)
  39. item2 = Channel(id='2',channel_name='catv2',address='http://10.10.10.188/catv2',service_name='sports')
  40. session.add(item2)
  41. item3 = Channel(id='3',channel_name='catv3',address='http://10.10.10.188/catv3',service_name='economics')
  42. session.add(item3)
  43. session.commit()
  44. session.close()
  45. # 查操作
  46. session1 = DBSession()
  47. channel = session1.query(Channel).filter(Channel.id < '4').all()
  48. for i in range(len(channel)):
  49. print(channel[i].id)
  50. print(channel[i].channel_name)
  51. print(channel[i].address)
  52. print(channel[i].service_name)
  53. session1.close()
  54. # 改操作,将id为2的记录的service_name字段修改为movie
  55. session2 = DBSession()
  56. session2.query(Channel).filter(Channel.id == '2').update({Channel.service_name: 'movie'}, synchronize_session=False)
  57. session2.commit()
  58. session2.close()
  59. ## 查看修改结果
  60. session3 = DBSession()
  61. print('\n')
  62. print(session3.query(Channel).filter(Channel.id == '2').one().service_name)
  63. session3.close()
  64. # 删操作,删除id为3的记录
  65. session4 = DBSession()
  66. session4.query(Channel).filter(Channel.id == '3').delete()
  67. session4.commit()
  68. session4.close()

执行上述脚本得到

  1. D:\tools\python3.5.1\python.exe D:/workshop/github/ffmpegWrapper/SQLAlchemy.py
  2. 1
  3. catv1
  4. http://10.10.10.188/catv1
  5. news
  6. 2
  7. catv2
  8. http://10.10.10.188/catv2
  9. sports
  10. 3
  11. catv3
  12. http://10.10.10.188/catv3
  13. economics
  14. movie
  15. Process finished with exit code 0

然后用mysql-workbench查看数据库

sqlalchemy_02

数据库中的记录跟代码要实现的意图完全相符。

参考资料

  1. http://www.sqlalchemy.org/
  2. http://www.liaoxuefeng.com/wiki/0014316089557264a6b348958f449949df42a6d3a2e542c000/0014320114981139589ac5f02944601ae22834e9c521415000
  3. http://baike.baidu.com/link?url=enj6JgEqdyte0DLpJqBAfiKusns6yL3-MHU8pW6_j14sa0yAvuTtC3DMlkHKbasHOti50UbcSLxljOVm5w6fV_

转载请注明作者和出处,并添加本页链接。
原文链接: http://xugaoxiang.com/post/21

给我留言