Add mssql dialect and replace playground with GraphiQL

.eslintignore

@@ -1,2 +1,3 @@
 templates/public/js
 steps/ast-builders/templates/node-def-es6.js
+node_modules/

.node-version

@@ -0,0 +1 @@
+10.13.0

.prettierignore

@@ -0,0 +1,3 @@
+dist
+*.json
+node_modules/

.prettierrc

@@ -0,0 +1,6 @@
+{
+    "trailingComma": "none",
+    "semi": false,
+    "singleQuote": true,
+    "printWidth": 100
+}

README.md

@@ -9,8 +9,8 @@ Generate GraphQL schemas and server based on SQL table structure.
 `sql-to-graphql` is a command-line utility that can help you get started. You give it the credentials to an SQL database (MySQL, PostgreSQL and SQLite currently) and it will inspect the tables it finds and do the following:
 
 - Generate GraphQL-types for each table (including resolvers)
-- Generate an HTTP-server based on Hapi that accepts GraphQL queries
-- Sets up a basic web-frontend that lets you query the server
+- Generate an HTTP-server based on Express that accepts GraphQL queries
+- Exposes a graphiql playground to query the server
 
 ## Disclaimer
 
@@ -28,7 +28,6 @@ This utility is intended to help people get started with GraphQL. It is **NOT**
 
   - `--relay`, `-r` - Generate Relay-style schema *`(boolean [default: false])`*
   - `--output-dir`, `-o` - Directory to use when generating app *`(string [required])`*
-  - `--es6` - Use ES6 for generated code *`(boolean [default: false])`*
   - `--database`, `--db` - Database name *`(string [required])`*
   - `--db-filename` - Database filename, used for SQLite *`(string)`*
   - `--host`, `-h` - Hostname of database server *`(string [default: "localhost"])`*

backends/index.js

@@ -1,13 +1,14 @@
-'use strict';
+'use strict'
 
-var adapters = {
-    mysql: require('./mysql'),
-    postgres: require('./postgres'),
-    pg: require('./postgres'),
-    sqlite: require('./sqlite')
-};
+const adapters = {
+  mssql: require('./mssql'),
+  mysql: require('./mysql'),
+  postgres: require('./postgres'),
+  pg: require('./postgres'),
+  sqlite: require('./sqlite')
+}
 
 module.exports = function getBackendAdapter(db) {
-    var backend = (db || '<not set>').toLowerCase();
-    return adapters[backend];
-};
+  var backend = (db || '<not set>').toLowerCase()
+  return adapters[backend]
+}

backends/mssql.js

@@ -0,0 +1,167 @@
+/* eslint camelcase: 0 */
+'use strict'
+
+const knex = require('knex')
+const mapKeys = require('lodash/mapKeys')
+const contains = require('lodash/includes')
+const camelCase = require('lodash/camelCase')
+const pluck = require('lodash/map')
+
+module.exports = function mssqlBackend(opts, callback) {
+    const mssql = knex({
+        client: 'mssql',
+        connection: opts
+    })
+
+    opts.stripPrefix = ['dbo.']
+
+    process.nextTick(callback)
+
+    return {
+        getTables: function(tableNames, cb) {
+            const matchAll = tableNames.length === 1 && tableNames[0] === '*'
+
+            // omit dbo. from table name if dbo schema selected
+            const tablename_expr = `table_schema + '.' + table_name`
+            // `case when table_schema = 'dbo' then table_name else
+            //                 table_schema + '.' + table_name end`
+
+            let sql = mssql
+                .select(mssql.raw(tablename_expr + ' as name'))
+                .from('information_schema.tables')
+                .where('table_type', 'BASE TABLE')
+            if (opts.schemas !== '*') {
+                sql = sql.whereIn('table_schema', opts.schemas.split(','))
+            }
+
+            sql.catch(cb).then(function(tbls) {
+                tbls = pluck(tbls, 'name')
+                if (!matchAll) {
+                    tbls = tbls.filter(function(tbl) {
+                        return contains(tableNames, tbl)
+                    })
+                }
+                cb(null, tbls)
+            })
+        },
+
+        getTableComment: function(tableName, cb) {
+            // return cb(null, '')
+            const sql = `
+                select CAST(ep.value AS sql_variant) AS comment
+                FROM sys.tables as tbl
+                INNER JOIN sys.extended_properties AS ep
+                on tbl.object_id = ep.major_id
+                where tbl.object_id = object_id('${tableName}')
+                and ep.minor_id = 0
+              `
+            mssql
+                .raw(sql)
+                .catch(cb)
+                .then(function(comments) {
+                    comments = pluck(comments, 'comment')
+                    cb(null, comments[0])
+                })
+        },
+
+        getTableStructure: function(tableName, cb) {
+            var ref_tableNameExpr = `rs.name + '.' + rt.name`
+            // `case when rs.name = 'dbo' then rt.name else
+            //                 rs.name + '.' + rt.name end`
+
+            var sql = `with ref_cols as (
+                select ${ref_tableNameExpr} as ref_table_name,
+                      fkc.parent_column_id as fk_column_id,
+                      rc.name as ref_column_name,
+                      count(*) over(partition by fk.name) as num_ref_cols
+                FROM sys.foreign_keys AS fk
+                inner join sys.foreign_key_columns as fkc
+                on fkc.constraint_object_id = fk.object_id
+                inner join  sys.columns AS rc
+                    ON fkc.referenced_column_id = rc.column_id
+                    AND fkc.referenced_object_id = rc.[object_id]
+                INNER JOIN sys.tables AS rt -- referenced table
+                  ON fk.referenced_object_id = rt.[object_id]
+                INNER JOIN sys.schemas AS rs 
+                  ON rt.[schema_id] = rs.[schema_id]
+                where fk.parent_object_id = object_id('${tableName}')
+            ),
+            single_fk_cols as (
+              select *
+              from ref_cols
+              where num_ref_cols = 1
+            ),
+            pk_cols as (
+              SELECT c.column_id,
+                     ic.key_ordinal,
+                     count(*) over() as num_pk_cols
+              FROM sys.indexes i
+              join sys.index_columns ic on i.object_id = ic.object_id
+                                       and i.index_id = ic.index_id
+              join sys.columns as c on ic.object_id = c.object_id
+                                   and ic.column_id = c.column_id
+              where i.object_id = object_id('${tableName}')
+              and i.is_primary_key = 1
+            ),
+            single_pk_cols as (
+              select *
+              from pk_cols
+              where num_pk_cols = 1
+            ),
+            col as (select c.name as column_name,
+                            column_id,
+                            c.is_nullable,
+                            c.is_identity,
+                            st.name as data_type,
+                            CAST(ep.value AS sql_variant) as column_comment
+                    from sys.columns as c
+                    left join sys.extended_properties AS ep
+                    on c.object_id = ep.major_id
+                    and c.column_id = ep.minor_id
+                    and ep.class_desc = 'OBJECT_OR_COLUMN'
+                    join sys.types as st
+                    on st.user_type_id = c.system_type_id
+                    where c.object_id = object_id('${tableName}')
+            )
+
+            select '${tableName}' as [table],
+                  col.column_name,
+                  col.column_id as ordinal_position,
+                  col.is_nullable,
+                  col.is_identity as is_auto_increment,
+                  col.data_type,
+                  column_comment,
+                  ref_table_name,
+                  fk_cols.ref_column_name,
+                  case when pk_cols.column_id is null
+                    then null
+                    else 'PRI'
+                  end as columnKey
+            from col
+            left join single_fk_cols as fk_cols
+            on col.column_id = fk_cols.fk_column_id
+            left join single_pk_cols as pk_cols
+            on col.column_id = pk_cols.column_id
+            order by col.column_id  
+                  `
+            mssql
+                .raw(sql)
+                .catch(cb)
+                .then(function(info) {
+                    // info.fieldName = table.fieldName
+                    // info.dbTableName = table.dbTableName
+                    cb(null, (info || []).map(camelCaseKeys))
+                })
+        },
+
+        close: function(cb) {
+            mssql.destroy(cb)
+        }
+    }
+}
+
+function camelCaseKeys(obj) {
+    return mapKeys(obj, function(val, key) {
+        return camelCase(key)
+    })
+}

