环境准备

引入oracledb包

oracledb是Oracle为nodejs提供的操作Oracle数据库的工具包，npm安装即可。

npm install oracledb

安装Oracle instantclient

nodejs操作Oracle数据库，需要有Oracle instantclient支持，实际操作数据库的是Oracle instantclient，而oracledb只是在和Oracle instantclient交互。

Oracle instantclient的安装步骤如下：

选择合适的版本下载，下载地址：https://www.oracle.com/database/technologies/instant-client/downloads.html

下载后解压放置到某路径下

系统环境变量Path中增加instantclient目录的路径，例：D:\application\instantclient\instantclient_18_5

重启电脑

操作数据库

初始化数据库连接

初始化单连接

import oracledb from 'oracledb'// If specified as oracledb.OUT_FORMAT_OBJECT, each row is fetched as a JavaScript object. oracledb.outFormat = oracledb.OUT_FORMAT_OBJECT// 将数值类型转为字符处理，避免数值过长，精度丢失oracledb.fetchAsString = [ oracledb.NUMBER ]let connection = await oracledb.getConnection({
       user: 'user',    password: 'password',    connectString: '127.0.0.1:1521/test'});

初始化连接池

连接池初始化后，使用方式与上面的单连接是一样的

import oracledb from 'oracledb'// If specified as oracledb.OUT_FORMAT_OBJECT, each row is fetched as a JavaScript object. oracledb.outFormat = oracledb.OUT_FORMAT_OBJECT// 将数值类型转为字符处理，避免数值过长，精度丢失oracledb.fetchAsString = [ oracledb.NUMBER ]// 可初始化多个连接池，通过poolAlias获取await oracledb.createPool({
       _enableStats: true,    user: 'user',    password: 'password',    connectString: '127.0.0.1:1521/test_a',    poolAlias: 'pool_a'})let connectionA = await oracledb.getPool('pool_a').getConnection()await oracledb.createPool({
       _enableStats: true,    user: 'user',    password: 'password',    connectString: '127.0.0.1:1521/test_b',    poolAlias: 'pool_b'})let connectionB = await oracledb.getPool('pool_b').getConnection()

执行sql语句

查询

const result = await connection.execute(    'select * from tb_test')// result.rows中便是查询的结果，row中的字段名与查询的字段名对应result.rows.forEach(row => {
       console.log(`${
     row.FIELD_A}, ${
     row.FIELD_B}`)})

修改

const result = await connection.execute(    `update tb_test t set t.field_a = :data where t.id = :id`,    ['test', '12345'],  // bind value)// result.rowsAffected是本次操作影响的行数if (result.rowsAffected == 1) {
       console.log('success')} else {
       console.error('更新数据时异常')}

插入和删除写法和修改一致，不再赘述

执行后返回的result数据结构

interface Result
   
     {
       implicitResults?: (T[] | ResultSet
    
     )[];    readonly lastRowid?: string;    metaData?: Metadata
     
      [];    outBinds?: T;    resultSet?: ResultSet
      
       ;    rows?: T[];    rowsAffected?: number;}

流式查询数据

oracledb支持流式查询数据，普通方式查询数据，会将所有数据一次性全部获取到缓存中，而如果数据量过大，操作响应时间非常长，而且可能导致内存溢出，这种情况就适合用流式查询。

流式查询时每次只会获取fetchArraySize设置的数量的数据进行处理，可避免内存溢出，同时数据库压力也小。

// 流式获取所有数据let stream = connection.queryStream(    `SELECT * from tb_test`,    [],  // bind value    {
    fetchArraySize: 10000 }  //每次预取长度，默认100，这里设置增大以提升性能);// 绑定异常回调事件stream.on('error', function (error) {
       throw new Error(error)});// 绑定元数据回调事件// 元素据可获取表字段信息等数据库表描述信息，查询操作开始会触发一次stream.on('metadata', function (metadata) {
       console.log(`tb_test表字段总数: ${
     metadata.length}`);});// 绑定行数据回调事件// 每次获取到数据都会触发该事件，数据的长度和fetchArraySize设置的一致stream.on('data', function (data) {
       console.log(data.length)});// 绑定获取结束回调事件stream.on('end', function () {
       });

转载地址：http://fvtlf.baihongyu.com/

你可能感兴趣的文章

【托业】【新东方托业全真模拟】TEST07~08-----P5~6