node.js + mssql 简单封装操作

发布时间：2023-03-11 12:41:17 所属栏目：教程来源：

导读：时间吧，总是这么凑巧，在我学习【node.js】还没几天，我的 Microsoft sql Server Management Studio 18 就歇菜了，至于怎么歇菜的吧....它可能的意思就是想让我换电脑了... 所以为了解决问题，就写了这个小东西满足

时间吧，总是这么凑巧，在我学习【node.js】还没几天，我的 Microsoft sql Server Management Studio 18 就歇菜了，至于怎么歇菜的吧....它可能的意思就是想让我换电脑了... 所以为了解决问题，就写了这个小东西满足需求；
....咳咳咳....

回归正题，开始最简易的封装数据操作。

首先老样子,先安装：

安装方法

npm install mssql
引入依赖

///引入依赖
const mssql = require('mssql');
配置Config

其实这里的config，和后端程序配置的web.config基本是一个意思。（可忽略 0.0）

code：

///引入依赖
const mssql = require('mssql');

//方法对象
const units = {
sql: function (sql, callback) {
///连接池
new mssql.ConnectionPool(units.config())
.connect()
.then(pool => {
let ps = new mssql.PreparedStatement(pool);
ps.prepare(sql, err => {
if (err) {
console.log(err);
return;
}
ps.execute('', (err, result) => {
if (err) {
console.log(err);
return;
}
ps.unprepare(err => {
if (err) {
console.log(err);
callback(err, null);
return;
}
callback(err, result);
});
});
});
}).catch(err => {
console.log("Database Connection Failed! Bad Config:", err);
});
},
/*
* 默认config对象
* @type {{user: string, password: string, server: string, database: string, pool: {min: number, idleTimeoutMillis: number}}}
*/
config: function () {
return {
user: 'sa', //sql Server 的登录名
password: '123456', //sql Server 的登录密码
server: 'localhost', //sql Server 的地址
database: 'sale', //数据库名称
port: 1433, //端口号，默认为1433
pool: {
min: 0, //连接池最小连接数，默认0
max: 10, //连接池最大连接数，默认10
idleTimeoutMillis: 3000 //设置关闭未使用连接的时间，单位ms默认30000
},
/*--其他属性--*/
// connectionTimeout： //连接timeout，单位ms 默认 15000
// requestTimeout： //请求timeout，单位ms默认15000
// parseJSON： //将json数据集转化成json obj
}
}
}

module.exports = units;
此上面这段代码就可以封装为一个命名为：helper.js(名字随意)。

然后就可以在其他的js里面来调用这个封装好的‘方法’：

const helper = require('./helper');
接下来就是写最基本的参数化批量：insert丶select丶update 丶delete ：

const helper = require('./helper');
/*
* 查询所有
* @param tableName
* @param result
*/
helper.sql('select * from dbo.tableName where 1 = 1', function (err, result) {
if (err) {
console.log(err);
return;
}
console.log('data :', result);
});

/*
* 修改
* @param updateObj 修改内容（必填）
* @param whereObj 修改对象（必填）
* @param tableName 表名
* @param callBack(err,recordset)
*/
helper.sql("update dbo.tableName set name = @updateObj where id = @whereObj", err => {
if (err) {
console.log("error:" + err);
return;
} else {
console.log('Ok!');
}
});

/*
* 添加
* @param addobj 添加对象（必填）
* @param tableName 表名
* @param callBack(err,recordset)
*/
helper.sql("insert into dbo.tableName(obj)values(@addobj)", err => {
if (err) {
console.log("error:" + err);
} else {
console.log("Ok!");
}
})

/*
* 删除
* @param whereObj 删除对象（必填）
* @param tableName 表名
* @param callBack(err,recordset)
*/
helper.sql("delete dbo.tableName where 1 = 1 and id = @whereObj", err => {
if (err) {
console.log("error:" + err);
} else {
console.log("Ok!");
}
})
以上就实现了最简易的node.js + mssql的使用。

越努力，越幸运。

<style></style>

（编辑：汽车网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!