Node.js+Sequelize环境下Oracle数据库CLOB转字符串求助

方法一：纯JavaScript读取CLOB内容 #

针对cu8-sequelize-oracle返回的CLOB对象，可通过异步读取的方式转换为字符串：

async function convertClobToString(clob) {
  if (!clob) return '';
  // 处理带read方法的CLOB流对象
  if (typeof clob.read === 'function') {
    let content = '';
    let chunk;
    while ((chunk = await clob.read())) {
      content += chunk.toString();
    }
    return content;
  }
  // 处理已缓冲的CLOB对象
  return clob.toString ? clob.toString() : String(clob);
}

// 使用示例
const results = await YourModel.findAll();
const processedResults = await Promise.all(results.map(async item => ({
  ...item.toJSON(),
  targetClobField: await convertClobToString(item.targetClobField)
})));

方法二：通过oracledb配置自动转换 #

cu8-sequelize-oracle底层依赖oracledb，可在连接配置中开启CLOB自动转字符串：

const oracledb = require('oracledb');
const Sequelize = require('sequelize');

const sequelize = new Sequelize({
  dialect: 'oracle',
  dialectModule: require('cu8-sequelize-oracle'),
  dialectOptions: {
    connectString: '你的Oracle连接串',
    user: '数据库用户名',
    password: '数据库密码',
    // 配置自动将CLOB转为字符串
    fetchAsString: [oracledb.CLOB]
  }
});

执行npm install oracledb完成依赖安装。

方法三：Sequelize模型钩子统一处理 #

在模型的afterFind钩子中批量转换CLOB字段：

const { DataTypes, Sequelize } = require('sequelize');

const YourModel = sequelize.define('YourModel', {
  targetClobField: {
    type: DataTypes.CLOB,
    allowNull: true
  }
}, {
  hooks: {
    afterFind: async (result) => {
      // 处理单实例（findOne返回结果）
      if (!Array.isArray(result)) {
        if (result.targetClobField) {
          result.targetClobField = await convertClobToString(result.targetClobField);
        }
        return;
      }
      // 处理实例数组（findAll返回结果）
      await Promise.all(result.map(async item => {
        if (item.targetClobField) {
          item.targetClobField = await convertClobToString(item.targetClobField);
        }
      }));
    }
  }
});

内容的提问来源于stack exchange，提问作者Melika Shojaee