本文实例讲述了Node.js连接Sql Server 2008及数据层封装。分享给大家供大家参考，具体如下：
最近需要学习Node.js，所以很久没写东西了，疯狂的看了很久的书。有关于Node.js的学习知识，可以参考官网教程WWW.NODEJS.ORG,或者书籍《Node.js权威指南》。这里我记录一下Node.js连接Sql Server 2008的步骤。
Node.js连接数据库需要特定的模块msnodesql，这个模块需要特定的环境去生成才可以使用。
前期准备如下：
1.安装Node.js（官网上下载）
2.安装node-gyp（安装好node.js后进入到npm目录，执行npm install node-gyp）
3.安装python 2.7.x（WWW.PYTHON.ORG上可以下载，注意下载2.7.X版本）
4.安装Visual C++ 2010 （vs2010中必须有C++模块，也可以单独下载Microsoft）
5.安装SQL Server Native Client 11.0（http://www.microsoft.com/en-us/download/details.aspx"htmlcode">
var obj=require('msnodesql');
console.log(obj);
coby到node.exe目录下，执行node test
若不出意外则会打印msnodesql的对外接口属性。若不能正确输出，则
1.说明msnodesql安装失败或者环境美搭建好，检查上面的安装和生成步骤。
2.说明msnodesql路径没设置好：node.exe会默认去搜索node_module文件下的模块，而msnodesql本身也是一个模块，一个模块的属性是由.json来设定的，检查.json的main属性，看是否是 "main": "./lib/sql.js",sql.js才是monodesql的入口。
最后附一段操作数据库的demo作为参考：
var sql=require('msnodesql');
var conn_str="Driver={SQL Server Native Client 11.0};Server={.};Database={nodetest};uid=sa;PWD=123456;";
sql.open(conn_str, function (err, conn) {
if (err) {
console.log('发生错误');
}
sql.queryRaw(conn_str, "select * from users", function (err, results) {
if (err) {
console.log(err);
}
else {
for (var i = 0; i < results.rows.length; i++) {
console.log(results.rows[i][0] + results.rows[i][1]);
}
}
})
})
Nodejs连接sqlserver数据层封装
前面简单介绍了nodejs连接sqlserver,接下来介绍将所有数据库操作封装起来，方便项目调用的方法。
思路：所有配置参数写入xml文件，数据库操作封装起来，外部只暴露增删改查方法，方法参数只需要sql语句。
1.nodejs读取xml文件
nodejs解析xml文件需要模块libxmljs，安装：nmp install libxmljs
config.xml文件如下：
<"1.0" encoding="UTF-8""SQL Server Native Client 11.0" server="XXX" database="XXX" user="XXX" pwd="XXX">
<table name="FelixTest" />
</mydb>
</root>
建立operateXML.js:
/*
Author:
Felix.X.Zhang
Date:
2014-6-19
Introduction:
this module provides you with the operations (read) of xml file.
*/
//Async Method
/*
var libxmljs=require('libxmljs');
var fs=require('fs');
var path='./config.xml';
var param=new params();
fs.readFile(path, 'utf8', function(err, data) {
if (err) throw err;
var xmlDoc = libxmljs.parseXmlString(data);
// xpath queries
var mydb = xmlDoc.get('//mydb');
var table=xmlDoc.get('//mydb//table');
param.mydb_server=mydb.attr('server').value();
param.mydb_database=mydb.attr('database').value();
param.mydb_user=mydb.attr('user').value();
param.mydb_pwd=mydb.attr('pwd').value();
param.table_name=table.attr('name').value();
});
*/
function params(){
this.mydb_driver="";
this.mydb_server="";
this.mydb_database="";
this.mydb_user="";
this.mydb_pwd="";
this.table_name="";
}
function getParamObj(){
var libxmljs=require('libxmljs');
var fs=require('fs');
var path='./config1.xml';
var param=new params();
var data;
try{
data= fs.readFileSync(path, 'utf8');
}
catch(err){
throw err;
}
var xmlDoc = libxmljs.parseXmlString(data);
var mydb = xmlDoc.get('//mydb');
var table=xmlDoc.get('//mydb//table');
param.mydb_driver=mydb.attr('driver').value();
param.mydb_server=mydb.attr('server').value();
param.mydb_database=mydb.attr('database').value();
param.mydb_user=mydb.attr('user').value();
param.mydb_pwd=mydb.attr('pwd').value();
param.table_name=table.attr('name').value();
//console.log(param.mydb_server+" "+param.table_name);
return param;
}
exports.getParamObj=getParamObj;
方法很简单，同步读取xml文件后利用libxml模块将data解析为对象，最后将所有属性全部封装到param中。(异步读取参考上面注释段)
2.dbHelper.js
/*
Author:
Felix.X.Zhang
Date:
2014-6-21
Introduction:
this module provides you with the operations of add,del,update,select.
*/
//pre-required params
var sql = require('msnodesql');
var xml=require('../mymodule/operateXML.js');
var paramObj=xml.getParamObj();
var conn_str="Driver={"+paramObj.mydb_driver+"};Server={"+paramObj.mydb_server+"};Database={"+paramObj.mydb_database+"};uid="+paramObj.mydb_user+";PWD="+paramObj.mydb_pwd+";";
//open database
sql.open(conn_str, function (err, conn) {
if (err) {
console.log(err);
}
});
function exeScript(sqlscript){
sql.queryRaw(conn_str, sqlscript, function (err, results) {
if (err) {
console.log(err);
}
else {
console.log(results);
}
});
}
function select(sqlscript){
sql.queryRaw(conn_str, sqlscript, function (err, results) {
if (err) {
console.log(err);
}
else {
var txt=toJson(results,paramObj.table_name);
var jsonObj=eval("("+txt+")");
console.log(jsonObj);
}
});
}
function del(sqlscript){
exeScript(sqlscript);
}
function update(sqlscript){
exeScript(sqlscript);
}
function add(sqlscript){
exeScript(sqlscript);
}
//convert table to json
function toJson(dt,tbName)
{
var jsonString;
if (dt != undefined && dt.rows.length > 0)
{
var rowLen=dt.rows.length;
var colLen=dt.meta.length;
jsonString="{";
jsonString+="\""+tbName+"\":[";
for (var i = 0; i < rowLen; i++)
{
jsonString+="{";
for (var j = 0; j < colLen; j++)
{
if (j < colLen - 1)
{
jsonString+="\"" + dt.meta[j].name + "\":" + "\"" + dt.rows[i][j]+ "\",";
}
else if (j == colLen - 1)
{
jsonString+="\"" + dt.meta[j].name + "\":" + "\"" + dt.rows[i][j] + "\"";
}
}
if (i == rowLen - 1)
{
jsonString+="}";
}
else
{
jsonString+="},";
}
}
jsonString+="]}";
return jsonString;
}
return jsonString;
}
exports.add=add;
exports.del=del;
exports.update=update;
exports.select=select;
封装的db层也很简单，只有select输出json，其他只执行。
3.测试
var db=require('./dbHelper.js');
db.select("select top 10 * from FelixTest");
当然了，在实际项目中可以在调用中间加一个bll层，让具体的业务逻辑去生成sql脚本，前台不需要去组装sql，而db层也只要sqlscript。
希望本文所述对大家nodejs程序设计有所帮助。
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！
稳了！魔兽国服回归的3条重磅消息！官宣时间再确认！
昨天有一位朋友在大神群里分享，自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址，com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后，确实是网易的网址，也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情，因为以前都没有出现这样的情况，现在突然提示跳转到国服战网的网址，是不是说明了简体中文客户端已经开始进行更新了呢？
更新日志
- 凤飞飞《我们的主题曲》飞跃制作[正版原抓WAV+CUE]
- 刘嘉亮《亮情歌2》[WAV+CUE][1G]
- 红馆40·谭咏麟《歌者恋歌浓情30年演唱会》3CD[低速原抓WAV+CUE][1.8G]
- 刘纬武《睡眠宝宝竖琴童谣 吉卜力工作室 白噪音安抚》[320K/MP3][193.25MB]
- 【轻音乐】曼托凡尼乐团《精选辑》2CD.1998[FLAC+CUE整轨]
- 邝美云《心中有爱》1989年香港DMIJP版1MTO东芝首版[WAV+CUE]
- 群星《情叹-发烧女声DSD》天籁女声发烧碟[WAV+CUE]
- 刘纬武《睡眠宝宝竖琴童谣 吉卜力工作室 白噪音安抚》[FLAC/分轨][748.03MB]
- 理想混蛋《Origin Sessions》[320K/MP3][37.47MB]
- 公馆青少年《我其实一点都不酷》[320K/MP3][78.78MB]
- 群星《情叹-发烧男声DSD》最值得珍藏的完美男声[WAV+CUE]
- 群星《国韵飘香·贵妃醉酒HQCD黑胶王》2CD[WAV]
- 卫兰《DAUGHTER》【低速原抓WAV+CUE】
- 公馆青少年《我其实一点都不酷》[FLAC/分轨][398.22MB]
- ZWEI《迟暮的花 (Explicit)》[320K/MP3][57.16MB]