graphql + dataloader + express-graphql Live Coding Demo

1README.md

How to test if Dataloader is working correctly, we are going to turn on server logging in order to see how many queries are being made to our db. If Dataloader is setup correctly, we should only see one hit on our db perrequest, even if duplicate data is being requested. Here's how to enable logging on postgresql. Note - This is the Mac way to enable logging.

• subl /usr/local/var/postgres/postgresql.conf

• around line 434 log_statement = 'all' uncomment and set to all log_statement = 'all'

• then brew service restart postgresql

• To view your logs coming in run tail -f /usr/local/var/postgres/server.log

• Here is a sample graphiql query to test dataloader: { people { first_name spouse { fullName spouse { fullName spouse { fullName } } } } }

• If Dataloader is setup correctly - you should only see one request being sent to your DB for multeiple calls.

database.js

const humps = require('humps');

module.exports = (pool) => ({
  getUsersByIds(userIds) {
    return pool.query(`
      select id, first_name, last_name, email, spouse_id,
      'Person' as type
      from people
      where id = ANY($1)
    `, [userIds]).then(result => result.rows);
  },

  getUsers() {
    return pool.query(`
      select * from people
    `).then(result => result.rows);
  }
});

index.js

const express = require('express');
const graphqlHTTP = require('express-graphql')
const app = express();
const PORT = process.env.PORT || 3000;

// function, the actual executor of the schema
const { graphql } = require('graphql');

const pg = require('pg');

const pool = new pg.Pool({
  database: 'graphql_server_db',
  user: 'joecarlson'
});

const db = require('./database')(pool);
const DataLoader = require('dataloader');

// the schema to execute
const mySchema = require('./schema');

app.use('/graphql', (req, res) => {
  const loaders = {
    usersByIds: new DataLoader(db.getUsersByIds)
  };

  return graphqlHTTP({
    schema: mySchema,
    graphiql: true,
    context: { pool, loaders }, // available to all graphql resolve as the third argument
  })(req, res);
});

app.listen(PORT);

schema.js

const {
  GraphQLSchema,
  GraphQLObjectType,
  GraphQLString,
  GraphQLInt,
  GraphQLList,
  GraphQLID,
  GraphQLNonNull
} = require('graphql');

const humps = require('humps');
const db = require('./database');

const PersonType = new GraphQLObjectType({
  name: 'Person',
  fields: () => ({
    id: { type: GraphQLID },
    first_name: { type: GraphQLString },
    last_name: { type: GraphQLString },
    email: { type: GraphQLString },
    spouse_id: { type: GraphQLInt },
    fullName: {
      type: GraphQLString,
      resolve: obj => `${obj.first_name} ${obj.last_name}`
    },
    spouse: {
      type: PersonType,
      resolve: ( obj, args, { loaders }, info ) => loaders.usersByIds.load(obj.spouse_id)
    }
  })
});


const queryType = new GraphQLObjectType({
  name: 'RootQuery',
  fields: {
    person: {
      type: PersonType,
      args: {
        id: {
          type: new GraphQLNonNull(GraphQLInt)
        }
      },
      // 4th is execution context ----v
      resolve: ( obj, args, { loaders }, info ) => loaders.usersByIds.load(args.id)
    },
    people: {
      type: new GraphQLList(PersonType),
      resolve: ( obj, args, { pool } ) => db(pool).getUsers()
    }
  }
});

const mySchema = new GraphQLSchema({
  query: queryType,
  // mutation: mutationType
});

module.exports = mySchema;