encode · asnelling · Jul 31, 2020 · Jul 31, 2020 · Jul 31, 2020
diff --git a/README.md b/README.md
@@ -39,7 +39,6 @@ class Note(orm.Model):
     __tablename__ = "notes"
     __database__ = database
     __metadata__ = metadata
-
     id = orm.Integer(primary_key=True)
     text = orm.String(max_length=100)
     completed = orm.Boolean(default=False)
@@ -53,6 +52,13 @@ await Note.objects.create(text="Buy the groceries.", completed=False)
 await Note.objects.create(text="Call Mum.", completed=True)
 await Note.objects.create(text="Send invoices.", completed=True)
 
+# .bulk_create()
+await Note.objects.bulk_create([
+    Note(text="Buy the groceries.", completed=False),
+    Note(text="Call Mum.", completed=True),
+    Note(text="Send invoices.", completed=True),
+])
+
 # .all()
 notes = await Note.objects.all()
 

diff --git a/orm/models.py b/orm/models.py
@@ -266,6 +266,28 @@ async def create(self, **kwargs):
         instance.pk = await self.database.execute(expr)
         return instance
 
+    async def bulk_create(self, objs):
+        # Validate the keyword arguments.
+        fields = self.model_cls.fields
+        required = [key for key, value in fields.items() if not value.has_default()]
+        validator = typesystem.Object(
+            properties=fields, required=required, additional_properties=False
+        )
+        validated_objs = [validator.validate(o) for o in objs]
+
+        # Remove primary key when None to prevent not null constraint in postgresql.
+        pkname = self.model_cls.__pkname__
+        pk = self.model_cls.fields[pkname]
+        for obj in validated_objs:
+            if obj[pkname] is None and pk.allow_null:
+                del obj[pkname]
+
+        # Build the insert expression.
+        expr = self.table.insert()
+
+        # Execute the insert, and return a new model instance.
+        return await self.database.execute_many(expr, validated_objs)
+
 
 class Model(typesystem.Schema, metaclass=ModelMetaclass):
     __abstract__ = True

diff --git a/tests/test_models.py b/tests/test_models.py
@@ -216,3 +216,15 @@ async def test_model_first():
         assert await User.objects.first(name="Jane") == jane
         assert await User.objects.filter(name="Jane").first() == jane
         assert await User.objects.filter(name="Lucy").first() is None
+
+
+@async_adapter
+async def test_model_bulk_create():
+    async with database:
+        await User.objects.bulk_create([
+            User(name="Tom"),
+            User(name="Jane"),
+            User(name="Lucy"),
+        ])
+
+        assert await User.objects.count() == 3