node 连接oracle 编写接口 发送请求
时间: 2024-04-28 10:19:29 浏览: 116
首先,你需要安装 `oracledb` 模块来连接 Oracle 数据库,可以使用 `npm` 命令进行安装:
```
npm install oracledb
```
接下来,你可以编写一个 Node.js 的接口来发送请求并连接 Oracle 数据库,示例代码如下:
```javascript
const oracledb = require('oracledb');
const express = require('express');
const app = express();
const port = 3000;
// 连接数据库
async function connect() {
try {
await oracledb.createPool({
user: 'USERNAME',
password: 'PASSWORD',
connectString: 'HOST:PORT/SID'
});
console.log('Connected to Oracle database');
} catch (err) {
console.error(err);
}
}
// 查询数据库
async function query(sql, params) {
let connection;
let result;
try {
connection = await oracledb.getConnection();
result = await connection.execute(sql, params);
} catch (err) {
console.error(err);
} finally {
if (connection) {
try {
await connection.close();
} catch (err) {
console.error(err);
}
}
}
return result;
}
// 定义接口
app.get('/api/query', async (req, res) => {
const sql = 'SELECT * FROM TABLE_NAME';
const result = await query(sql, []);
res.send(result);
});
// 启动服务
app.listen(port, () => {
console.log(`Server is running on port ${port}`);
connect();
});
```
在以上代码中,我们使用 `oracledb` 模块来连接数据库并发送查询请求。首先,我们通过 `createPool` 方法创建一个连接池,并在 `getConnection` 方法中获取连接对象,然后通过 `execute` 方法执行 SQL 查询语句。最后,在查询结束后,我们关闭连接池。
接口部分,我们定义了一个 `/api/query` 接口,当接收到请求时,我们执行 SQL 查询语句并将结果返回给客户端。最后,我们启动 Node.js 服务并监听 3000 端口。
当你运行该代码后,你可以通过访问 http://localhost:3000/api/query 来获取数据库查询结果。
阅读全文