4.EmbeddedSQL_PL_SQL here

EXEC SQL BEGIN DECLARE SECTION;
  varchar username [20];
  varchar password [20];
  varchar dbname [20];
EXEC SQL END DECLARE SECTION;
… … …

  strcpy (username.arr, “SCOTT”);
  strcpy (password.arr, “TIGER”);
  strcpy (dbname.arr,   “ORCL” );
  username.len = strlen (“SCOTT”);
  password.len = strlen (“TIGER”);
  dbname.len   = strlen (“ORCL” );

… … …
  
  EXEC SQL CONNECT :username IDENTIFIED BY :password USING :dbname;

/* 호스트 변수의 선언 시작 */
EXEC SQL BEGIN DECLARE SECTION;
  int empno;              /* emp 테이블의 empno를 받을 변수 */
  char ename[10];         /* emp 테이블의 ename을 받을 변수 */
  char jog[10];    /* emp 테이블의 job  을 받을 변수 */
  float sal;              /* emp 테이블의 sal  을 받을 변수 */
  float comm;             /* emp 테이블의 comm 을 받을 변수 */
EXEC SQL EBD DECLARE SECTION;
/* 호스트 변수의 선언 종료 */

… … …

/*
 * empno를 얻어와서 해당하는 사람의 이름과 급여, 상여를 받아온다.
 */
empno = atoi (gets ());
EXEC SQL
SELECT ename, job, sal, comm
INTO :ename, :job, :sal, :comm
  FROM emp
  WHERW empno = :empno;

/*
 * 얻어온 급여와 상여를 수정하여 다시 업데이트 한다.
 */
sal  = sal  + 3000;
comm = comm + 1000;
EXEC SQL
  UPDATE emp
  SET sal = :sal, comm = :comm.
  WHERE empno = :empno;

EXEC SQL BEGIN DECLARE SECTION; /* 호스트 변수의 선언 시작 */
  int empno;              /* emp 테이블의 empno를 받을 변수 */
  char ename[10];         /* emp 테이블의 ename을 받을 변수 */
  char job[10];    /* emp 테이블의 job  을 받을 변수 */
  float sal;              /* emp 테이블의 sal  을 받을 변수 */
  float comm;             /* emp 테이블의 comm 을 받을 변수 */
  short ind_empno;  /* empno변수의 INDICATOR */
  short ind_ename;  /* ename변수의 INDICATOR */
  short ind_job;    /* job  변수의 INDICATOR */
  short ind_sal;    /* sal  변수의 INDICATOR */
  short ind_comm;    /* comm 변수의 INDICATOR */
EXEC SQL END DECLARE SECTION;   /* 호스트 변수의 선언 종료 */

… … …

/*
 * empno를 얻어와서 해당하는 사람의 이름과 급여, 상여를 받아온다.
 */
empno = atoi (gets ());
EXEC SQL
SELECT ename, job, sal, comm
INTO :ename:ind_ename, :job:ind_job, :sal:ind_sal, :comm:ind_comm
FROM emp
WHERE empno = :empno;

/*
 * 얻어온 급여와 상여를 수정하여 다시 업데이트 한다.
 */
(ind_sal  == -1) ? sal  = 3000 : sal  = sal  + 3000;
(ind_comm == -1) ? comm = 1000 : comm = comm + 1000;
EXEC SQL
  UPDATE emp
  SET sal = :sal, comm = :comm.
  WHERE empno = :empno;

EXEC SQL BEGIN DECLARE SECTION;
  int deptno;
  char dname[10];
  char loc[10];
EXEC SQL END DECLARE SECTION;


/*
 * 부서번호가 50번인 새로운 부서를 Insert 한다.
 */
deptno = 50;
strcpy (dname, “MANAGER”);
strcpy (loc, “SEOUL”);
EXEC SQL
INSERT INTO DEPT 
  VALUES (:deptno, :dname, :loc);

EXEC SQL BEGIN DECLARE SECTION;
  Int deptno;
