SQL adapter (Postgres, MySQL, SQLite , MSSQL & CockroachDB) for Moleculer DB service
npm install @indevweb/moleculer-db-adapter-sequelize



SQL adapter (Postgres, MySQL, SQLite, MSSQL & CockrachDB ) for Moleculer DB service with sequelize-cockroachdb.
``bash`
$ npm install moleculer-db-adapter-sequelize sequelize-cockroachdb --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 sequelize 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 Sequelize 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'
dialectOptions: {
// only cockroachdb
ssl: {
rejectUnauthorized: false,
// For secure connection:
/*ca: fs.readFileSync('certs/ca.crt')
.toString()*/
},
},
});
`Test
`
$ npm test
`In development with watching
`
$ npm run ci
``