การใช้ GraphQL ร่วมกับ PostgreSQL

module.exports = ( sequelize , Sequelize ) => {
  //sequelize.define(modelName, attributes, options)
    const users = sequelize.define(
      'users', //ชื่อของ model 
      {
        //attributes ต่างๆ ซึ่งจะตั้งให้สอดคล้องกับ User ในที่นี้คือ id firstName lastName email password
        id: { type: Sequelize.INTEGER(), primaryKey: true, autoIncrement: true, field: 'id' },//ตั้งเป็น primary key และกำหนดให้มีค่าเพิ่มขึ้นเองเมื่อมีข้อมูลเพิ่ม
        firstName: { type: Sequelize.STRING(50), allowNull: false, field: 'firstName' },
        lastName: { type: Sequelize.STRING(50), allowNull: false, field: 'lastName' },
        email: { type: Sequelize.STRING(50), allowNull: false, field: 'email' },
        password: { type:Sequelize.STRING(50), allowNull: false, field: 'password' },
      },
      { 
        // ส่วนของ option ในที่นี้จะปิดการเพิ่ม timestamp
        //หากไม่กำหนดค่าในส่วนนี้เป็น false sequelize จะเป็น attributes createdAt และ updatedAt ให้โดยอัตโนมัติ
        timestamps: false,
        createdAt: false, 
        updatedAt: false, 
        tableName: 'users' // กำหนดชื่อตาราง
      }
    );
    
    return users;
  }

const dbConfig = require('./config'); // เรียกค่าต่างๆ ที่ใช้ในการเชื่อมต่อกับฐานข้อมูล
const { Sequelize } = require('sequelize');
const sequelize = new Sequelize(
   dbConfig.dbName, // ชื่อของฐานข้อมูลเช่น 'BornToDevDB'
    dbConfig.username, //'youusername'
    dbConfig.password, {
    host: dbConfig.host,
    /*dialect => one of 'mysql' | 'postgres' | 'sqlite' | 'mariadb' | 'mssql' | 'db2' | 'snowflake' | 'oracle' */
    //ในบทความนี้ใช้ dialect: 'postgres'
    dialect: dbConfig.dialect 
  });

  const db = {};

  db.Sequelize = Sequelize;
  db.sequelize = sequelize;

  db.users = require('./model/user')( sequelize , Sequelize );

  module.exports = db;

module.exports = {
    'username': 'yourUserName',
    'password': ' yourUserPassword',
    'host':'localhost',
    'dbName': 'BornToDevDB',
    'dialect': 'postgres',
  }

const db = require("./db");
const users = db.users;
db.sequelize.sync();

const userData = require("../MOCK_DATA.json");
//สร้างฟังก์ชัน เพื่อย้ายข้อมูลทั้งหมดไปสู่ฐานข้อมูล
async function bulkInsertUsers(usersData) {
  try {
    const createdUsers = await users.bulkCreate(usersData);
    // ถ้าทำการย้ายข้อมูลสำเร็จให้รายงานจำนวนข้อมูลที่ย้ายใน console
    console.log(
      "Bulk insert successful:",
      createdUsers.length,
      "users inserted."
    );
  } catch (error) {
    console.error("Error inserting users:", error);
  }
}
//เรียกใช้ฟังก์ชัน
bulkInsertUsers(userData);

const express = require("express");
const app = express();
const port = 3000;
const graphql = require("graphql");
const {
  GraphQLObjectType,
  GraphQLSchema,
  GraphQLInt,
  GraphQLString,
  GraphQLList,
} = require("graphql");
const { graphqlHTTP } = require("express-graphql");
const db = require('./db/db');
const users = db.users;
const { where } = require("sequelize");
db.sequelize.sync();

const UserType = new GraphQLObjectType({
  name: "User",
  fields: {
    id: { type: GraphQLInt },
    firstName: { type: GraphQLString },
    lastName: { type: GraphQLString },
    email: { type: GraphQLString },
    password: { type: GraphQLString },
  },
});
app.use(express.json());
const RootQuery = new GraphQLObjectType({
  name: "RootQueryType",
  description: "getALlUsers,getUser(id)",
  fields: {
    getAllUsers: {
      type: new GraphQLList(UserType),
       async resolve(parent, args) {
        info = await users.findAll();
        return info;
      },
      description: "get all users from database",
    },
    getUser: {
      type: UserType,
      args: {
        id: { type: GraphQLInt },
      },
      async resolve(parent, args) {
        info = await users.findOne({
          where: {id:args.id}
        })
        return info;
      },
      description: "get user by id ",
    },
  },
});

const Mutation = new GraphQLObjectType({
  name: "Mutation",
  fields: {
    createUser: {
      type: UserType,
      args: {
        firstName: { type: GraphQLString },
        lastName: { type: GraphQLString },
        email: { type: GraphQLString },
        password: { type: GraphQLString },
      },
      async resolve(parent, args) {
        const newRecord = await users.create({
          firstName: args.firstName,
          lastName: args.lastName,
          email: args.email,
          password: args.password,
        });
        return newRecord;
      },
    },
  },
});

const schema = new GraphQLSchema({ query: RootQuery, mutation: Mutation });
app.use(
  "/graphql",
  graphqlHTTP({
    schema,
    graphiql: true,
  })
);
app.listen(port, () => {
  console.log("Listening on port %d", port);
});