sql server optional

Author: David Gómez Matarrodona

doc/inputs/sqlserver.md

@@ -0,0 +1,63 @@
+## SQL Server Input
+
+Permite la lectura de registros de tablas de Microsoft SQL Server
+
+## Examples
+
+Lectura de una table con seguridad integrada.
+```json
+"inputs": {      
+	"sqlserver": {
+		"type": "sqlserver",
+		"config": {
+			"query": "select TOP (1000) [Index],[Height_Inches],[Weight_Pounds] from hw_25000 where [Index] > ${Index}",
+			"watermark": {"Index": 0},
+			"mode": "watermark",
+			"options": {
+				"database": "LogsDB",
+				"server": "localhost",
+				"pool": {
+					"max": 10,
+					"min": 0,
+					"idleTimeoutMillis": 30000
+				},
+				"options": {
+					"trustedConnection": false,
+				}
+			}
+		}
+	}
+}
+```
+
+## Configuration parameters
+* **query** : Consulta SQL sobra la que se obtienen los registros (filas). Es parametrizable, usando como valores los atributos del último registro leido. Inicialmente, al no haber "ultimo registro", se usa el objeto *watermark*
+* **watermark** : Fila inicial para la parametrización de la consulta. Las posteriores ejecuciones usarán el último registro leido.
+* **mode** : Puede ser **start** or **watermark**. Cuando es **start**, el input siempre inicia usando como último registro el objeto *watermark* especificado. En caso de usar el modo **watermark**, las posteriores ejecuciones usarán el último registro leído.
+* **options** : Opciones de conexión y configuración del acceso a SQL Server. Se puede ver la especificación completa en [http://tediousjs.github.io/tedious/api-connection.html#function_newConnection](http://tediousjs.github.io/tedious/api-connection.html#function_newConnection)
+
+## Output
+Cada lectura generará un objeto con el siguiente esquema:
+```javascript
+{
+	id : '<input ID>',
+	type : 'sqlserver',
+	database: '<dbname>',
+	originalMessage : '<String value or JSON object>'
+}
+```
+
+### Ejemplo
+```json
+{
+	"id":"sqlserver",
+	"type":"sqlserver",
+	"database":"LogsDB",
+	"input":"sqlserver",
+	"originalMessage":{
+		"Index":26100,
+		"Height_Inches":4739,
+		"Weight_Pounds":7900
+	}
+}
+```

lib/input/sqlserver.js

@@ -190,6 +190,7 @@ if(module.parent) {
 else {
 	logger.setLevel('debug');
 
+	/*
 	async function test()  {
 		const config = {
 			query : 'select TOP (1000) [Index],[Height_Inches],[Weight_Pounds] from hw_25000 where [Index] > ${Index}',
@@ -225,7 +226,51 @@ else {
 	}
 
 	test();
+*/
+
+async function test()  {
+	const sqlConfig = {
+	//domain : "GRUPOICA", 
+		user: "david.gomez",
+		password: "",
+		database: "LogsDB",
+		server: 'GICA-MAD-671',
+		pool: {
+			max: 10,
+			min: 0,
+			idleTimeoutMillis: 30000
+		},
+		options: {
+			trustedConnection: true,			  
+			encrypt: false, // for azure
+			trustServerCertificate: true // change to true for local dev / self-signed certs
+		}
+	}	
+
+	try {
+		let pool = await sql.connect(sqlConfig);
+		
+		let mreq = await pool.request();
+		let max = await mreq.query('SELECT MAX([Index]) as WM from hw_25000');
+		let idx =  max.recordset[0].WM;
+
+		for(let i=0;i<1000;i++) {
+			idx++;
+			let v1 = Math.floor(Math.random()*10000);
+			let v2 = Math.floor(Math.random()*10000);
+			let req = await pool.request();
+			await req.query(`insert into hw_25000 ([Index],Height_Inches,Weight_Pounds) values (${idx},${v1},${v2})`);
+			process.stdout.write('.');
+			await timer(300);
+		}
+		console.log('DONE');
+		process.exit(0);
+	}catch(err) {
+		console.error(err);
+	}
+}
 
+test();
 
 /*
 	async function test()  {

package.json

@@ -61,8 +61,6 @@
     "minimatch": "^3.0.4",
     "mkdirp": "^0.5.1",
     "mongodb": "^3.3.3",
-    "msnodesqlv8": "^2.2.0",
-    "mssql": "^7.2.1",
     "node-forge": "^0.10.0",
     "nools": "^0.4.4",
     "nsyslog-parser": "^0.9.6",
@@ -81,6 +79,10 @@
     "xml2js": "^0.4.19",
     "yallist": "^4.0.0"
   },
+  "optionalDependencies": {
+    "msnodesqlv8": "^2.2.0",
+    "mssql": "^7.2.1"
+  },
   "devDependencies": {
     "@pixi/jsdoc-template": "^2.4.3",
     "@types/mongodb": "^3.3.11",