add helpers export

.github/workflows/npm-publish.yml

@@ -0,0 +1,21 @@
+name: Node.js Package
+
+on:
+  push:
+    branches: [master]
+  pull_request:
+    branches: [master]
+  release:
+    types: [created]
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v2
+      - uses: actions/setup-node@v1
+        with:
+          node-version: 12
+      - run: npm ci
+      - run: npm run build
+      - run: npm run validate

README.md

@@ -9,6 +9,7 @@ Simple ORM for nodejs, based on [sql-template-string](https://github.com/felixfb
     - [Model](#usage-model)
         - [Definition](#usage-model-definition)
         - [Usage](#usage-model-usage)
+    - [Helpers](#usage-helpers)
 - [Devlopment](#dev)
     - [Installation](#dev-install)
     - [Tests](#dev-tests)
@@ -24,7 +25,7 @@ Simple ORM for nodejs, based on [sql-template-string](https://github.com/felixfb
 const vegeData = VegeData({ filename: <your sqlite filename> });
 ```
 
-## Get connection
+## Connection
 
 __db__ is an [sqlite](https://github.com/kriasoft/node-sqlite#readme) object
 
@@ -69,6 +70,27 @@ model.save(data);
 models.saveAll(datas)
 ```
 
+
+## Helpers
+
+```js
+import { helpers } from 'vege-data';
+
+// concat value
+model.queries.select()
+ .append(' WHERE id IN (')
+ .append(helpers.concatValue([1, 2, 3]))
+
+// custom element
+const items = [{ id: 1}, { id: 2 }];
+model.queries.select()
+ .append(' WHERE id IN (')
+ .append(helpers.concatValue(items, ({ id }) => id))
+ .append(')');
+
+```
+
+
 # Devlopment
 ## Installation
 

package.json

@@ -41,7 +41,6 @@
   },
   "homepage": "https://github.com/BibiFock/vege-data#readme",
   "dependencies": {
-    "eslint-plugin-node": "11.1.0",
     "sql-template-strings": "2.2.2",
     "sqlite": "4.0.9",
     "sqlite3": "4.2.0"
@@ -58,6 +57,7 @@
     "eslint-config-standard": "14.1.1",
     "eslint-plugin-import": "2.20.2",
     "eslint-plugin-jest": "23.13.2",
+    "eslint-plugin-node": "11.1.0",
     "eslint-plugin-promise": "4.2.1",
     "jest": "26.0.1",
     "rimraf": "3.0.2"

src/helpers.js

@@ -0,0 +1,21 @@
+import SQL from 'sql-template-strings';
+
+/**
+ * transform array of items.
+ * [1, 2, 3] => SQL'${1}, ${2}, ${3}';
+ *
+ * @param {array} items
+ * @param {func} each function call for each elements
+ *
+ * @return object sql template string
+ */
+export const concatValues = (items, each) => {
+  const query = SQL``;
+  items.forEach(
+    (item, index) => query
+      .append(index > 0 ? ', ' : '')
+      .append(each ? each(item) : SQL`${item}`)
+  );
+  return query;
+};
+

src/index.js

@@ -3,6 +3,10 @@ import { open } from 'sqlite';
 
 import model from './model/model';
 
+import { concatValues } from './helpers';
+
+export { concatValues };
+
 export default ({ filename }) => {
   const dbParams = {
     filename,
@@ -21,9 +25,7 @@ export default ({ filename }) => {
   }
 
   const migrate = () => connect()
-    .then(db => db.migrate({ force: 'last' }))
-  // eslint-disable-next-line no-console
-    .catch(e => console.error('Failed: ' + e.message));
+    .then(db => db.migrate({ force: 'last' }));
 
   return {
     connect,

src/model/model.js

@@ -1,14 +1,6 @@
 import SQL from 'sql-template-strings';
 
-const concatValues = (items, each) => {
-  const query = SQL``;
-  items.forEach(
-    (item, index) => query
-      .append(index > 0 ? ', ' : '')
-      .append(each ? each(item) : SQL`${item}`)
-  );
-  return query;
-};
+import { concatValues } from '../helpers';
 
 const makeExec = (connect) => (action, query) => connect()
   .then(db => db[action](query));
@@ -83,7 +75,7 @@ const init = (connect) => (config) => {
   const {
     fields,
     table,
-    primaryKey = 'rowId',
+    primaryKey = 'rowid',
   } = config;
   const exec = makeExec(connect)
   const queries = makeQueries({ fields, table });

tests/features/model/getter/getter.test.js

@@ -4,7 +4,7 @@ import { getTmpDb } from 'utils';
 
 describe('Model->getters', () => {
   let vegeData, db, model;
-  beforeEach(async () => {
+  beforeAll(async () => {
     vegeData = VegeData({ filename: getTmpDb() });
 
     db = await vegeData.connect();
@@ -24,6 +24,9 @@ describe('Model->getters', () => {
         ('sangoku', 'sayan'),
         ('bulma', 'human');
     `);
+  });
+
+  beforeEach(async () => {
 
     model = vegeData.model.init({
       table: 'characters',