matissjanis / knex-serverless-mysql Goto Github PK

  const mysql = require('serverless-mysql')({ config });
  const knexServerlessMysql = require('knex-serverless-mysql');
  const knexInstance = Knex({
    mysql,
    client: knexServerlessMysql,
  } as any);
  // ...
  const originalDestroy = (knexInstance as any).context.destroy;
  (knexInstance as any).context.destroy = async () => {
    if (knexInstance) {
      await originalDestroy.apply(knexInstance);
    }
    if (mysql) {
      await mysql.end();
      mysql.quit();
    }
  };

/* eslint-disable @typescript-eslint/no-unsafe-member-access */
/* eslint-disable @typescript-eslint/no-unsafe-call */
/* eslint-disable @typescript-eslint/no-var-requires */
/* eslint-disable @typescript-eslint/no-unsafe-assignment */
// import knex, { Knex } from 'knex';
const Knex = require('knex');
const knexServerlessMysql = require('knex-serverless-mysql');
const env = process.env.NODE_ENV || 'test';
import { Knex as knexType } from 'knex';
import config from '../../knexfile';
console.log(`env ${env}`);

export let k: knexType;
let mysql: any;
console.log(`config ${JSON.stringify(config[env])}`);
if (env === 'test' || env === 'local' || env === 'local_to_dev') {
  k = Knex(config[env]);
} else if (env === 'production' || env === 'dev') {
  mysql = require('serverless-mysql')({
    config: {
      host: process.env.DB_END_POINT,
      database: process.env.DB_DATABASE,
      user: process.env.DB_USERNAME,
      password: process.env.DB_PASSWORD,
    },
  });
  console.log(mysql);
  k = Knex({
    client: knexServerlessMysql,
    connection: mysql,
  });
}

void (async () => {
  if (mysql) {
    await mysql.end();
    mysql.quit();
  }
})();

console.log('db connected');