From 1f7c661fa37f71c5df67df9f675f0f8b0e442fed Mon Sep 17 00:00:00 2001 From: Luke Childs Date: Tue, 1 Aug 2017 16:31:49 +0100 Subject: [PATCH] Use keyv-sql instead of keyv-sequelize (#3) --- packages/keyv-mysql/package.json | 2 +- packages/keyv-mysql/src/index.js | 12 ++++++++++-- 2 files changed, 11 insertions(+), 3 deletions(-) diff --git a/packages/keyv-mysql/package.json b/packages/keyv-mysql/package.json index 891368a..f355ae0 100644 --- a/packages/keyv-mysql/package.json +++ b/packages/keyv-mysql/package.json @@ -39,7 +39,7 @@ }, "homepage": "https://github.com/lukechilds/keyv-mysql", "dependencies": { - "keyv-sequelize": "0.1.0", + "keyv-sql": "^0.2.3", "mysql2": "^1.3.6" }, "devDependencies": { diff --git a/packages/keyv-mysql/src/index.js b/packages/keyv-mysql/src/index.js index dd175a9..f282272 100644 --- a/packages/keyv-mysql/src/index.js +++ b/packages/keyv-mysql/src/index.js @@ -1,8 +1,9 @@ 'use strict'; -const KeyvSequelize = require('keyv-sequelize'); +const KeyvSql = require('keyv-sql'); +const mysql = require('mysql2/promise'); -class KeyvMysql extends KeyvSequelize { +class KeyvMysql extends KeyvSql { constructor(opts) { if (typeof opts === 'string') { opts = { uri: opts }; @@ -12,6 +13,13 @@ class KeyvMysql extends KeyvSequelize { uri: 'mysql://localhost' }, opts); + opts.connect = () => Promise.resolve() + .then(() => mysql.createConnection(opts.uri)) + .then(connection => { + return sql => connection.execute(sql) + .then(data => data[0]); + }); + super(opts); } }