百度360必应搜狗淘宝本站头条
php redisredis 命令oracle位图索引redis 锁启动 redis
当前位置：网站首页 > 技术教程 > 正文

Deno 操作 Oracle 数据库全解析:从入门到精通的实战指南

mhr18 2025-06-12 14:38 28 浏览 0 评论

在企业级应用开发中，Oracle 数据库凭借其强大的功能、高可靠性和安全性，一直是大型系统的首选数据存储方案。Deno 作为新一代 JavaScript/TypeScript 运行时，以安全、高效和现代的特性备受开发者青睐。如何将 Deno 与 Oracle 数据库相结合，实现高效的数据交互？本文将从基础入门到进阶技巧，全面解析 Deno 操作 Oracle 数据库的方法，助力你打造高性能的数据库应用。

一、基础入门教程

1. 环境准备与安装

在开始使用 Deno 操作 Oracle 数据库前，需完成一系列准备工作。首先，从 Oracle 官方网站下载并安装 Instant Client，它提供了连接 Oracle 数据库所需的库文件 。安装完成后，根据系统类型配置环境变量：在 Linux/Unix 系统中，设置ORACLE_HOME指向 Instant Client 安装目录，并将LD_LIBRARY_PATH添加该目录下的lib文件夹路径；在 Windows 系统中，直接将 Instant Client 路径添加到系统PATH变量。

完成 Oracle 客户端配置后，在 Deno 项目中引入第三方驱动deno-oracledb。在 Deno 脚本文件开头添加如下代码：

import oracledb from 'https://deno.land/x/oracledb/mod.ts';

运行脚本时，Deno 会自动下载并缓存该模块。

2. 建立数据库连接

连接 Oracle 数据库需要提供连接字符串、用户名和密码等信息。连接字符串格式为主机名/服务名，示例代码如下：

async function connectToOracle() {

try {

const connection = await oracledb.getConnection({

user: 'your_username',

password: 'your_password',

connectString: 'localhost/XE'

});

console.log('成功连接到Oracle数据库');

await connection.close();

} catch (error) {

console.error('连接数据库失败:', error);

}

}

connectToOracle();

运行上述代码时，由于涉及网络和环境变量操作，需添加相应权限：

deno run --allow-net --allow-env your_script.ts

3. 执行基本 SQL 查询

连接成功后，即可执行 SQL 查询语句。查询和插入数据示例如下：

查询数据

async function executeQuery() {

const connection = await oracledb.getConnection({/* 连接配置 */});

try {

const result = await connection.execute(

'SELECT * FROM employees WHERE department_id = :deptId',

[10]

);

console.log('查询结果行数:', result.rows?.length);

console.log('查询结果:', result.rows);

} finally {

await connection.close();

}

}

上述代码中，使用占位符:deptId绑定参数，避免 SQL 注入风险。

插入数据

async function insertData() {

const connection = await oracledb.getConnection({/* 连接配置 */});

try {

const result = await connection.execute(

'INSERT INTO employees (employee_id, first_name, last_name, email) ' +

'VALUES (:id, :fname, :lname, :email)',

{

id: 1001,

fname: 'John',

lname: 'Doe',

email: 'john.doe@example.com'

},

{ autoCommit: true }

);

console.log('插入的行数:', result.rowsAffected);

} finally {

await connection.close();

}

}

这里通过对象形式传递参数，并设置autoCommit: true自动提交事务。

4. 处理查询结果

Oracle 查询结果以数组形式返回，每行数据也是一个数组。通过元数据可获取列名，示例如下：

async function processResults() {

const connection = await oracledb.getConnection({/* 连接配置 */});

try {

const result = await connection.execute('SELECT * FROM employees');

const columnNames = result.metaData.map(column => column.name);

console.log('列名:', columnNames);

if (result.rows) {

for (const row of result.rows) {

console.log('行数据:', row);

}

}

} finally {

await connection.close();

}

}

二、进阶教程

1. 事务处理

Oracle 支持事务操作，确保一组操作的原子性。示例如下：

async function executeTransaction() {

const connection = await oracledb.getConnection({/* 连接配置 */});

try {

await connection.execute(

'UPDATE accounts SET balance = balance - 100 WHERE account_id = 1',

[],

{ autoCommit: false }

);

await connection.execute(

'UPDATE accounts SET balance = balance + 100 WHERE account_id = 2',

[],

{ autoCommit: false }

);

await connection.commit();

console.log('事务提交成功');

} catch (error) {

await connection.rollback();

console.error('事务回滚:', error);

} finally {

await connection.close();

}

}

