Link models

We know that each room must be linked to an address. Lets make it true in our project.

Note: You can use III-04_mixins directory from AnyBlok/anyblok-book-examples repository to get ready to start with this chapter.

Add the field

In any database system, to link two tables together we use relationships, here we need to add a Many2One relationship between Room and Address:

# File rooms_booking/room/room.py
@@ -8,6 +8,7 @@

 from anyblok import Declarations
 from anyblok.column import String, Integer
+from anyblok.relationship import Many2One

 Model = Declarations.Model
 Mixin = Declarations.Mixin
@@ -20,3 +21,6 @@ class Room(Mixin.IdColumn, Mixin.TrackModel):

     name = String(label="Room name", nullable=False, index=True)
     capacity = Integer(label="Capacity", nullable=False)
+    address = Many2One(
+        label="Address", model=Model.Address, nullable=False, one2many="rooms"
+    )

Fix tests

You probably have noticed that your tests are failing now! We have to fix them.

rooms_booking/room/tests/conftest.py
@@ -1 +1,15 @@
+import pytest
 from anyblok.conftest import *  # noqa: F401,F403
+
+
+@pytest.fixture()
+def an_address(rollback_registry):
+    return rollback_registry.Address.insert(
+        first_name="The Queen's College",
+        last_name="University of oxford",
+        street1="High Street",
+        zip_code="OX1 4AW",
+        city="Oxford",
+        country="GBR",
+        access="Kick the door to open it!"
+    )

rooms_booking/room/tests/test_room.py
@@ -14,22 +13,24 @@ import pytz
 class TestRoom:
     """Test Room model"""

-    def test_create_room(self, rollback_registry):
+    def test_create_room(self, rollback_registry, an_address):
         registry = rollback_registry
         room_count = registry.Room.query().count()
         room = registry.Room.insert(
             name="A1",
             capacity=25,
+            address=an_address
         )
         assert registry.Room.query().count() == room_count + 1
         assert room.name == "A1"

-    def test_track_modification_date(self, rollback_registry):
+    def test_track_modification_date(self, rollback_registry, an_address):
         registry = rollback_registry
         before_create = datetime.now(tz=pytz.timezone(time.tzname[0]))
         room = registry.Room.insert(
             name="A1",
             capacity=25,
+            address=an_address
         )
         room.refresh()
         after_create = datetime.now(tz=pytz.timezone(time.tzname[0]))

If you are curious, you may read which kind of relationship AnyBlok provides and learn from documentation reference

Init some data

To play with queries we need to populate some data entries while installing the blok.

# File: rooms_booking/room/__init__.py

    def install(self):
        sorbonne = self.registry.Address.insert(
            first_name="La Sorbonne",
            last_name="La Chancellerie des Universités de Paris",
            street1="47, rue des Écoles ",
            zip_code="75230",
            city="Paris cedex 05",
            country="FRA",
            access="Crie fort pour réveiller le consièrge"
        )
        self.registry.Room.insert(
            name="Salle 101",
            capacity=25,
            address=sorbonne
        )
        self.registry.Room.insert(
            name="Salle 102",
            capacity=30,
            address=sorbonne
        )
        self.registry.Room.insert(
            name="Salle 103",
            capacity=28,
            address=sorbonne
        )
        trinity = self.registry.Address.insert(
            first_name="Trinity College",
            last_name="University of Oxford",
            street1="Broad Street",
            zip_code="OX1 3BH",
            city="Oxford",
            country="GBR",
            access="Ring the bell!"
        )
        self.registry.Room.insert(
            name="Room 101",
            capacity=47,
            address=trinity
        )
        self.registry.Room.insert(
            name="102",
            capacity=50,
            address=trinity
        )
        self.registry.Room.insert(
            name="103",
            capacity=42,
            address=trinity
        )
        imt_lille = self.registry.Address.insert(
            first_name="l'IMT Lille Douai",
            last_name="Université de Lille",
            street1="Site de Villeneuve d'Ascq",
            street2="20 rue Guglielmo Marconi",
            zip_code="59650",
            city="Villeneuve - d’Ascq",
            country="FRA",
            access="Ring the bell!"
        )
        self.registry.Room.insert(
            name="Salle E001S",
            capacity=42,
            address=imt_lille
        )
        self.registry.Room.insert(
            name="Salle E002S",
            capacity=28,
            address=imt_lille
        )
        self.registry.Room.insert(
            name="Salle E003S",
            capacity=60,
            address=imt_lille
        )
        self.registry.Room.insert(
            name="Amphi Byron",
            capacity=200,
            address=imt_lille
        )
        self.registry.Room.insert(
            name="Amphi Pascal",
            capacity=150,
            address=imt_lille
        )
        self.registry.Room.insert(
            name="Amphi Morse",
            capacity=500,
            address=imt_lille
        )
        self.registry.Room.insert(
            name="Amphi Shannon",
            capacity=200,
            address=imt_lille
        )
        self.registry.Room.insert(
            name="Amphi Chappe",
            capacity=500,
            address=imt_lille
        )

