一、orm框架的概念
orm全称为对象关系映射(object relational mapping),是一种将关系型数据库表与python对象之间进行映射,从而实现开发者在编程过程中不再需要进行sql语句操作的技术, orm框架在python中的应用,为开发者提供了更多选择,使得程序开发更加便捷。
二、databases框架
databases是由django orm的开发者andrew goodwin所开发的一款简洁的orm框架,其最大特点就是轻量级,以及方便、易于使用,而且支持多种数据库,包括mysql、postgresql、sqlite和microsoft sql server等多种类型的数据库。
安装databases框架针对databases框架的安装,可以使用pip进行安装,命令如下:
pip install databases==0.4.*
连接数据库在使用databases框架进行开发之前,需要先连接到数据库中。连接数据库所需参数包括数据库类型、主机名、数据库名称、用户名和密码等。本次开发中,我们尝试连接到mysql数据库中,代码如下:
import databasesdatabase_url = "mysql://user:password@hostname/database_name"database = databases.database(database_url)
这里,qaqsaaspassword是连接数据库的密码,askdnsadn312as是连接数据库的用户名,localhost是数据库所在的主机名或ip地址,my_database是数据库的名称。
创建表格与列databases框架支持sql表达式语言来创建复杂的查询语句,从而使得开发者能够更灵活的控制sql执行过程。在databases框架中,我们可以使用table类来创建表格,使用column类来创建列。
表格创建代码如下:
import sqlalchemymetadata = sqlalchemy.metadata()users = sqlalchemy.table( "users", metadata, sqlalchemy.column("id", sqlalchemy.integer, primary_key=true), sqlalchemy.column("username", sqlalchemy.string), sqlalchemy.column("password", sqlalchemy.string), sqlalchemy.column("email", sqlalchemy.string),)
这里,我们使用了sqlalchemy中的metadata对象,通过定义一个users表格,创建了四个字段(id、username、password和email)。
执行sql语句databases框架也提供了直接使用sql语句进行操作的方法,这种方法更加灵活。可以通过execute()方法来实现sql语句的执行,代码如下:
result = await database.execute(query)
其中query代表的是sql语句代码,result则是执行结果,当执行成功时,它会返回一个由dict类型组成的list,每个dict代表sql查询结果中的一条记录。
5.在databases中使用orm
databases框架同样支持orm的方式来操作sql语句,对于开发者而言,更加便捷。orm的方式有助于将对象关系映射到数据库上,使得代码具有更好的可读性和可维护性。
使用orm的方式,我们可以通过定义模型的方式来操作数据库,代码如下:
import sqlalchemymetadata = sqlalchemy.metadata()users = sqlalchemy.table( "users", metadata, sqlalchemy.column("id", sqlalchemy.integer, primary_key=true), sqlalchemy.column("username", sqlalchemy.string), sqlalchemy.column("password", sqlalchemy.string), sqlalchemy.column("email", sqlalchemy.string),)class usermodel: id: int username: str password: str email: str __tablename__ = "users" query: sq.select def __init__(self, **kwargs): for key, value in kwargs.items(): setattr(self, key, value)
这里,我们定义了一个usermodel模型类,代表我们的数据表对象,同时我们通过简单的定义,即可完成sqlalchemy中表、列的定义,从而使其orm映射到数据库上,方便快捷,易于维护。
三、应用实例
在此,我们以一个简单的博客应用为例,演示databases框架的具体操作。
1.连接到数据库
进行数据库连接所需的信息也非常简单,如下代码所示:
import databasesdatabase_url = "mysql://user:password@hostname/database_name"database = databases.database(database_url)
这里的database_url指定了连接到mysql的各项参数,以此来连接到我们的数据库系统。
2.定义模型
在这个博客示例中,我们需要定义两个数据模型,一个是blog模型,代表博客文章对象,生成代码如下:
class blog: id: int title: str description: str content: str __tablename__ = "blog" query: sq.select def __init__(self, **kwargs): for key, value in kwargs.items(): setattr(self, key, value)
另一个是user模型,代表用户对象,生成代码如下:
class user: id: int name: str email: str password: str __tablename__ = "user" query: sq.select def __init__(self, **kwargs): for key, value in kwargs.items(): setattr(self, key, value)
类似地,我们通过简单的定义,使其orm映射到我们连接的mysql数据库上。
3.创建表格
由于我们所操作的数据库系统为mysql,因此我们需要创建对应的表格,生成代码如下:
create table `blog` ( `id` int(11) unsigned not null auto_increment, `title` varchar(100) default null, `description` varchar(100) default null, `content` text, primary key (`id`)) engine=innodb default charset=utf8;create table `user` ( `id` int(11) unsigned not null auto_increment, `name` varchar(45) default null, `email` varchar(100) default null, `password` varchar(100) default null, primary key (`id`)) engine=innodb default charset=utf8;
4.插入数据
我们可以使用orm的方式很方便地输入数据,生成代码如下:
async def create_blog_post(title: str, description: str, content: str): query = blog.insert().values(title=title, description=description, content=content) return await database.execute(query)async def create_user(name: str, email: str, password: str): query = user.insert().values(name=name, email=email, password=password) return await database.execute(query)
这里我们使用了insert()方法来完成数据插入的操作,具有很好的可读性,方便开发者更好地维护代码。
5.查询数据
databases框架同样支持执行查询操作,如下代码所示:
async def get_blog_post(id: int): query = blog.select().where(blog.c.id == id) return await database.fetch_one(query)async def get_all_users(): query = user.select() return await database.fetch_all(query)async def get_users_by_email(email: str): query = user.select().where(user.c.email == email) return await database.fetch_all(query)
这里我们使用了select()方法,拼接条件获取一个生成器,遍历之时返回数对。我们也可以通过使用查询数据的方式,来实现数据的筛选和排序。
总结
databases框架是一个针对python开发者而言的一个灵活、易用、轻量级的orm框架,它可以轻松地支持多种数据库,方便开发者进行数据的存储、操作、筛选和排序等。本文从连接数据库到定义模型的操作,再到数据插入和查询操作,演示了databases框架的灵活性以及易用性,方便开发者更高效的开发python程序。
以上就是python中的orm框架databases实战的详细内容。