Better schema

Author: visnup

lib/snowflake.js

@@ -5,7 +5,6 @@ import snowflake from "snowflake-sdk";
 
 export default url => {
   url = new URL(url);
-  console.log(url);
   const {host: account, username, password, pathname, searchParams} = new URL(
     url
   );
@@ -66,25 +65,23 @@ export default url => {
   };
 };
 
-// https://www.postgresql.org/docs/9.6/datatype.html
+// https://github.com/snowflakedb/snowflake-connector-nodejs/blob/master/lib/connection/result/data_types.js
 const array = ["null", "array"],
   boolean = ["null", "boolean"],
-  // integer = ["null", "integer"],
+  integer = ["null", "integer"],
   number = ["null", "number"],
   object = ["null", "object"],
   string = ["null", "string"];
 function dataTypeSchema(column) {
-  // https://github.com/snowflakedb/snowflake-connector-nodejs/blob/master/lib/connection/result/data_types.js
   switch (column.getType()) {
     case "binary":
       return {type: object, buffer: true};
     case "boolean":
       return {type: boolean};
     case "fixed":
     case "real":
-      return {type: number};
+      return {type: column.getScale() ? number : integer};
     case "date":
-    case "time":
     case "timestamp_ltz":
     case "timestamp_ntz":
     case "timestamp_tz":
@@ -94,6 +91,7 @@ function dataTypeSchema(column) {
       return {type: object};
     case "array":
       return {type: array, items: {type: object}};
+    case "time":
     case "text":
     default:
       return {type: string};