1 |
|
2 | import * as oracledb from 'oracledb';
|
3 | import IConnection = oracledb.IConnection;
|
4 | import IExecuteReturn = oracledb.IExecuteReturn;
|
5 | import IExecuteOptions = oracledb.IExecuteOptions;
|
6 | import IResultSet = oracledb.IResultSet;
|
7 | import IConnectionAttributes = oracledb.IConnectionAttributes;
|
8 | import { IConnectionPool } from "oracledb";
|
9 | import { IDbService } from "./db_service";
|
10 | export declare const DB_CONNECT_ERROR: string;
|
11 | export declare const DB_ORACLE_ERROR: string;
|
12 | export declare const DB_ORACLE_FETCH_ERROR: string;
|
13 | export declare const DB_ORACLE_CLOSE_ERROR: string;
|
14 | export declare const DB_ORACLE_RELEASE_ERROR: string;
|
15 | export declare const DB_ORACLE_EXECUTE_ERROR: string;
|
16 | export declare class OracleService implements IDbService {
|
17 | poolMax: number;
|
18 | maxQueryAttempts: number;
|
19 | protected connectionParams: IConnectionAttributes;
|
20 | protected options: IExecuteOptions;
|
21 | protected pool: IConnectionPool;
|
22 | protected _queryFailsCounter: any;
|
23 | constructor(connectionParams: IConnectionAttributes, options?: IExecuteOptions);
|
24 | run(query: string, params?: Array<any>, options?: IExecuteOptions): Promise<IExecuteReturn>;
|
25 | getManyRows(query: string, params?: Array<any>): Promise<IExecuteReturn>;
|
26 | fetchRows(resultSet: IResultSet, numRows: number): Promise<Array<any>>;
|
27 | closeResultSet(resultSet: IResultSet, connection?: IConnection): Promise<void>;
|
28 | getRows(query: string, params?: Array<any>, options?: IExecuteOptions): Promise<Array<any>>;
|
29 | getRow(query: string, params?: Array<any>, options?: IExecuteOptions): Promise<any>;
|
30 | mustGetRow(errorCode: string, query: string, params?: Array<any>, options?: IExecuteOptions): Promise<any>;
|
31 | protected _connect(): Promise<IConnection>;
|
32 | protected _disconnect(connection: IConnection): Promise<void>;
|
33 | protected _run(query: string, params?: object | Array<any>, options?: IExecuteOptions): Promise<IExecuteReturn>;
|
34 | protected _needRetry(runArguments: IArguments, error: any): boolean;
|
35 | }
|