/* ----------------------------------------------------------------- 
 * Binary File을 읽어서 데이터 베이스의 BLOB칼럼에 저장하는 프로그램 
 * --------------------------------------------------------------- */ 
 
#include <stdio.h> 
#include <string.h> 
#include <stdlib.h> 
#include <oci.h> 
 
#define FAILURE        0 
#define SUCCESS        !FAILURE 
 
exec sql include sqlca; 
 
/* -------------------------------------------------------------------------- 
                   전   역    변   수       선   언   부 
-------------------------------------------------------------------------- */ 
 
exec sql begin declare section; 
#define MAXBUFLEN    100000 
    char *userpass; 
    unsigned int amt; 
    unsigned int offset = 1; 
    unsigned int length; 
    unsigned char buffer[MAXBUFLEN]; 
    OCIClobLocator *clob; 
    OCIBlobLocator *blob; 
exec sql end   declare section; 
 
 
/* -------------------------------------------------------------------------- 
                        함   수       구   현   부 
-------------------------------------------------------------------------- */ 
 
/* 
 * 데이타 베이스와의 연동에 문제가 생겼을 경우 
 * 실행되는 함수로서 SQL 에러번호와 메세지를 
 * 출력하고 디비와의 접속을 끊고 프로그램을 종료한다. 
 */ 
void sql_error  (void) 
{ 
    printf  ("Error : %d - %s\n", sqlca.sqlcode, sqlca.sqlerrm.sqlerrmc); 
 
    exec sql whenever sqlerror continue; 
    exec sql rollback work release; 
 
    exit (1); 
} 
 
 
/* 
 * 데이타베이스와 접속하는 함수. 
 */ 
void ora_connect () 
{ 
    userpass = strdup ("scott/tiger"); 
    exec sql whenever sqlerror do sql_error (); 
    exec sql connect :userpass; 
} 
 
 
/* 
 * 데이타베이스와 접속을 종료하는 함수. 
 */ 
void ora_disconnect  (void) 
{ 
    exec sql whenever sqlerror do sql_error (); 
    exec sql rollback work release; 
} 
 
 
/* 
 * DB의 변경사항을 COMMIT 하는 함수 
 */ 
void ora_commit (void) 
{ 
    exec sql whenever sqlerror do sql_error (); 
    exec sql commit work; 
} 
 
 
/* 
 * DB의 변경사항을 ROLLBACK 하는 함수 
 */ 
void ora_rollback (void) 
{ 
    exec sql whenever sqlerror do sql_error (); 
    exec sql rollback work; 
} 
 
 
/* ---------------------------------------------------------------------- 
                     M A I N       F U N C T I O N 
---------------------------------------------------------------------- */ 
 
int main (void) 
{ 
FILE *f; 
int filelen = 0, nbytes = 0; 
 
    ora_connect (); 
 
    exec sql whenever sqlerror do sql_error (); 
    exec sql var buffer is raw(MAXBUFLEN); 
 
    /* 
     * LOB 테이블을 드랍하고 새로 생성한다. 
     */ 
    exec sql drop table lobs; 
    exec sql create table lobs (b_lob blob); 
 
    /* 
     * BLOB 타입의 포인터를 초기화하여 빈 LOB를 만들어 준다. 
     */ 
    exec sql allocate :blob; 
 
    /* 
     * DB의 테이블에 BLOB 레코드를 생성하고 LOB 포인터와 연결한다. 
     */ 
    exec sql insert into lobs (b_lob) values (:blob); 
    exec sql select b_lob into :blob from lobs where rownum = 1 for update; 
 
    /* 
     * 파일을 열고 파일 사이즈를 구한다. 
     */ 
    f = fopen ((const char *)"pic.jpg", (const char *)"r"); 
    if (f == NULL) 
    { 
        printf ("File Open Error!!!\n"); 
        exit(1); 
    } 
    fseek (f, 0, SEEK_END); 
    filelen = ftell (f); 
    fseek (f, 0, SEEK_SET); 
    printf ("File Length : %d\n", filelen); 
 
    /* 
     * 파일을 버퍼로 읽어들인다. 
     */ 
    amt = filelen; 
    nbytes = fread (buffer, 1, MAXBUFLEN, f); 
    length = nbytes; 
    printf ("%d Bytes Read\n", nbytes); 
 
    /* 
     * 버퍼의 내용을 DB에 넣는다. 
     */ 
    exec sql lob write one :amt from :buffer with length :length into :blob at :offset; 
    printf ("%d Bytes wrote\n", amt); 
 
    ora_commit (); 
    ora_disconnect (); 
    fclose (f); 
 
    exit (0); 
} 
 