先将autoCommit设为false，执行多个 SQL 语句后，根据执行情况决定提交或回滚事务。

2. 批量操作

对于大量数据插入或更新，批量操作可显著提升性能：

async function batchInsert() {

const connection = await oracledb.getConnection({/* 连接配置 */});

try {

const data = [

[1001, 'Alice', 'Smith'],

[1002, 'Bob', 'Johnson'],

[1003, 'Charlie', 'Williams']

];

const result = await connection.executeMany(

'INSERT INTO employees (employee_id, first_name, last_name) ' +

'VALUES (:1, :2, :3)',

data,

{ autoCommit: true }

);

console.log('批量插入的行数:', result.rowsAffected);

} finally {

await connection.close();

}

}

executeMany方法一次执行多条 SQL 语句，减少与数据库的交互次数。

3. 存储过程与函数调用

Oracle 的存储过程和函数可通过 Deno 调用。

调用存储过程

async function callProcedure() {

const connection = await oracledb.getConnection({/* 连接配置 */});

try {

await connection.execute(

'BEGIN add_employee(:id, :fname, :lname); END;',

{

id: 1004,

fname: 'David',

lname: 'Brown'

}

);

console.log('存储过程执行成功');

} finally {

await connection.close();

}

}

调用函数

async function callFunction() {

const connection = await oracledb.getConnection({/* 连接配置 */});

try {

const result = await connection.execute(

'SELECT get_employee_count(:deptId) FROM DUAL',

{ deptId: 20 },

{ outFormat: oracledb.OUT_FORMAT_OBJECT }

);

console.log('部门20的员工数量:', result.rows[0][0]);

} finally {

await connection.close();

}

}

三、实用技巧

1. 连接池管理

使用连接池可提高性能和资源利用率：

async function initConnectionPool() {

try {

await oracledb.createPool({

user: 'your_username',

password: 'your_password',

connectString: 'localhost/XE',

poolMin: 2,

poolMax: 10,

poolIncrement: 1

});

console.log('连接池初始化成功');

} catch (error) {

console.error('连接池初始化失败:', error);

}

}

async function getConnectionFromPool() {

const connection = await oracledb.getConnection();

return connection;

}

预先创建一定数量的连接，需要时直接获取，减少连接创建时间。

2. 性能优化建议

  • 使用绑定变量：减少 SQL 解析时间，提升执行效率，同时防范 SQL 注入。
  • 优化查询语句：添加合适索引，避免全表扫描；使用EXPLAIN PLAN分析查询执行计划，针对性优化。
  • 批量处理数据：尽量使用executeMany等方法，减少与数据库的交互次数。
  • 合理配置连接池：根据应用负载，调整连接池的最小、最大连接数和增量，避免连接过多或过少。

3. 错误处理与调试

完善的错误处理有助于快速定位问题：

async function safeDatabaseOperation() {

let connection;

try {

connection = await oracledb.getConnection({/* 连接配置 */});

await connection.execute('SELECT * FROM non_existent_table');

} catch (error) {

if (error instanceof Error) {

console.error('Oracle错误:', error.message);

console.error('错误代码:', error.code);

console.error('错误堆栈:', error.stack);

} else {

console.error('未知错误:', error);

}

} finally {

if (connection) {

try {

await connection.close();

} catch (closeError) {

console.error('关闭连接失败:', closeError);

}

}

}

}

捕获错误后，打印详细信息，便于排查问题。

4. 安全最佳实践

  • 最小权限原则：为数据库用户分配最小必要权限，降低数据泄露风险。
  • 避免硬编码凭证：使用环境变量、配置文件或密钥管理工具存储数据库密码，防止密码泄露。
  • 输入验证：对所有用户输入进行严格验证和过滤，防止 SQL 注入攻击。
  • 定期备份：建立完善的数据库备份机制，定期备份数据，防止数据丢失 。

通过本文的学习，你已掌握 Deno 操作 Oracle 数据库的核心技术，从基础连接到进阶应用，再到实用技巧。这些知识将帮助你构建高效、可靠、安全的企业级应用，充分发挥 Deno 与 Oracle 数据库的强大性能。

相关推荐

订单超时自动取消业务的 N 种实现方案，从原理到落地全解析

