加入收藏 | 设为首页 | 会员中心 | 我要投稿 核心网 (https://www.hxwgxz.com/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 编程 > 正文

数据库运作必读 SQLAlchemy入门

发布时间:2022-03-29 12:18:49 所属栏目:编程 来源:互联网
导读:环境 :Ubuntu 15.10 64-bit SQLAlchemy是Python的ORM框架,它的理念是:数据库的量级和性能重要于对象集合,而对象集合的抽象又重要于表和行。 安装 直接通过pip安装: $ pip install sqlalchemy 打开Python,测试是否安装成功: import sqlalchemy sqlalch
        环境 :Ubuntu 15.10 64-bit
 
       SQLAlchemy是Python的ORM框架,它的理念是:数据库的量级和性能重要于对象集合,而对象集合的抽象又重要于表和行。
 
       安装
      直接通过pip安装:
 
     $ pip install sqlalchemy
     打开Python,测试是否安装成功:
 
     >>> import sqlalchemy>>> sqlalchemy.__version__'1.0.9'
创建引擎
SQLite
 
MySQL
再来看看连接MySQL时怎么创建引擎。 本文后续示例全部基于MySQL,这是与官方文档不同的地方。 先在MySQL里创建一个测试数据库:sa_test,后续示例都将基于这个数据库。
 
创建表
创建两张表,user和address,address表里有一个user id的外键。 注意:表名没有像官方文档及很多人推荐的那样使用复数形式,个人偏好而已,详细讨论请见StackOverflow的这个问题: Table NamingDilemma: Singular vs. Plural Names
 
from sqlalchemy import create_engine, MetaData,        Table, Column, Integer, String, ForeignKeyengine = create_engine('mysql+mysqldb://root:******@localhost/sa_test', echo=True)metadata = MetaData(engine)
user_table = Table('user', metadata,        Column('id', Integer, primary_key=True),        Column('name', String(50)),        Column('fullname', String(100))        )address_table = Table('address', metadata,        Column('id', Integer, primary_key=True),        Column('user_id', None, ForeignKey('user.id')),        Column('email', String(128), nullable=False)        )metadata.create_all()
执行完metadata.create_all()这一句,两张表就创建好了,可以在MySQL里立即查看。
 
user_table.create(checkfirst=True)address_table.create(checkfirst=True)
这里忽略了bind参数,因为创建MetaData对象时已经绑定了引擎,而创建表对象时又传入了metadata,所以顺藤摸瓜,表自己是知道引擎的。 如果调整一下表的创建顺序,就会报错,因为address表里有一个user表的外键,而这时候user表还没创建呢。所以,还是建议使用MetaData.create_all()吧,毕竟它也会检查表是否已经存在。
 
from sqlalchemy import create_engine, MetaData, Tableengine = create_engine('mysql+mysqldb://root:******@localhost/sa_test', echo=False)metadata = MetaData(engine)address_table = Table('address', metadata, autoload=True)print 'user' in metadata.tablesprint 'address' in metadata.tables
输出:
 
TrueTrue
插入数据
插入数据之前,必须要有表对象,不管是新创建的,还是通过反射导入的。
 
ins = ins.values(name='adam', fullname='Adam Gu')print ins
限制后,id列已经没有了:
 
INSERT INTO user (name, fullname) VALUES (%s, %s)
可见values()方法限制了INSERT语句所包含的列。但是我们指定的name和fullname的值并没有打印出来,这两个值保存在Insert对象里,只有等到执行时才会用到。
 
执行
我们一直在说的引擎,可以理解成一个数据库连接对象的仓库,通过连接对象可以往数据库发送具体的SQL语句。调用引擎的connect()方法可以获取一个连接:
 
conn = engine.connect()
现在把前面的Insert对象丢给它来执行:
 
result = conn.execute(ins)
由调试信息可见具体的INSERT语句:
 
INSERT INTO user (name, fullname) VALUES (%s, %s)('adam', 'Adam Gu')COMMIT
返回值result是一个ResultProxy对象,ResultProxy是对DB- API中cursor的封装。插入语句的结果并不常用,但是查询语句肯定是要用到它的。 不妨在MySQL里看一下刚插入的数据。
 
conn.execute(address_table.insert(), [    { 'user_id': 1, 'email': 'sprinfall@gmail.com' },    { 'user_id': 1, 'email': 'sprinfall@hotmail.com' },    ])
调试信息里具体的INSERT语句:
 
INSERT INTO address (user_id, email) VALUES (%s, %s)((1, 'sprinfall@gmail.com'), (1, 'sprinfall@hotmail.com'))COMMIT
在MySQL里看一下插入的地址:
 
mysql> select * from address;+----+---------+-----------------------+| id | user_id | email                 |+----+---------+-----------------------+|  1 |       1 | sprinfall@gmail.com   ||  2 |       1 | sprinfall@hotmail.com |+----+---------+-----------------------+2 rows in set (0.00 sec)

(编辑:核心网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    热点阅读