mengmakies / mssqlhelper

nodejs Microsoft SQL Server Helper nodejs的一个用于连接mssql数据库的工具类

nodejs Microsoft SQL Server Helper

nodejs的一个用于连接mssql数据库的工具类

说明一下，lib目录的tds是第三库，原作者已经不更新了，年代久远，地址也无从知晓。 请慎重使用！

Features 介绍

• 采用微软tds协议，不需要任何C/C++扩展，跨平台使用
• 执行sql语句，获得结果行
• 执行存储过程，获得输出参数以及结果行

TODO 待实现内容

• 将支持获得多个结果集（Table）
• 将支持连接池
• 更多性能加强

Use 使用

    $ git clone [email protected]:play175/mssqlhelper.git
    $ cd mssqlhelper
    $ node test.js

Example 测试代码

var db = require('./index');

db.config({
    host: '192.168.1.100'
	,port: 1433
	,userName: 'sa'
	,password: '123'
	,database:'testdb'
});

//test query sql 执行sql

db.query(
	'select @Param1 Param1,@Param2 Param2'
	,{
		 Param1: { type : 'NVarChar', size: 7,value : 'myvalue' }
		 ,Param2: { type : 'Int',value : 321 }
	}
	,function(res){
		if(res.err)throw new Error('database error:'+res.err.msg);
		var rows = res.tables[0].rows;
		for (var i = 0; i < rows.length; i++) {
			console.log(rows[i].getValue(0),rows[i].getValue('Param2'));
		}
	}
);

//test excute sp 执行存储过程

db.exec(
	'test_sp'
	,{
		 Param1: {direction:'out', type : 'NVarChar', size: 50,value : 'my Param1 value' }
		 ,Param2: { type : 'Int',value : 123 }
		 ,Param3: {direction:'out', type : 'VarChar', size: 50,value : '789' }
	}
	,function(res){
		if(res.err)throw new Error('database error:'+res.err.msg);

		//get output paramater value
		console.log('output @Param1='+res.params.Param1.value);

		//get rows
		var rows = res.tables[0].rows;
		for (var i = 0; i < rows.length; i++) {
			var rp = '';
			for(var j=0,len = rows[i].metadata.columns.length;j<len;j++){
				var col = rows[i].metadata.columns[j];
				rp += ' ' +(rows[i].getValue(j));
			}
			console.log(rp);
		}
	}
);

///////////////////////////////问题和解决方案//////////////////////////////////////

问题/Issues：

1：不能输出匿名列，比如select *

2：如果不能排序，比如 select a from table oerder by b desc，目前的解决方法：

	;with result as(
		SELECT Actor,ActorName FROM [GameActor] order by time desc
	)
	select * from result

3：输出中文乱码，引发这个问题有几个方面，解决方法：

（1）把所有js文件用utf-8编码保存

（2）数据库中含有中文的字段，必须是unicode类型，比如varchar应该改为nvarchar

4:在多进程cluster的的使用：

	var db = require('./index');	
	var cluster = require('cluster');	
	if (cluster.isMaster) {
	    var numCPUs = require('os').cpus().length;
	    for (var i = 0; i < numCPUs; i++) {
	        var worker = cluster.fork();
	    }
	} else {
	    db.config(..);
	    db.query(..);
	}