/* -------------------------------------------------------------------------------- 
파일 이름 : plsql.pc 
개발 일자 : 2002-10-28 
작성자 : 류명환 
-------------------------------------------------------------------------------- */ 
 
#include <stdio.h> 
#include <stdlib.h> 
#include <stdlib.h> 
 
/* 
 * $ORACLE_HOME/precomp/public/sqlca.h 를 포함해 주기 위해서 
 */ 
exec sql include sqlca; 
 
/* 
 * 호스트 변수 선언 
 */ 
exec sql begin declare section; 
    /* 
     * 사용자 ID와 패스워드 
     */ 
    char *username; 
    char *password; 
 
/* 
 * DB와 연동할 호스트 변수 
 */ 
char deptno [128]; 
int avg_sal; 
int max_sal; 
int min_sal; 
 
/* 
 * Indicator 변수 
 */ 
short ind_deptno; 
short ind_avg_sal; 
short ind_max_sal; 
short ind_min_sal;     
exec sql end declare section; 
 
 
/* 
 * SQL 에러 발생시 실행할 함수 
 * 에러코드를 프린트 하고 롤백 후에 접속을 종료한다. 
 */ 
void sql_error (void) 
{ 
    printf ("SQL Error Code : %d\n", sqlca.sqlcode); 
    printf ("SQL Error Message : %s\n", sqlca.sqlerrm.sqlerrmc); 
 
    exec sql whenever sqlerror continue; 
    exec sql rollback work release; 
 
    exit (EXIT_FAILURE); 
} 
 
 
/* 
 * 메인 함수 
 */ 
int main (int argc, char **argv) 
{ 
    username = (char *)strdup ("scott"); 
    password = (char *)strdup ("tiger"); 
 
    /* 
     * scott 사용자 계정으로 접속 시도 
     * 접속 시도 후에 성공 여부를 위해 에러를 검사한다. 
     */ 
    exec sql 
        connect :username identified by :password; 
    if (sqlca.sqlcode != 0) 
    { 
        sql_error (); 
    } 
    printf ("Connected to Oracle Database\n"); 
 
/* 
 * DB에 Procedure를 생성한다. 
 * Procedure의 내용은 부서번호를 입력받아서 
 * 그 부서의 평균급여, 최고급여, 최저급여를 얻어온다. 
 */ 
exec sql 
    create or replace 
        procedure dept_salary_info 
        ( 
        p_deptno in dept.deptno%type,   /* 부서번호 */ 
        p_salary_avg out number,        /* 평균급여 */ 
        p_salary_max out number,        /* 최고급여 */ 
        p_salary_min out number         /* 최저급여 */ 
        ) 
    is 
    begin 
        /* 
         * 해당 부서의 평균급여, 최고급여, 최저급여를 
         * 구하여 Out Parameter 변수에 넣어준다. 
         */ 
        select    round (avg (sal + nvl (comm, 0)), 0) average, 
            round (max (sal + nvl (comm, 0)), 0) maximum, 
            round (min (sal + nvl (comm, 0)), 0) minimum 
        into    p_salary_avg, 
            p_salary_max, 
            p_salary_min 
        from    emp 
        where   deptno = p_deptno; 
 
        exception 
        /* 
         * 해당 부서가 없는 경우 
         */ 
        when no_data_found then 
        p_salary_avg := 0; 
        p_salary_max := 0; 
        p_salary_min := 0; 
 
        /* 
         * 알 수 없는 에러가 발생한 경우 
         */ 
        when others then 
        p_salary_avg := 0; 
        p_salary_max := 0; 
        p_salary_min := 0; 
 
end dept_salary_info; 
end-exec; 
 
if (sqlca.sqlcode != 0) 
{ 
    sql_error (); 
} 
 
printf ("Procedure created\n\n"); 
 
/* 
 * 부서번호를 얻어온다. 
 */ 
printf ("Deptno : "); 
fgets (deptno, sizeof (deptno) - 1, stdin); 
deptno [strlen (deptno) - 1] = '\0'; 
ind_deptno = 0; 
 
/* 
 * 위에서 생성한 프로시저를 호출하여 입력받은 
 * 부서의 평균급여, 최고급여, 최저급여를 얻어온다. 
 */ 
exec sql 
    execute 
        begin 
        dept_salary_info 
        ( 
            :deptno:ind_deptno, 
            :avg_sal:ind_avg_sal, 
            :max_sal:ind_max_sal, 
            :min_sal:ind_min_sal 
        ); 
        end; 
    end-exec; 
 
if (sqlca.sqlcode != 0) 
{ 
    sql_error (); 
} 
     
/* 
 * 각 값들이 NULL 이라면 0으로 셋팅한다. 
 */ 
if (ind_avg_sal == -1) avg_sal = 0; 
if (ind_max_sal == -1) max_sal = 0; 
if (ind_min_sal == -1) min_sal = 0; 
 
printf ("Average Salary : %d\n", avg_sal); 
printf ("Maximum Salary : %d\n", max_sal); 
printf ("Minimum Salary : %d\n", min_sal); 
 
    /* 
     * 데이터베이스와 접속을 종료한다. 
     */ 
    exec sql 
        rollback work release; 
    if (sqlca.sqlcode != 0) 
    { 
        sql_error (); 
    } 
 
    exit (EXIT_SUCCESS); 
}