diff options
| author | dujinkim <dujin.kim@dtsolution.co.kr> | 2025-05-21 10:04:19 +0000 |
|---|---|---|
| committer | dujinkim <dujin.kim@dtsolution.co.kr> | 2025-05-21 10:04:19 +0000 |
| commit | 11061af33d325546e075b37923845881ded0e6f6 (patch) | |
| tree | a35951bc68a691f8cdd92af7ddc0efeaa70b8e31 /lib/oracle-knex/db.ts | |
| parent | d583c7912d9934e0550908b74a7eba8bdbb46953 (diff) | |
(김준회) Oracle DB 지원을 위한 라이브러리(oracledb, knex.js) 추가 및 번들러 버그 패치
Diffstat (limited to 'lib/oracle-knex/db.ts')
| -rw-r--r-- | lib/oracle-knex/db.ts | 68 |
1 files changed, 68 insertions, 0 deletions
diff --git a/lib/oracle-knex/db.ts b/lib/oracle-knex/db.ts new file mode 100644 index 00000000..fe61f0a2 --- /dev/null +++ b/lib/oracle-knex/db.ts @@ -0,0 +1,68 @@ +import knex from 'knex'; +// import oracledb from 'oracledb'; +const oracledb = require('oracledb'); + +// Knex Oracle 연결 생성 +export const oracleKnex = knex({ + client: 'oracledb', + connection: { + user: process.env.ORACLE_USER, + password: process.env.ORACLE_PASSWORD, + connectString: process.env.ORACLE_CONNECTION_STRING, + }, + pool: { min: 0, max: 5 } +}); + +// OracleDB 직접 연결 생성 함수 +export async function getOracleConnection() { + try { + const connection = await oracledb.getConnection({ + user: process.env.ORACLE_USER, + password: process.env.ORACLE_PASSWORD, + connectString: process.env.ORACLE_CONNECTION_STRING + }); + + return connection; + } catch (error) { + console.error('Oracle DB 연결 오류:', error); + throw error; + } +} + +// 연결을 테스트하는 함수 +export async function testOracleConnection() { + try { + const connection = await getOracleConnection(); + const result = await connection.execute('SELECT 1 FROM DUAL'); + await connection.close(); + return { + success: true, + message: 'Oracle DB 연결 성공', + data: result.rows + }; + } catch (error: any) { + return { + success: false, + message: 'Oracle DB 연결 실패', + error: error instanceof Error ? error.message : '알 수 없는 오류' + }; + } +} + +// Knex를 사용하여 Oracle 연결 테스트 +export async function testKnexOracleConnection() { + try { + const result = await oracleKnex.raw('SELECT 1 FROM DUAL'); + return { + success: true, + message: 'Knex Oracle DB 연결 성공', + data: result + }; + } catch (error: any) { + return { + success: false, + message: 'Knex Oracle DB 연결 실패', + error: error instanceof Error ? error.message : '알 수 없는 오류' + }; + } +}
\ No newline at end of file |
