sqlalchemy连接数据库

王茂南

2478
文章

75
评论

2018年4月30日06:32:55

评论2 1555字阅读5分11秒

摘要这一篇文章会介绍一些关于sqlalchemy来连接mysql和sqlite，并且一些测试是否连接成功的方法。

这一篇文章记录一下使用sqlalchemy进行数据库的连接，以及连接之后的一些简单测试（测试是否连接成功）。

文章目录(Table of Contents)

连接sqlite

连接数据库的URL形式:
sqlite:/// + 文件路径

接下来看两个例子：

'sqlite:////tmp/test.db'
文件路径为：/tmp/test.db，这是一个绝对路径
---
'sqlite:///tmp/test.db'
文件路径为： tmp/test.db，这是一个相对路径

测试连接

当连接好数据库之后，我们可以使用下面的方法来测试一下是否连接成功

from sqlalchemy import create_engine
# 连接数据库
engine = create_engine('sqlite:///app.db',echo=True)
# 执行查询语句
users = engine.execute('select * from users')
# 打印查询的内容
for user in users:
print(user)

接下来，我们看一下使用session(Session 是映射类和数据库沟通的桥梁，包含事务管理功能)来进行一些操作的代码实现

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
# 链接数据库
engine = create_engine('sqlite:///app.db',echo=True)
# 创建session
Session = sessionmaker(bind=engine)
session = Session()
# 进行查找
name = session.query(Contact).filter(Contact.name=='myname').first()
print(name)

连接mysql

上面是关于连接sqlite，下面讲一下连接mysql，其实具体的方法和上面讲得差不多，我们再来叙述一下。

首先是测试数据库是否连接成功

In[1]: from sqlalchemy import create_engine
In[2]: engine = create_engine("mysql://root:root@localhost:3306/datbasename?charset=utf8",encoding="utf-8", echo=True)
In[6]: users = engine.execute('select * from users')
2018-03-21 20:56:09,419 INFO sqlalchemy.engine.base.Engine select * from users
2018-03-21 20:56:09,421 INFO sqlalchemy.engine.base.Engine ()
In[7]: for i in users:
   ...:     print(i)

接下来使用session来进行一些操作：

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
engine = create_engine("mysql://root:root@localhost:3306/datbasename?charset=utf8",encoding="utf-8", echo=True)
# 创建session
Session = sessionmaker(bind=engine)
session = Session()
names = session.query(User).all()
for name in names:
print(name.user_login)