Class OracleConnection

packages/oracledb/src/OracleConnection.ts:46–398

}

export class OracleConnection extends AbstractSqlConnection {
  private oraclePool?: oracledb.Pool;
  // Resolves `password` callbacks per acquire so `callRoutine` doesn't bypass password rotation.
  private acquireOracleConnection?: () => Promise<oracledb.Connection>;

  override async createKyselyDialect(overrides: PoolAttributes): Promise<OracleDialect> {
    const options = this.mapOptions(overrides);
    const password = options.password as ConnectionConfig['password'];
    const onCreateConnection = this.options.onCreateConnection ?? this.config.get('onCreateConnection');

    const initialPassword = typeof password === 'function' ? await password() : password;

    const poolOptions = {
      ...options,
      password: initialPassword,
      sessionCallback: onCreateConnection as PoolAttributes['sessionCallback'],
    };

    // Retry pool creation for transient Oracle errors (e.g. ORA-01017 under load)
    let pool: oracledb.Pool;
    const maxRetries = 3;

    for (let attempt = 1; ; attempt++) {
      try {
        pool = await oracledb.createPool(poolOptions);
        this.oraclePool = pool;
        break;
        /* v8 ignore start: transient Oracle pool-creation errors are not reproducible in tests */
      } catch (e: any) {
        if (attempt < maxRetries && (e.errorNum === 1017 || e.errorNum === 12514 || e.errorNum === 12541)) {
          await new Promise(resolve => setTimeout(resolve, 250 * attempt));
          continue;
        }

        throw e;
      }
      /* v8 ignore stop */
    }

    const executeOptions: ExecuteOptions = {
      fetchTypeHandler: metaData => {
        const bigInt = metaData.dbType === oracledb.DB_TYPE_NUMBER && (metaData.precision ?? 0) > 10;
        metaData.name = metaData.name.toLowerCase();

        if (bigInt || metaData.dbType === oracledb.DB_TYPE_CLOB) {
          return {
            type: oracledb.DB_TYPE_VARCHAR,
          };
        }

        if (metaData.dbType === oracledb.DB_TYPE_BLOB) {
          return {
            type: oracledb.BUFFER,
          };
        }

        return undefined;
      },