As this code is only called while installing this blok we are going to recreate the dev database:

bash dropdb rooms_booking make setup-dev

Play with queries

As AnyBlok is based on SqlAlchemy you can directly learn how to build queries from SqlAlchemy query API doc. Here are some examples using anyblok_interpreter -c app.dev.cfg

How many addresses we have

registry.Address.query().count()
3

Count how many rooms have a capacity greater than 45

registry.Room.query().filter(
    registry.Room.capacity > 45).count()
8

Count how many rooms have a capacity greater than 45 in France

registry.Room.query().join(
    registry.Room.address).filter_by(
    country='FRA').filter(
    registry.Room.capacity > 45).count()
6

Display the query that will be execute

str(
    registry.Room.query().join(
        registry.Room.address).filter_by(
        country='FRA').filter(
        registry.Room.capacity > 45)
)
'SELECT room.capacity AS room_capacity, room.name AS room_name, room.id AS room_id, room.create_date AS room_create_date, room.edit_date AS room_edit_date, room.address_uuid AS room_address_uuid
 FROM room JOIN address ON address.uuid = room.address_uuid
 WHERE address.country = %(country_1)s AND room.capacity > %(capacity_1)s'

Count how many rooms have a capacity greater than 45 OR in France

from sqlalchemy import or_

registry.Room.query().join(
    registry.Room.address).filter(
    or_(
        registry.Address.country=='FRA',
        registry.Room.capacity > 45
    )
).count()
13

Display a list of tuple (room name, address first name, room capacity) using the previous query.

registry.Room.query(
    registry.Room.name,
    registry.Address.first_name,
    registry.Room.capacity
).join(
    registry.Room.address
).filter(
    or_(
        registry.Address.country=='FRA',
        registry.Room.capacity > 45)
).all()
[('Salle 101', 'La Sorbonne', 25),
 ('Salle 102', 'La Sorbonne', 30),
 ('Salle 103', 'La Sorbonne', 28),
 ('Room 101', 'Trinity College', 47),
 ('102', 'Trinity College', 50),
 ('Salle E001S', "l'IMT Lille Douai", 42),
 ('Salle E002S', "l'IMT Lille Douai", 28),
 ('Salle E003S', "l'IMT Lille Douai", 60),
 ('Amphi Byron', "l'IMT Lille Douai", 200),
 ('Amphi Pascal', "l'IMT Lille Douai", 150),
 ('Amphi Morse', "l'IMT Lille Douai", 500),
 ('Amphi Shannon', "l'IMT Lille Douai", 200),
 ('Amphi Chappe', "l'IMT Lille Douai", 500)]

... and order results by capacity

registry.Room.query(
    registry.Room.name,
    registry.Address.first_name,
    registry.Room.capacity
).join(registry.Room.address).filter(
    or_(
        registry.Address.country == 'FRA',
        registry.Room.capacity > 45)
).order_by(
    registry.Room.capacity
).all()
[('Salle 101', 'La Sorbonne', 25),
 ('Salle 103', 'La Sorbonne', 28),
 ('Salle E002S', "l'IMT Lille Douai", 28),
 ('Salle 102', 'La Sorbonne', 30),
 ('Salle E001S', "l'IMT Lille Douai", 42),
 ('Room 101', 'Trinity College', 47),
 ('102', 'Trinity College', 50),
 ('Salle E003S', "l'IMT Lille Douai", 60),
 ('Amphi Pascal', "l'IMT Lille Douai", 150),
 ('Amphi Byron', "l'IMT Lille Douai", 200),
 ('Amphi Shannon', "l'IMT Lille Douai", 200),
 ('Amphi Chappe', "l'IMT Lille Douai", 500),
 ('Amphi Morse', "l'IMT Lille Douai", 500)]

Get only the first element

registry.Room.query(
    registry.Room.name, registry.Address.first_name, registry.Room.capacity
).join(
    registry.Room.address
).filter(
    or_(registry.Address.country=='FRA', registry.Room.capacity > 45)
).order_by(registry.Room.capacity).first()
('Salle 101', 'La Sorbonne', 25)

Get a unique instance matching query if exists and None otherwise

registry.Room.query(
    registry.Room.name, registry.Room.capacity
).filter_by(
    name='Salle 101').one_or_none()
('Salle 101', 25)
registry.Room.query().filter_by(name='not an existing name').one_or_none()
None

exit

Note: You can use III-05_link-models directory from AnyBlok/anyblok-book-examples repository to get that whole code.

Link models

Link models

Add the field

Fix tests

Init some data

Play with queries

results matching ""

No results matching ""