backends/mysql.js

@@ -1,24 +1,24 @@
 /* eslint camelcase: 0 */
-'use strict';
+'use strict'
 
-var knex = require('knex');
-var pluck = require('lodash/collection/pluck');
-var mapKeys = require('lodash/object/mapKeys');
-var contains = require('lodash/collection/includes');
-var camelCase = require('lodash/string/camelCase');
-var undef;
+const knex = require('knex')
+const pluck = require('lodash/map')
+const mapKeys = require('lodash/mapKeys')
+const contains = require('lodash/includes')
+const camelCase = require('lodash/camelCase')
+let undef
 
 module.exports = function mysqlBackend(opts, callback) {
-    var mysql = knex({
+    const mysql = knex({
         client: 'mysql',
         connection: opts
-    });
+    })
 
-    process.nextTick(callback);
+    process.nextTick(callback)
 
     return {
         getTables: function(tableNames, cb) {
-            var matchAll = tableNames.length === 1 && tableNames[0] === '*';
+            const matchAll = tableNames.length === 1 && tableNames[0] === '*'
 
             mysql
                 .select('table_name')
@@ -27,16 +27,16 @@ module.exports = function mysqlBackend(opts, callback) {
                 .where('table_type', 'BASE TABLE')
                 .catch(cb)
                 .then(function(tbls) {
-                    tbls = pluck(tbls, 'table_name');
+                    tbls = pluck(tbls, 'table_name')
 
                     if (!matchAll) {
                         tbls = tbls.filter(function(tbl) {
-                            return contains(tableNames, tbl);
-                        });
+                            return contains(tableNames, tbl)
+                        })
                     }
 
-                    cb(null, tbls);
-                });
+                    cb(null, tbls)
+                })
         },
 
         getTableComment: function(tableName, cb) {
@@ -49,8 +49,8 @@ module.exports = function mysqlBackend(opts, callback) {
                 })
                 .catch(cb)
                 .then(function(info) {
-                    cb(null, info ? info.comment || undef : undef);
-                });
+                    cb(null, info ? info.comment || undef : undef)
+                })
         },
 
         getTableStructure: function(tableName, cb) {
@@ -73,31 +73,18 @@ module.exports = function mysqlBackend(opts, callback) {
                 .orderBy('ordinal_position', 'asc')
                 .catch(cb)
                 .then(function(info) {
-                    cb(null, (info || []).map(camelCaseKeys));
-                });
-        },
-
-        hasDuplicateValues: function(table, column, cb) {
-            mysql
-                .count(column + ' as hasSameValues')
-                .from(table)
-                .groupBy(column)
-                .having('hasSameValues', '>', 1)
-                .limit(1)
-                .catch(cb)
-                .then(function(info) {
-                    cb(null, (info || []).length > 0);
-                });
+                    cb(null, (info || []).map(camelCaseKeys))
+                })
         },
 
         close: function(cb) {
-            mysql.destroy(cb);
+            mysql.destroy(cb)
         }
-    };
-};
+    }
+}
 
 function camelCaseKeys(obj) {
     return mapKeys(obj, function(val, key) {
-        return camelCase(key);
-    });
+        return camelCase(key)
+    })
 }