DpackGetData/util/db_sqlserver.js

const sql = require('mssql');

var util = require('../util/util.js');
var log = require('../util/log.js');

module.exports.connectDPACK = async function connectDPACK(){
	try{
		var configjs = util.getConfig();
		var config = configjs.database_dpack;
		config.connectionTimeout = parseInt(config.connectionTimeout);
		config.requestTimeout = parseInt(config.requestTimeout);

		var configPool = {
		    user: config.user,
		    password: config.password,
		    server: config.server, // You can use 'localhost\\instance' to connect to named instance
		    database: config.database,
		    connectionTimeout : config.connectionTimeout,
		    requestTimeout : config.requestTimeout,		 
		    options: {
		        tdsVersion: '7_1'
		    }
		}

		const pool1 = new sql.ConnectionPool(configPool).connect();
		// sql.connect(config, function(err){
		//  if (err){
		//  	res.json(err);
		//  }         
		// });
		//await pool1;

		return await pool1;
	}
	catch(e){
		log.createLog(0,e.message);
		util.throwNotif(e.message)
		return {"STATUS":0};
	}

}

module.exports.connectCollection = async function connectCollection(){
	try{
		var configjs = util.getConfig();
		var config = configjs.database_collection;
		config.connectionTimeout = parseInt(config.connectionTimeout);
		config.requestTimeout = parseInt(config.requestTimeout);

		var configPool = {
		    user: config.user,
		    password: config.password,
		    server: config.server, // You can use 'localhost\\instance' to connect to named instance
		    database: config.database,
		    connectionTimeout : config.connectionTimeout,
		    requestTimeout : config.requestTimeout,		 
		    options: {
		        tdsVersion: '7_1'
		    }
		}

		const pool2 = new sql.ConnectionPool(configPool).connect();

		return await pool2;
	}
	catch(e){
		log.createLog(0,e.message);
		util.throwNotif(e.message)
		return {"STATUS":0};
	}

}

module.exports.checkDataType = async function checkDataType(dataType){
	// 0 = varchar
	// 1 = numeric
	// 2 = datetime

	if(dataType == sql.Char || dataType == sql.NChar || dataType == sql.Text || dataType == sql.NText || dataType == sql.VarChar || dataType == sql.NVarChar || dataType == sql.Xml){
		return 0;
	}
	else if(dataType == sql.Bit || dataType == sql.BigInt || dataType == sql.Decimal || dataType == sql.Float || dataType == sql.Int || dataType == sql.Money || dataType == sql.Numeric
		|| dataType == sql.SmallInt || dataType == sql.SmallMoney || dataType == sql.Real || dataType == sql.TinyInt){
		return 1;
	}
	else if(dataType == sql.Time || dataType == sql.Date || dataType == sql.DateTime || dataType == sql.DateTime2 || dataType == sql.DateTimeOffset || dataType == sql.SmallDateTime){
		return 2;
	}
}