DEV Community

Cover image for Koa Js : Part 2 - Connect a SQL database to your server
Kachi Cheong
Kachi Cheong

Posted on • Updated on

Koa Js : Part 2 - Connect a SQL database to your server

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
Enter fullscreen mode Exit fullscreen mode

Setup

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

npm i pg sequelize
Enter fullscreen mode Exit fullscreen mode

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
Enter fullscreen mode Exit fullscreen mode

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;
Enter fullscreen mode Exit fullscreen mode

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
Enter fullscreen mode Exit fullscreen mode

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');
Enter fullscreen mode Exit fullscreen mode

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)
    }
};
Enter fullscreen mode Exit fullscreen mode

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

postman picture

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;
    }
};
Enter fullscreen mode Exit fullscreen mode

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"
    }
]
Enter fullscreen mode Exit fullscreen mode

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.

Discussion (2)

Collapse
isabel0715 profile image
Isabel0715

Amazing!I’m a junior front-end developer, and recently want to learn node server-side development. Lucky to find your blog and find it quite useful! May I ask if you will keep updating this series of koa? I'm sincerely looking forward to it!

Collapse
kachiic profile image
Kachi Cheong Author • Edited on

Thank you Isabel! I appreciate it. I will continue to update this tutorial shortly