SQL adapter (Postgres, MySQL, SQLite & MSSQL) for Moleculer DB service
npm install moleculer-db-adapter-sequelizeSQL adapter (Postgres, MySQL, SQLite & MSSQL) for Moleculer DB service with Sequelize.
``bash`
$ npm install moleculer-db-adapter-sequelize sequelize --save
You have to install additional packages for your database server:
`bashFor SQLite
$ npm install sqlite3 --save
Usage
js
"use strict";const { ServiceBroker } = require("moleculer");
const DbService = require("moleculer-db");
const SqlAdapter = require("moleculer-db-adapter-sequelize");
const Sequelize = require("sequelize");
const broker = new ServiceBroker();
// Create a Sequelize service for
post entities
broker.createService({
name: "posts",
mixins: [DbService],
adapter: new SqlAdapter("sqlite://:memory:"),
model: {
name: "post",
define: {
title: Sequelize.STRING,
content: Sequelize.TEXT,
votes: Sequelize.INTEGER,
author: Sequelize.INTEGER,
status: Sequelize.BOOLEAN
},
options: {
// Options from http://docs.sequelizejs.com/manual/tutorial/models-definition.html
}
},
});
broker.start()
// Create a new post
.then(() => broker.call("posts.create", {
title: "My first post",
content: "Lorem ipsum...",
votes: 0
}))
// Get all posts
.then(() => broker.call("posts.find").then(console.log));
`$3
You can reach the instance via this.adapter.db. To call Raw queries:`js
actions: {
findHello2() {
return this.adapter.db.query("SELECT * FROM posts WHERE title = 'Hello 2' LIMIT 1")
.then(([res, metadata]) => res);
}
}
`Options
Every constructor arguments are passed to the constructor. Read more about Sequelize connection.Example with connection URI
`js
new SqlAdapter("postgres://user:pass@example.com:5432/dbname");
`Example with connection options
js
new SqlAdapter('database', 'username', 'password', {
host: 'localhost',
dialect: / one of 'mysql' | 'mariadb' | 'postgres' | 'mssql' /, pool: {
max: 5,
min: 0,
idle: 10000
},
// SQLite only
storage: 'path/to/database.sqlite'
});
`Test
$ npm test
In development with watching
$ npm run ci
 