/* ----------------------------------------------------------------- 
 * 데이터 베이스의 BLOB칼럼에서 Binary Data를 읽어서 파일로 저장하는 프로그램 
 * --------------------------------------------------------------- */ 
 
#include <stdio.h> 
#include <string.h> 
#include <stdlib.h> 
#include <oci.h> 
 
#define FAILURE        0 
#define SUCCESS        !FAILURE 
 
exec sql include sqlca; 
 
/* -------------------------------------------------------------------------- 
                   전   역    변   수       선   언   부 
-------------------------------------------------------------------------- */ 
 
exec sql begin declare section; 
#define MAXBUFLEN    100000 
    char *userpass; 
    unsigned int amt; 
    unsigned int offset = 1; 
    unsigned int length; 
    unsigned char buffer[MAXBUFLEN]; 
    OCIClobLocator *clob; 
    OCIBlobLocator *blob; 
exec sql end   declare section; 
 
 
/* -------------------------------------------------------------------------- 
                        함   수       구   현   부 
-------------------------------------------------------------------------- */ 
 
/* 
 * 데이타 베이스와의 연동에 문제가 생겼을 경우 
 * 실행되는 함수로서 SQL 에러번호와 메세지를 
 * 출력하고 디비와의 접속을 끊고 프로그램을 종료한다. 
 */ 
void sql_error  (void) 
{ 
    printf  ("Error : %d - %s\n", sqlca.sqlcode, sqlca.sqlerrm.sqlerrmc); 
 
    exec sql whenever sqlerror continue; 
    exec sql rollback work release; 
 
    exit (1); 
} 
 
 
/* 
 * 데이타베이스와 접속하는 함수. 
 */ 
void ora_connect () 
{ 
    userpass = strdup ("scott/tiger"); 
    exec sql whenever sqlerror do sql_error (); 
    exec sql connect :userpass; 
} 
 
 
/* 
 * 데이타베이스와 접속을 종료하는 함수. 
 */ 
void ora_disconnect (void) 
{ 
    exec sql whenever sqlerror do sql_error (); 
    exec sql rollback work release; 
} 
 
 
/* 
 * DB의 변경사항을 COMMIT 하는 함수 
 */ 
void ora_commit (void) 
{ 
    exec sql whenever sqlerror do sql_error (); 
    exec sql commit work; 
} 
 
 
/* 
 * DB의 변경사항을 ROLLBACK 하는 함수 
 */ 
void ora_rollback (void) 
{ 
    exec sql whenever sqlerror do sql_error (); 
    exec sql rollback work; 
} 
 
 
/* ---------------------------------------------------------------------- 
                     M A I N       F U N C T I O N 
---------------------------------------------------------------------- */ 
 
int main (void) 
{ 
FILE *f; 
int nbytes = 0; 
 
    ora_connect (); 
 
    exec sql whenever sqlerror do sql_error (); 
    exec sql var buffer is raw(MAXBUFLEN); 
 
    /* 
     * BLOB 타입의 포인터를 초기화하여 빈 LOB를 만들어 준다. 
     */ 
    exec sql allocate :blob; 
 
    /* 
     * DB의 테이블에서  BLOB 레코드와 LOB 포인터와 연결한다. 
     */ 
    exec sql select b_lob into :blob from lobs where rownum = 1 for update; 
 
    /* 
     * BLOB 칼럼의 데이타 길이를 얻어온다. 
     */ 
    exec sql lob describe :blob get length into :length; 
 
    /* 
     * 빈 LOB칼럼이면 종료 
     */ 
    if (length == 0) sql_error (); 
 
    /* 
     * BLOB 칼럼의 데이타를 저장할 파일을 생성한다. 
     */ 
    f = fopen ((const char *)"test.jpg", (const char *)"w"); 
    if (f == NULL) 
    { 
        printf ("File Open Error!!!\n"); 
        exit(1); 
    } 
 
    /* 
     * BLOB 칼럼에서 데이타의 길이만큼 읽어와 파일에 저장한다. 
     */ 
    exec sql lob read :amt from :blob into :buffer with length :length; 
    printf ("%d bytes read from DB\n", amt); 
    nbytes = fwrite ((void *)buffer, 1, amt, f); 
    printf ("%d bytes write to file\n", nbytes); 
 
    fclose (f); 
    ora_disconnect (); 
 
    exit (0); 
}