本文实例讲述了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程序设计有所帮助。
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
RTX 5090要首发 性能要翻倍!三星展示GDDR7显存
三星在GTC上展示了专为下一代游戏GPU设计的GDDR7内存。
首次推出的GDDR7内存模块密度为16GB,每个模块容量为2GB。其速度预设为32 Gbps(PAM3),但也可以降至28 Gbps,以提高产量和初始阶段的整体性能和成本效益。
据三星表示,GDDR7内存的能效将提高20%,同时工作电压仅为1.1V,低于标准的1.2V。通过采用更新的封装材料和优化的电路设计,使得在高速运行时的发热量降低,GDDR7的热阻比GDDR6降低了70%。