apgorm 1.0.0b14

A fully type-checked asynchronous ORM wrapped around asyncpg.

apgorm

Documentation | Support

An asynchronous ORM wrapped around asyncpg. Examples can be found under examples/. Run examples with python -m examples.<example_name> (python -m examples.basic).

Please note that this library is not for those learning SQL or Postgres. Although the basic usage of apgorm is straightforward, you will run into problems, especially with migrations, if you don't understand regular SQL well.

Features

• Fairly straightforward and easy-to-use.
• Support for basic migrations.
• Protects against SQL-injection.
• Python-side converters and validators.
• Decent many-to-many support.
• Fully type-checked.
• Tested.

Limitations

• Limited column namespace. For example, you cannot have a column named tablename since that is used to store the name of the model.
• Only supports PostgreSQL with asyncpg.
• Migrations don't natively support field/table renaming or type changes, but you can still write your own migration with raw SQL.
• Converters only work on instances of models and when initializing the model.
• Models can only detect assignments. If User.nicknames is a list of nicknames, it won't detect user.nicknames.append("new nick"). You need to do user.nicknames = user.nicknames + ["new nick"].

Basic Usage

Defining a model and database:

class User(apgorm.Model):
    username = apgorm.types.VarChar(32).field()
    email = apgorm.types.VarChar().nullablefield()
    
    primary_key = (username,)
    
class Database(apgorm.Database):
    users = User

Intializing the database:

db = Database(migrations_folder="path/to/migrations")
await db.connect(database="database name")

Creating & Applying migrations:

if db.must_create_migrations():
    db.create_migrations()
if await db.must_apply_migrations():
    await db.apply_migrations()

Basic create, fetch, update, and delete:

user = await User(username="Circuit").create()
print("Created user", user)

assert user == await User.fetch(username="Circuit")

user.email = "[e-mail]"
await user.save()

await user.delete()