没有项目描述
aiosqlalchemy-miniorm的Python项目详细描述
#异步sqlalchemy对象关系映射器。
这是一个使用asyncio访问sqlalchemy的orm。在sqlalchemy核心之上工作。
它提供了一种将用户定义的python类与数据库表相关联的方法,以及将这些类(对象)的实例与相应表中的行相关联的方法。
datetime
来自aiopg.sa import create_engine
来自aiosqllachemy_miniorm import rowmodel、rowmodeldeclarativemeta、basemodelmanager
metadata=metadata()
basemodel=declarative_base(metadata=metadata,cls=rowmodel,元类=rowmodelDeclarativeMeta)
metadata.bind=await create_engine(**database_settings)
Class MyEntityManager(BaseModelManager):
async def get_with_products(self):
return await self.get_items(where_list=[(MyEntity.c.num_products>;0])
Class MyEntity(BaseModel):
服务器默认=文本('now()',可空=false)
查询:
objects=等待myentity.objects.get_实例(
where_list=[(myentity.c.name=='foo')],
order_by=['name',
>num-objects=await-myentity.objectobjects.count(
where\list=[(myentity.c.name=='foo'),(myentity.c.num-products>;3)
objects=await-myentity.objects\
.set-sql(myentity.table.select())\
.where([(myentity.c.name.c.name.c.name=where=[是的=='foo')])\
。限制(10)\
.fetchall()
管理:
record=等待myentity.objects.insert(
name='bar',
num_products=0,
)
wait record.update(name='baz')
wait record.delete()
事务:
这是一个使用asyncio访问sqlalchemy的orm。在sqlalchemy核心之上工作。
它提供了一种将用户定义的python类与数据库表相关联的方法,以及将这些类(对象)的实例与相应表中的行相关联的方法。
datetime
来自aiopg.sa import create_engine
来自aiosqllachemy_miniorm import rowmodel、rowmodeldeclarativemeta、basemodelmanager
metadata=metadata()
basemodel=declarative_base(metadata=metadata,cls=rowmodel,元类=rowmodelDeclarativeMeta)
Class MyEntityManager(BaseModelManager):
async def get_with_products(self):
return await self.get_items(where_list=[(MyEntity.c.num_products>;0])
Class MyEntity(BaseModel):
服务器默认=文本('now()',可空=false)
查询:
objects=等待myentity.objects.get_实例(
where_list=[(myentity.c.name=='foo')],
order_by=['name',
>num-objects=await-myentity.objectobjects.count(
where\list=[(myentity.c.name=='foo'),(myentity.c.num-products>;3)
objects=await-myentity.objects\
.set-sql(myentity.table.select())\
.where([(myentity.c.name.c.name.c.name=where=[是的=='foo')])\
。限制(10)\
.fetchall()
管理:
record=等待myentity.objects.insert(
name='bar',
num_products=0,
)
wait record.update(name='baz')
wait record.delete()
事务: