DML

/* --------------------------------------------------------------------------------
파일 이름 : dml.pc
개발 일자 : 2002-10-28
작성자 : 류명환
-------------------------------------------------------------------------------- */
#include <stdio.h>
#include <stdlib.h>

/*
 * $ORACLE_HOME/precomp/public/sqlca.h 를 포함해 주기 위해서
 */
exec sql include sqlca;

/*
* 호스트 변수 선언
*/
exec sql begin declare section;
    /*
     * 사용자 ID와 패스워드
     */
    char *username;
    char *password;

    /*
     * emp 테이블의 칼럼 리스트
     */
    int empno;
    int mgr;
    int sal;
    int comm;
    int deptno;
    char *ename;
    char *job;
    char *hiredate;

    /*
     * emp 테이블 칼럼들의 Indicator 변수
     */
    short ind_empno;
    short ind_mgr;
    short ind_sal;
    short ind_comm;
    short ind_deptno;
    short ind_ename;
    short ind_job;
    short ind_hiredate;
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);
}

/*
 * Standard Input 에서 문자열을 받아서 저장하는 함수
 * 입력이 없으면 -1을 리턴한다.
*/
int get_value (char *buf, char *prompt)
{
    printf (prompt);
    fgets (buf, 256, stdin);
    /*
     * \r\n을 제거한다.
     */
    buf [strlen (buf) - 1] = '\0';

    if (strlen (buf) == 0)
    {
        return -1;
    }
    else
    {
        return 0;
    }
}

/*
 * 데이터베이스에 접속하고 Insert, Update, Delete를
 * 진행한 후 접속을 종료한다.
 */
int main (void)
{
char buf [256];

    printf ("Input Data to Insert\n");

    ind_empno = get_value (buf, "Empno (Max 4) : ");
    empno = atoi (buf);

    ind_ename = get_value (buf, "Ename (Max 10) : ");
    ename = (char *)strdup (buf);

    ind_job = get_value (buf, "Job (Max 10) : ");
    job = (char *)strdup (buf);

    ind_mgr = get_value (buf, "Manager (Max 4) : ");
    mgr = atoi (buf);

    ind_sal = get_value (buf, "Salary (Max 7) : ");
    sal = atoi (buf);

    ind_comm = get_value (buf, "Comm (Max 7) : ");
    comm = atoi (buf);

    ind_deptno = get_value (buf, "Deptno (Max 2) : ");
    deptno = atoi (buf);

    /*
     * 사용자 ID와 Password를 설정하고 데이타베이스에 접속하고
     * sqlca.sqlcode 를 통해 에러가 있는지 검사한다.
     */
    username = (char *)strdup ("scott");
    password = (char *)strdup ("tiger");
    exec sql
        connect :username identified by :password;
    if (sqlca.sqlcode != 0)
    {
        sql_error ();
    }
    printf ("Connected to Oracle Database\n");

    /*
     * Insert 를 수행한다. 칼럼 값 뒤에 Indicator를 붙여서
* NULL이 있을 경우 정확히 NULL을 넣도록 한다.
* sqlca.sqlcode 를 사용하여 SQL 실행에 에러가 있었는지 검사한다.
*/
    exec sql
        insert into emp
        values (:empno:ind_empno, :ename:ind_ename, :job:ind_job, :mgr:ind_mgr,
                sysdate, :sal:ind_sal, :comm:ind_comm, :deptno:ind_deptno);
    if (sqlca.sqlcode != 0)
    {
        sql_error ();
    }
    printf ("Inserted to Emp table in Oracle Database\n");

    /*
     * Insert 한 후에 데이터를 적용한다.
* 이때 데이터베이스와 접속이 끊어지지 않도록 주의한다.
*/
    exec sql
        commit work;
    if (sqlca.sqlcode != 0)
    {
        sql_error ();
    }

printf ("Input Data to Update\nSalary Increase and Comm Increase\n");

    ind_empno = get_value (buf, "Empmo (Max 4) : ");
    empno = atoi (buf);

    ind_sal = get_value (buf, "Sal (Max 7) : ");
    sal = atoi (buf);

    ind_comm = get_value (buf, "Comm (Max 7) : ");
    comm = atoi (buf);

    /* 
     * Update 한다.
     * 데이터를 적용하기전에 SQL 문장이 잘 실행되었나 검사한다.
     */
    exec sql
        update emp
        set sal = :sal:ind_sal, comm = :comm:ind_comm
        where empno = :empno;
    if (sqlca.sqlcode != 0)
    {
        sql_error ();
    }

    printf ("Updated to Emp table in Oracle Database\n");

    /*
     * 변경된 데이터 적용한다.
     */
    exec sql
        commit work;
    if (sqlca.sqlcode != 0)
    {
        sql_error ();
    }

    printf ("Input Data to Delete\n");
    /*
     * 삭제할 사람의 사원 번호를 입력 받는다.
     */
    ind_empno = get_value (buf, "Empmo (Max 4) : ");
    empno = atoi (buf);

    /*
   * Delete 한다. 역시 SQL 실행 결과를 검사한다.
   */
    exec sql
        delete from emp
        where empno = :empno;
    if (sqlca.sqlcode != 0)
    {
        sql_error ();
    }

printf ("Deleted from Emp table in Oracle Database\n");

    /*
     * 변경된 데이터를 적용한다.
     */
    exec sql
        commit work;
    if (sqlca.sqlcode != 0)
    {
        sql_error ();
    }

    /*
     * 데이터베이스와 접속을 종료한다.
     * Rollback 으로 접속을 종료한 것은 특별한 이유는 없다. ^^
     */
    exec sql
        rollback work release;
    if (sqlca.sqlcode != 0)
    {
        sql_error ();
    }
    printf ("Disconnect from Oracle Database\n");

    exit (EXIT_SUCCESS);
}