在分布式系统架构中，订单超时自动取消机制是保障业务一致性的关键组件。某电商平台曾因超时处理机制缺陷导致日均3000+订单库存锁定异常，直接损失超50万元/天。本文将从技术原理、实现细节、...

使用Spring Boot 3开发时，如何选择合适的分布式技术?

作为互联网大厂的后端开发人员，当你满怀期待地用上SpringBoot3，准备在项目中大显身手时，却发现一个棘手的问题摆在面前：面对众多分布式技术，究竟该如何选择，才能让SpringBoot...

数据库内存爆满怎么办?99%的程序员都踩过这个坑!

你的数据库是不是又双叒叕内存爆满了？！服务器监控一片红色警告，老板在群里@所有人，运维同事的电话打爆了手机...这种场景是不是特别熟悉？别慌！作为一个在数据库优化这条路上摸爬滚打了10年的老司机，今天...

springboot利用Redisson 实现缓存与数据库双写不一致问题

使用了Redisson来操作Redis分布式锁，主要功能是从缓存和数据库中获取商品信息，以下是针对并发时更新缓存和数据库带来不一致问题的解决方案1.基于读写锁和删除缓存策略在并发更新场景下，...

外贸独立站数据库炸了?对象缓存让你起死回生

上周黑五，一个客户眼睁睁看着服务器CPU飙到100%——每次页面加载要查87次数据库。这让我想起2024年Pantheon的测试：Redis缓存能把WooCommerce查询速度提升20倍。跨境电商最...

手把手教你在 Spring Boot3 里纯编码实现自定义分布式锁

为什么要自己实现分布式锁？你是不是早就受够了引入各种第三方依赖时的繁琐？尤其是分布式锁这块，每次集成Redisson或者Zookeeper，都得额外维护一堆配置，有时候还会因为版本兼容问题头疼半...

如何设计一个支持百万级实时数据推送的WebSocket集群架构?

面试解答：要设计一个支持百万级实时数据推送的WebSocket集群架构，需从**连接管理、负载均衡、水平扩展、容灾恢复**四个维度切入：连接层设计-**长连接优化**：采用Netty或Und...

Redis数据结构总结——面试最常问到的知识点

Redis作为主流的nosql存储，面试时经常会问到。其主要场景是用作缓存，分布式锁，分布式session，消息队列，发布订阅等等。其存储结构主要有String，List，Set，Hash，Sort...

skynet服务的缺陷 lua死循环

服务端高级架构—云风的skynet这边有一个关于云风skynet的视频推荐给大家观看点击就可以观看了！skynet是一套多人在线游戏的轻量级服务端框架，使用C+Lua开发。skynet的显著优点是，...

七年Java开发的一路辛酸史:分享面试京东、阿里、美团后的心得

前言我觉得有一个能够找一份大厂的offer的想法，这是很正常的，这并不是我们的饭后谈资而是每个技术人的追求。像阿里、腾讯、美团、字节跳动、京东等等的技术氛围与技术规范度还是要明显优于一些创业型公司...

mysql mogodb es redis数据库之间的区别

1.MySQL应用场景概念：关系型数据库,基于关系模型,使用表和行存储数据。优点：支持ACID事务,数据具有很高的一致性和完整性。缺点：垂直扩展能力有限,需要分库分表等方式扩展。对于复杂的查询和大量的...

redis，memcached，nginx网络组件

1.理解阻塞io，非阻塞io，同步io，异步io的区别2.理解BIO和AIO的区别io多路复用只负责io检测，不负责io操作阻塞io中的write，能写多少是多少，只要写成功就返回，譬如准备写500字...

SpringBoot+Vue+Redis实现验证码功能

一个小时只允许发三次验证码。一次验证码有效期二分钟。SpringBoot整合Redis...

AWS MemoryDB 可观测最佳实践

AWSMemoryDB介绍AmazonMemoryDB是一种完全托管的、内存中数据存储服务，专为需要极低延迟和高吞吐量的应用程序而设计。它与Redis和Memcached相似，但具有更...

从0构建大型AI推荐系统:实时化引擎从工具到生态的演进

在AI浪潮席卷各行各业的今天，推荐系统正从幕后走向前台，成为用户体验的核心驱动力。本文将带你深入探索一个大型AI推荐系统从零起步的全过程，揭示实时化引擎如何从单一工具演进为复杂生态的关键路径。无论你是...

取消回复欢迎 你 发表评论:

一周热门
最近发表
标签列表
赣ICP备2024040476号-7