Support Database Schemas #153

module.exports = function (schemaName) {
  return context => {
    const { table, createQuery } = context.service;
    const knex = createQuery(context.params);

    // do something with query here
    knex.clearSelect().withSchema(schemaName).table(`${table} as ${table}`);

    context.params.knex = knex;
    return context;
  };
};

app.use('/messages', service({
  Model: db,
  name: 'messages',
  schema: 'public'
}));

const knex = require('knex');

const db = knex({
  client: 'sqlite3',
  connection: {
    filename: './db.sqlite'
  }
});

// Create a public database
const schemaName = 'public';
knex({
  client: 'sqlite3',
  connection: {
    filename: `./${schemaName}.sqlite`
  }
});

// Attach the public database to mimic a "schema"
db.schema.raw(`attach database '${schemaName}.sqlite' as ${schemaName}`);