tornado框架基础06-SQLAlchemy连接数据库

01 ORM

在服务器后台,数据是要存储在数据库的,但是如果项目在开发和部署的时候,是使用的不同的数据库,该怎么办呢?是不是需要把所有的 SQL 语句都再重新写一遍呢?

和数据库相关,不同的数据库需要写不同的 SQL 语句

使用 ORM 隔离框架和数据库

ORM全称 Object Relational Mapping对象关系映射

通过 ORM 可以不用关心后台是使用的哪种数据库,只需要按照 ORM 所提供的语法规则去书写相应的代码, ORM 就会自动的转换成对应数据库的 SQL 语句 ,一个类对应一张一表.

02 SQLAlchemy连接数据库

第一步:安装

安装: mysql

安装python包: pymysql、sqlalchemy

pip安装 python 包

pip install -i https://pypi.douban.com/simple pymysql

pip install -i https://pypi.douban.com/simple sqlalchemy

这里是使用国内的源

第二步:导入模块

from sqlalchemy import create_engine

第三步:数据库数据

HOSTNAME = '127.0.0.1' #常量用大写

PORT = '3306'

DATABASE = 'mydb'

USERNAME = 'admin'

PASSWORD = 'pswd'

第四步:数据连接 URL

Db_Uri = 'mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8'.format(

USERNAME,PASSWORD,HOSTNAME,PORT,DATABASE)

第五步:连接数据库

engine = create_engine(Db_Uri)

第六步:测试连接

if __name__ == '__main__':

  connection = engine.connect() result = connection.execute('select 1') print(result.fetchone())

03 Module

第一步:创建 Module 的 Base 类

新建一个base.py文件.

from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base(engine)

对象关系型映射,数据库中的表与python中的类相对应,创建的类必须继承自 sqlalchemy 中的基类。

使用 declarative 方法定义的映射类依据一个基类,这个基类是维系类和数据表关系的目录。

应用通常只需要有一个 Base 的实例。我们通过 declarative_base() 功能创建一个基类。

第二步:创建 Module

新建一个user_module.py

from datetime import datetime

from sqlalchemy import Column, Integer, String, DateTime,Boolean

from connect import Base

class User(Base):

   --tablename-- = 'user'

   id = Column(Integer,primary_key=True,autoincrement=True)

   username = Column(String(20),nullable=False)

  password = Column(String(50))

   creatime = Column(DateTime,default=datetime.now)

  update_time = Column(DateTime,default = datetime.now()

  _locked = Colume(Boolean,default=False,nullable=False)

)

再次强调,我们用类来表示数据库里面的表!!!

这些表的类都继承于我们的Base基类。

在类里面我们定义一些属性,这个属性通过映射,就对应表里面的字段

第三步:启动 Module

Base.metadata.create_all()

执行此代码,就会把创建好的 Module 映射到数据库中

Module

--tablename--: 数据库中的表名

Column: 用来创建表中的字段的一个方法

Integer: 整形,映射到数据库中的int类型

String: 字符类型,映射到数据库中的varchar类型,使用时,需要提供一个字符长度

DateTime: 时间类型

通过 SQLAlchemy  提供的语法来声明表

04 增删改查

第一步:创建会话

from sqlalchemy.orm import sessionmaker

Session = sessionmaker(engine) #传入引擎

session = Session()

在对表数据进行增删改查之前,先需要建立会话,建立会话之后才能进行操作,就类似于文件要打开之后才能对文件内容操作

add

person = User(username='buodng', password='qwe123')

session.add(person)

session.commit()

session.add_all([

User(username='tuple', password=2),           User(username='which', password=3)

]) #加多条

add 是添加一条数据, add_all 添加多条数据

query

rows = session.query(User).all()

rows = session.query(User).first()

query 就是查询的意思,在 SQLAlchemy 中也用来查询数据

all 是查询所有的意思

first 是查询第一条数据

在后面会详细介绍更多的用法

update

rows = session.query(User).filter(User.username=='budong').update({User.password:1}) #修改值放到字典里面去.

session.commit()

update  用来更改数据

delete

rows = session.query(User).filter(User.username=='budong')[0]

#用filter查出来的是一条原生的SQL语句

print(rows)

session.delete(rows)

session.commit()

使用 delete 方法来删除数据

上一篇:【读书笔记】iOS-storyBoard-为一个按钮添加一个点击事件


下一篇:从构建分布式秒杀系统聊聊Disruptor高性能队列