EXEC SQL END DECLARE SECTION;

/*
 * 부서번호가 50인 부서의 부서번호를 60번으로 변경한다.
 */
EXECL SQL 
UPDATE DEPT
  SET deptno = 60
  WHERE deptno = 50;

… … …

/*
 * 부서번호가 60인 부서를 삭제한다.
 */
EXEC SQL
  DELETE DEPT
  WHERE deptno = 60;

EXEC SQL BEGIN DECLARE SECTION;
int empno;
char ename[10];
char job[10];
float sal;
float comm.;
EXEC SQL END DECLARE SECTION;
… … …

/*
 * 부서번호가 10번인 사원의 사원번호, 이름, 직책, 급여, 상여를
 * 가져오는 커서를 선언한다.
 */
EXEC SQL
DECLARE emp_cursor CURSOR FOR
  SELECT empno, ename, job, sal, comm
  FROM emp
  WHERE deptno = 10;

… … …

/*
 * 커서를 연다.
 */
EXEC SQL
OPEN emp_cursor;

… … …

/*
 * 커서에서 레코드를 더 이상 패치할 것이 없을 때 Loop를 break 하도록 한다.
 */
EXEC SQL
WHENEVER NOT FOUND DO break;

While (1)
{
  /*
   * 커서에서 레코드를 하나씩 패치한다.
   */
  EXEC SQL
FETCH emp_cursor
INTO :empno, :ename, :job, :sal, :comm.;

  printf (“Fetch Data : %d, %s, %s, %7.2f, %7.2f\n”,
empno, ename, job, sal, comm );

  /*
   * 패치한 레코드의 사원 정보에서 급여를 20% 인상한다.
   */
  EXEC SQL 
    UPDATE emp
    SET sal = sal * 1.2;
    WHERE empno = :empno;
} 

/*
 * 사용이 끝난 커서를 닫는다.
 */
EXEC SQL
  CLOSE emp_cursor;

EXEC SQL
  COMMIT WORK;

EXECL SQL
  ROLLBACK WORK;

EXEC SQL
  COMMIT WORK RELEASE;

EXEC SQL
  ROLLBACK WORK RELEASE;

int main (void)
{
… … …

EXEC SQL
WHENEVER SQLERROR DO sql_error ();
EXEC SQL
  DELETE FROM dept
  WHERE deptno = 10;
EXEC SQL
    WHENEVER SQLERROR DO CONTINUE;

… … …
}

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 DO CONTINUE;
  EXEC SQL
    ROLLBACK WORK RELEASE;
  
  EXIT (EXIT_FAILURE);
}

int main (void)
{
… … …

EXEC SQL
  DELETE FROM dept
  WHERE deptno = 10;
If (sqlca.sqlcode != 0)
{
  printf (“Error Occurred\n”);
sql_error();
}

… … …

exit (EXIT_SUCCESS);
}

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 DO CONTINUE;
  EXEC SQL
    ROLLBACK WORK RELEASE;
  
  EXIT (EXIT_FAILURE);
}

EXEC SQL ---->  WHENEVER --+---> NOT FOUND -----+---> CONTINUE
                           l---> SQLERROR       |---> GOTO Label
                           +---> SQLWARNING     |---> STOP
                                                |---> DO routine
                                                |---> DO BREAK
                                                +---> DO CONTINUE

struct sqlca
{
char sqlcaid[8]; /* "SQLCA" */
long sqlabc;     /* SQLCA 의 크기 */
long sqlcode;    /* 오라클 에러 메시지 코드가 저장된다. */
struct {
unsigned short sqlerrml; /* 에러 메시지의 크기 */
char sqlerrmc[70];       /* 에러 메시지 내용 */
} sqlerrm;
char sqlerrp[8]; /* 예약 */
long sqlerrd[6]; /* 상태 코드 */
char sqlwarn[8]; /* 경고 플래그 */
char sqlext[8];
};
struct sqlca sqlca;