Before you start, If you have no experience with Koa, make sure you've read part 1 of this tutorial.

If you want to follow along with this tutorial, you can clone the file from here.

KOA SQL Server

Now that our server is up and running the next step is to connect it to a database. In this part we will be using a SQL (postgres) database.

Before we start let's make sure we have postgres installed:

psql --version

Setup

In this tutorial we will be using sequelize with postgres. So let's start by installing postgres and sequelize:

npm i pg sequelize

Models

Once postgres is installed lets create our models folder.

Then let's create two files, an index.js file and our first model and called it event.models.js.

Let's run the following commands:

mkdir models
touch models/index.js
touch models/event.models.js

Let's first add following code to our index.js file:

const { Sequelize } = require('sequelize');

const settings = {
  host: 'localhost',
  dialect: 'postgres',
}

const sequelize = new Sequelize('DATABASE', 'USERNAME', 'PASSWORD', settings);

module.exports = sequelize;

This file will connect us to our postgres database.

Replace the 'DATABASE', 'USERNAME', 'PASSWORD' with your own postgres credentials.

Now let's add the following to event.models.js:

const sequelize = require('.')
const { DataTypes } = require('sequelize');

const Event = sequelize.define('Events', {
  name: DataTypes.STRING,
  adultsOnly: DataTypes.BOOLEAN,
  attendees: DataTypes.INTEGER,
  description: DataTypes.STRING,
});

Event.sync();

module.exports = Event

So what did we just do? We've just created a model named Events and defined the following schemas:

1. Name - this will be a string representing the name of the event.
2. Adults Only - this will be a boolean field.
3. Attendees - this will be a number representing the number of attendees
4. Description - this will also be a string field.

Update the controllers

We should now change the import in our event.controllers.js file to:

const events = require('../models/events.models');

Post Request

Let's update the post request in our event.models.js

The post request takes the request body and creates an object in our postgres database.

• A successful request returns 'Event Created!',
• An unsuccessful request returns a status 500 error.

const postEvent = async ctx => {
    try {
        const { name, adultsOnly, attendees, description } = ctx.request.body;

        await Event.create({ name, adultsOnly, attendees, description });

        ctx.body = 'Event Created!'
        ctx.status = 201;
    } catch (err) {
        ctx.status = 500;
        throw (err)
    }
};

Try posting an item to the following endpoint on postman http://127.0.0.1:8000/post_event:

Let's move on to the get request!

Get Request

On our event.models.js file, let's update the getEvents controller.

We need to update our function to make it async and return all the event items stored in our postgres.

const getEvents = async ctx => {
    try {
        const foundEvents = await Event.findAll();
        ctx.body = foundEvents;
        ctx.status = 200;
    } catch (err) {
        ctx.body = err;
        ctx.status = 500;
    }
};

Let's try a get request to the following endpoint: http://127.0.0.1:8000/events_list.

If this works correctly you should get the following:

[
    {
        "id": 1,
        "name": "test event",
        "adultsOnly": false,
        "attendees": 100,
        "description": "test event description",
        "createdAt": "TIME OF CREATION",
        "updatedAt": "TIME OF CREATION"
    }
]

And that is all!

Summary

• We've added models to our project.
• The models/index.js connects us to our server and each model will call the index file.
• We connected our controllers to our models for the post and get requests.

The full code of this tutorial can be found here.