介绍
Node.js是一个非常流行的JavaScript运行时环境，被广泛应用于服务器端开发。在Node.js中，可以使用各种第三方模块来处理与数据库的交互。本文将介绍如何使用Node.js模块操作MSSQL数据库。
安装依赖
在使用Node.js操作MSSQL数据库之前，需要先安装相应的依赖包。常用的依赖包是mssql。可以使用以下命令进行安装：
npm install mssql
连接数据库
连接MSSQL数据库需要提供以下信息：
服务器名称
数据库名称
用户名
密码
代码示例：
const sql = require('mssql') // 导入mssql模块
const config = {
server: 'localhost', // 服务器名称
database: 'test', // 数据库名称
user: 'sa', // 用户名
password: '123456', // 密码
port: 1433, // 端口号
options: {
encrypt: false
}
}
const pool = new sql.ConnectionPool(config)
pool.connect(err => {
if (err) {
throw err // 连接失败抛出异常
}
console.log('Connected successfully')
// do something with the connection
})
pool.on('error', err => {
console.log(err) // 处理连接错误
})
代码解析：
首先导入mssql模块。
创建一个配置对象，该对象包含要连接的数据库的服务器名称、数据库名称、用户名、密码和端口号等信息。
创建一个ConnectionPool对象，该对象用于管理一组与数据库的连接。
通过ConnectionPool对象的connect方法连接数据库。如果出现错误，会抛出异常。
如果连接成功，可以进行后续的数据库操作。
如果连接出现错误，可以通过ConnectionPool对象的error事件进行处理。
查询数据
查询数据是使用MSSQL数据库最基本的操作之一。在Node.js中，也可以通过mssql模块来实现这个功能。以下是一个简单的查询示例：
const sql = require('mssql')
const config = {
// ...
}
const pool = new sql.ConnectionPool(config)
pool.connect(err => {
if (err) {
throw err
}
const request = new sql.Request(pool)
request.query('SELECT * FROM [users]', (err, result) => {
if (err) {
throw err
}
console.log(result.recordset)
})
})
代码解析：
首先导入mssql模块。
创建一个ConnectionPool对象，并在连接成功后创建一个Request对象。
调用Request对象的query方法查询数据库，该方法接受两个参数：要执行的SQL语句以及回调函数。回调函数接受两个参数：错误对象和结果对象。
如果查询成功，结果对象的recordset属性包含了查询结果。
查询中的参数
在实际的开发过程中，很少直接使用字符串拼接的方式来拼接SQL语句。相反，可以使用参数化查询来避免SQL注入等问题。
以下是一个使用参数化查询的示例：
const sql = require('mssql')
const config = {
// ...
}
const pool = new sql.ConnectionPool(config)
pool.connect(err => {
if (err) {
throw err
}
const request = new sql.Request(pool)
// 定义查询参数
const id = 1
const name = '张三'
// 执行参数化查询
request.input('id', sql.Int, id)
request.input('name', sql.NVarChar, name)
request.query('SELECT * FROM [users] WHERE id=@id AND name=@name', (err, result) => {
if (err) {
throw err
}
console.log(result.recordset)
})
})
代码解析：
参数化查询需要使用Request对象的input方法为查询定义参数。该方法接受三个参数：参数名、参数类型和参数值。
在SQL语句中使用@符号定义参数名。
使用参数化查询可以避免SQL注入等问题。
插入数据
插入数据是MSSQL数据库中的另一个基本操作。在Node.js中，也可以使用mssql模块来实现插入操作。以下是一个简单的插入示例：
const sql = require('mssql')
const config = {
// ...
}
const pool = new sql.ConnectionPool(config)
pool.connect(err => {
if (err) {
throw err
}
const request = new sql.Request(pool)
// 定义要插入的数据
const user = {
id: 1,
name: '张三',
age: 20
}
// 执行插入操作
request.query("INSERT INTO [users] (id, name, age) VALUES (@id, @name, @age)", user, (err, result) => {
if (err) {
throw err
}
console.log(result.rowsAffected)
})
})
代码解析：
首先导入mssql模块。
创建一个ConnectionPool对象，并在连接成功后创建一个Request对象。
定义要插入的数据。
执行插入操作，Request对象的query方法将第二个参数传递给SQL语句中的参数。如果插入成功，结果对象的rowsAffected属性将包含受影响的行数。
更新数据
更新数据是MSSQL数据库中的另一个基本操作。在Node.js中，可以使用mssql模块来实现更新操作。以下是一个简单的更新示例：
const sql = require('mssql')
const config = {
// ...
}
const pool = new sql.ConnectionPool(config)
pool.connect(err => {
if (err) {
throw err
}
const request = new sql.Request(pool)
// 定义要更新的数据
const user = {
id: 1,
name: '李四',
age: 21
}
// 执行更新操作
request.query("UPDATE [users] SET name=@name, age=@age WHERE id=@id", user, (err, result) => {
if (err) {
throw err
}
console.log(result.rowsAffected)
})
})
代码解析：
首先导入mssql模块。
创建一个ConnectionPool对象，并在连接成功后创建一个Request对象。
定义要更新的数据。
执行更新操作，Request对象的query方法将第二个参数传递给SQL语句中的参数。如果更新成功，结果对象的rowsAffected属性将包含受影响的行数。
删除数据
删除数据是MSSQL数据库中的另一个基本操作。在Node.js中，也可以使用mssql模块来实现删除操作。以下是一个简单的删除示例：
const sql = require('mssql')
const config = {
// ...
}
const pool = new sql.ConnectionPool(config)
pool.connect(err => {
if (err) {
throw err
}
const request = new sql.Request(pool)
// 定义要删除的数据
const user = {
id: 1
}
// 执行删除操作
request.query("DELETE FROM [users] WHERE id=@id", user, (err, result) => {
if (err) {
throw err
}
console.log(result.rowsAffected)
})
})
代码解析：
首先导入mssql模块。
创建一个ConnectionPool对象，并在连接成功后创建一个Request对象。
定义要删除的数据。
执行删除操作，Request对象的query方法将第二个参数传递给SQL语句中的参数。如果删除成功，结果对象的rowsAffected属性将包含受影响的行数。
常见问题解答
连接错误：错误描述中包含“Login failed for user”
出现这种错误的原因是无法通过提供的用户名和密码来登录到数据库。
检查用户名和密码是否正确。
检查连接字符串中的服务器名称和数据库名称是否正确。
如果使用Windows身份验证，尝试使用用户名和密码方式进行认证。
确保网络连接正常，可以通过Ping命令测试服务器连接状态。
连接错误：错误描述中包含“Network-related or instance-specific error”
出现这种错误的原因是网络连接错误或服务器名称无法解析。
确保网络连接正常，可以通过Ping命令测试服务器连接状态。
检查连接字符串中的服务器名称和数据库名称是否正确。
如果使用Windows身份验证，尝试使用用户名和密码方式进行认证。
如果使用网络别名连接服务器，确保网络别名已设置。
如果SQL Server实例未启动，启动SQL Server实例。
查询时出现“Cannot read property 'recordset' of undefined”错误
出现这种错误的原因是查询没有返回结果对象。
检查SQL语句是否正确。
检查是否在查询后立即回调函数（查询是异步执行的）。
确保查询结果包含记录集（result.recordset属性）。
插入、更新或删除时出现“RequestError: No rows were affected by the last statement.”错误
出现这种错误的原因是没有任何数据被影响。
检查SQL语句是否正确。
确保操作针对的表中存在符合条件的数据。
插入数据时出现“RequestError: The incoming tabular data stream (TDS) remote procedure call (RPC) protocol stream is incorrect.”错误
出现这种错误的原因是数据类型不匹配。
确保传递给查询的参数类型与实际要插入的数据类型相匹配。
检查数据库表结构中每一列的数据类型是否正确。
总结
本文介绍了如何使用mssql模块在Node.js中操作MSSQL数据库。首先介绍了连接数据库的基本方式，然后分别介绍了查询、插入、更新和删除数据的方法。最后，还介绍了一些常见问题的解决方法。