기본 콘텐츠로 건너뛰기

[ ORACLE ] BLOB 작업하기

현재 진행 중인 프로젝트에서 IMAGE 나 PDF 등 (Binary Data)을 저장하고 조회하는 기능이 필요해서 오라클 DB에 ODP.NET을 이용해서 작업을 구성하였다.

BLOB  작업

LOBs Basic

  LOBs 는 데이터베이스에 저장할 수 있는 데이터 스트림으로서의  Large OBject 를 의미한다. 최대 처리할 수 있는 크기는 4G이며 다음과 같은 형식을 제공한다.

  • BLOB - 비정형 바이너리 데이터로 저장되는 형식으로 문자형식(Character set)에 상관없는 비트스트림이다.
  • CLOB - Single byte 와 Multi byte 의 문자형 데이터를 의미하고 고정/가변 길이를 제공하고 데이터베이스의 Character Set 기준을 따라서 저장된다.
  • NCLOB - CLOB 과 같지만 Unicode 데이터로 저장된다.
   LONG 이나 LONG RAW 형식을 처리하는 것과 같이 OracleDataReader를 이용해서 LOB 필드에 저정된 값을 읽을 수 있다. LOB 데이터 형식을 사용하는 방식의 다른 점은 DML 이나 PL/SQL 을 이용해서 해당 필드에 접근하는 경우에 명확하게 구분된다. BLOB 이나 CLOB 의 경우는 별도의 테이블스페이스에 저장이 되기 때문에 해당 필드는 데이터가 존재하는 위치의 포인터 정보만 가지고 있게 된다. (LOB Locator) 따라서 LONG 이나 LONG RAW 형식과는 다른 방식으로 관리가 된다.

Working with BLOB

  아래와 같이 기본 테이블을 구성하도록 한다.


CREATE TABLE BLOBSAMPLE (
  FILE_ID VARCHAR2(32) NOT NULL,
  FILE_NAME VARCHAR2(200) NOT NULL,
FILE_EXTENSION VARCHAR2(10) NOT NULL,
FILE_CONTENT BLOB NOT NULL,
CONSTRAINT BLOBSAMPLE_PK PRIMARY KEY (
FILE_ID
)
ENABLE
);

  위의 테이블을 생성한 후에 생성된 테이블의 스크립트를 빼서 보면 아래와 같이 BLOB 컬럼에 대한 저장 관련 정보가 생성된 것을 확인할 수 있다.



  일반적인 SQL 문장을 통해서 충분히 처리가 가능하지만, 프로젝트에서는 패키지를 기본으로 사용하고 있기 때문에 아래와 같이 BLOB 처리를 위한 패키지를 구성하도록 한다.


[ 패키지 HEAD ]
CREATE OR REPLACE PACKAGE BLOBSAMPLE AS
PROCEDURE ADD_BLOB ( I_FILE_ID IN VARCHAR2, I_FILE_NAME IN VARCHAR2, I_FILE_EXTENSION IN VARCHAR2, I_FILE_CONTENT IN BLOB ); PROCEDURE READ_BLOBS ( O_DATACUR OUT SYS_REFCURSOR ); END BLOBSAMPLE;
[ 패키지 BODY ]
CREATE OR REPLACE PACKAGE BODY BLOBSAMPLE AS
PROCEDURE ADD_BLOB ( I_FILE_ID IN VARCHAR2, I_FILE_NAME IN VARCHAR2, I_FILE_EXTENSION IN VARCHAR2, I_FILE_CONTENT IN BLOB ) AS BEGIN INSERT INTO LOBSAMPLE
VALUES(I_FILE_ID, I_FILE_NAME, I_FILE_EXTENSION, DBMS_LOB.GETLENGTH(I_FILE_CONTENT)
I_FILE_CONTENT);
<span style="color: blue;">COMMIT WORK;</span>

END ADD_BLOB; PROCEDURE READ_BLOBS ( O_DATACUR OUT SYS_REFCURSOR ) AS BEGIN OPEN O_DATACUR FOR SELECT FILE_ID , FILE_NAME , FILE_EXTENSION , FILE_SIZE , FILE_CONTENT FROM LOBSAMPLE; END READ_BLOBS; END BLOBSAMPLE;


  위의 코드는 일반적인 패키지 구성 코드이며, 별다른 특이사항은 없지만 BLOB 이기 때문에 별도로 함수를 사용해야 하는 부분이 존재한다. 전달된 BLOB 파라미터는 Lob Locator 이기 때문에 실제 데이터나 데이터의 길이를 구하기 위해서는 “DBMS_LOB” 로 시작되는 패키지를 사용해야 한다. 위에서는 데이터 길이를 구하기 위해서 “GETLENGTH” 함수를 사용하였다.

  이제 서버에서 처리할 작업이 완료되었으므로 아래와 같이 클라이언트의 샘플 코드를 작성하도록 한다.


private void btnAdd_Click(object sender, EventArgs e) { FileInfo fi = new FileInfo(this.txtFile.Text); try { using (OracleConnection conn = new OracleConnection(ConfigurationManager.ConnectionStrings["LOCALDB"].ConnectionString)) { conn.Open(); try {
using (OracleCommand cmd = new OracleCommand()) { cmd.Connection = conn; cmd.CommandText = "BLOBSAMPLE.ADD_BLOB"; cmd.CommandType = CommandType.StoredProcedure; cmd.Parameters.Add(new OracleParameter() { ParameterName = "I_FILE_ID", OracleDbType = OracleDbType.Varchar2, Value = Guid.NewGuid().ToString("N"), Direction = ParameterDirection.Input }); cmd.Parameters.Add(new OracleParameter() { ParameterName = "I_FILE_NAME", OracleDbType = OracleDbType.Varchar2, Value = fi.FullName, Direction = ParameterDirection.Input }); cmd.Parameters.Add(new OracleParameter() { ParameterName = "I_FILE_EXTENSION", OracleDbType = OracleDbType.Varchar2, Value = fi.Extension, Direction = ParameterDirection.Input }); cmd.Parameters.Add(new OracleParameter() { ParameterName = "I_FILE_CONTENT", OracleDbType = OracleDbType.Blob, Value = File.ReadAllBytes(fi.FullName), Direction = ParameterDirection.Input });
      cmd.ExecuteNonQuery();
    }
  } finally {
    conn.Close(); 
  }
}

} catch (Exception ex) { MessageBox.Show(ex.Message); } }

private void btnFile_Click(object sender, EventArgs e) { OpenFileDialog dlg = new OpenFileDialog(); if (dlg.ShowDialog() == DialogResult.OK) { this.txtFile.Text = dlg.FileName; } }

private void btnQuery_Click(object sender, EventArgs e) { try { using (OracleConnection conn = new OracleConnection(ConfigurationManager.ConnectionStrings[“LOCALDB”].ConnectionString)) { conn.Open(); try { using (OracleCommand cmd = new OracleCommand()) { cmd.Connection = conn; cmd.CommandText = “BLOBSAMPLE.READ_BLOBS”; cmd.CommandType = CommandType.StoredProcedure; cmd.InitialLOBFetchSize = -1; cmd.Parameters.Add(new OracleParameter() { ParameterName = “O_DATACUR”, OracleDbType = OracleDbType.RefCursor, Value = null, Direction = ParameterDirection.Output });

      using (OracleDataAdapter oda = new OracleDataAdapter(cmd)) {
        DataSet ds = new DataSet();
        <span style="color: red;"><b>oda.Fill(ds);</b></span></span></span><br />

this.dataGridView1.DataSource = ds.Tables[0]; } } } finally { conn.Close(); } } } catch (Exception ex) { MessageBox.Show(ex.Message); } }

private void dataGridView1_DataError(object sender, DataGridViewDataErrorEventArgs e) { e.Cancel = true; }


  LOBs 가 포함된 정보를 조회하는 경우는 ODP.NET Command가 LOBs Locator 만을 처리하는 것이 아니라 실제 데이터를 모두 조회할 수 있도록 "InitialLOBFetchSize" 를 -1 로 설정해 주는 부분만 조심하면 된다.

  아래의 그림은 실행해서 BLOB 데이터를 처리한 결과이다. 기본 제공되는 DataGridView 컨트롤은 바인딩이 되는 컬럼의 형식이 BLOB (byte[]) 인 경우에는 자동으로 Image 로 전환하려고 하기 때문에 오류가 발생하게 된다. 오류를 표시하지 않기 위해서는 DataError 이벤트로 오류를 잡아주어야 한다. 그럼 Image로 변환이 불가한 바이너리 데이터는 표시되지 않는다. 당연히 Image 로 변환 가능한 것은 Image 가 표시된다.



Inserting LOBs on Oracle Server 8.0.5 and Olders

  이전 버전의 오라클에서는 현재와 같은 방식으로 LOBs 를 지원하지 않는다. 따라서 매뉴얼로 EMPTY_BLOB or EMPTY_CLOB 함수를 사용해서 Lob Locator를 생성하고 초기화 해주어야 한다. 그리고 RETURNING 명령을 통해서 초기화된 Locator를 반환해 주어야 한다.


UPDATE CLOBTABLE
SET NAME = :Name
, VALUE = EMPTY_CLOB()
WHERE ID = :Id
RETUNING VALUE
INTO :Value

  따라서 클라이언트 코드도 이에 맞춰서 파라미터를 구성해 주어야 한다.


...
string sql = "UPDATE CLOBTABLE SET NAME = :Name, VALUE = EMPTY_CLOB()" +
"WHERE ID = :Id RETURNING VALUE INTO :Value";
OracleCommand cmd = new OracleCommand(sql, conn);
cmd.Parameters.Add("Id", 1);
cmd.Parameters.Add("Name", "First");
OracleParameter param = cmd.Parameters.Add("Value", OracleDbType.Clob);
param.Direction = ParameterDirection.Input;
param.Value = "The CLOB Test Value";
cmd.ExecuteNonQuery();
...

  이전 버전에 대한 처리를 오라클 버전을 구해서 설치하고 테스트할 수 없었기 때문에 실제 검증이 되지는 않았지만, 인터넷에 정리된 내용을 기준으로 한 것이기 때문에 큰 문제는 없을 듯 하다.

댓글

이 블로그의 인기 게시물

OData 에 대해서 알아보자.

얼마 전에 어떤 회사에 인터뷰를 하러 간 적이 있었다. 당시 그 회사는 자체 솔루션을 개발할 기술인력을 찾고 있었고 내부적으로 OData를 사용한다고 했다. 좀 창피한 이야기일 수도 있지만 나름 기술적인 부분에서는 많은 정보를 가지고 있다고 했던 것이 무색하게 OData란 단어를 그 회사 사장님에게서 처음 들었다. 작고, 단순한 사이트들만을 계속해서 작업을 하다 보니 어느덧 큰 줄기들을 잃어버린 것을 느끼기 시작했다. 명색이 개발이 좋고, 기술적인 기반을 만들려고 하는 인간이 단어조차도 모른다는 것은 있을 수 없는 것이라서 다시 새로운 단어들과 개념들을 알아보는 시간을 가지려고 한다. OData (Open Data Protocol) 란? 간단히 정리하면 웹 상에서 손쉽게 데이터를 조회하거나 수정할 수 있도록 주고 받는 웹(프로토콜)을 말한다. 서비스 제공자 입장에서는 웹으로 데이터를 제공하는 방식으로 각 포탈 사이트들이 제공하는 OPEN API 포맷을 독자적인 형식이 아니라 오픈된 공통규약으로 제공 가능하며, 개발자는 이 정보를 다양한 언어의 클라이언트 라이브러리로 어플리케이션에서 소비할 수 있도록 사용하면 된다. 공식 사이트는 www.odata.org 이며 많은 언어들을 지원하고 있다. 좀더 상세하게 정의를 해 보면 OData는 Atom Publishing Protocol  (RFC4287) 의 확장 형식이고 REST (REpresentational State Transfer) Protocol 이다. 따라서 웹 브라우저에서 OData 서비스로 노출된 데이터를 볼 수 있다. 그리고 AtomPub 의 확장이라고 했듯이 데이터의 조회만으로 한정되는 것이 아니라 CRUD 작업이 모두 가능하다. Example 웹 브라우저에서 http://services.odata.org/website/odata.svc 를 열어 보도록 하자. This XML file does not appear to have any style in...

C# 에서 Timer 사용할 때 주의할 점.

예전에 알고 지내시던 분의 질문을 받았다. Windows Forms 개발을 하는데, 주기적 (대략 1분)으로 데이터 요청을 하는 프로그램을 작성하기 위해서 Timer 를 사용하는데, 어떤 기능을 처리해야 하기 때문에 Sleep 을 같이 사용했다고 한다. 여기서 발생하는 문제는 Sleep 5초를 주었더니, Timer 까지 5초 동안 멈춘다는 것이다. Timer 라는 것은 기본적으로 시간의 흐름을 측정하는 기능이기 때문에 Sleep 을 했다고 해서 Timer 가 멈추는 일은 생겨서는 안된다. 그러나 실제 샘플을 만들어 보면 ... Timer 가 Sleep 만큼 동작이 멈추는 것을 확인할 수 있다. Windows Forms 는 UI Thread 를 사용하는 것으로 최적화 되어 있으며 여기서 Timer 를 쓰면 UI Thread 에 최적화된 System.Windows.Forms.Timer 가 사용된다. 여기서 문제의 발생이 시작되는 것이다. Sleep 을 사용하게 되면 UI Thread 가 Sleep 이 걸리기 때문에 여기에 속한 Timer 까지도 멈추는 것이다. 이런 문제를 해결하기 위해서는 System.Threading.Timer 를 사용해야 한다. 이 Timer 는 별도의 Thread 에서 동작하기 때문에 Sleep 의 영향을 받지 않는다. 언뜻 보면 쉬운 해결 방법인 것 같지만 Thread 가 분리되었기 때문에 Timer 가 돌아가는 Thread 에서 UI Thread 의 메서드나 컨트롤에 접근하기 위해서는 별도의 명령을 사용해야 하는 문제가 존재한다. 자~ 그럼 여기서 Timer 에 대해서 다시 한번 정리해 보도록 하자. .NET 에서 제공하는 Timer 들 .NET 에서는 기본적으로 3가지 Timer를 제공하고 있다. (MSDN) System.Windows.Forms.Timer - 사용자가 지정한 간격마다 이벤트를 발생시키며 Windows Forms 응용 프로그램에서 사용할 수 있도록 최적화 되어 있다. System...

[Logging] NLog 사용법 정리...

SCSF 에는 기본적으로 Enterprise Library가 사용된다. 예전에도 그랬지만 기능은 훌륭하고 많은 부분에서 최적화(?)된 것일지도 모르지만, 역시나 사용하기에는 뭔가 모르게 무겁고, 사용하지 않는 기능이 더 많다라는 느낌을 지울수가 없다. 이번 프로젝트도 SCSF를 기반으로 하고 있지만, Enterprise Library를 걷어내고 각 부분에 전문화된 오픈 소스를 사용하기로 하였다. 예전에는 Log4Net을 사용했지만, 대량 사용자 환경에서는 메모리 누수와 기타 문제점이 존재한다는 MS 컨설턴트(?)의 전해진 말을 들은 후로는 사용하지 않는다. 대안으로 사용하는 것이 NLog 이다. 조금 후에는 3.0 버전도 나온다고 홈 페이지에 기재되어 있지만, 그 때가 되면 프로젝트는 끝나기 때문에 현재 2.1.0 버전을 사용하기로 했다. [원본 출처] http://cloverink.net/most-useful-nlog-configurations-closed/ 위의 참조 자료에는 다양한 정보들이 존재하므로 꼭 링크를 통해서 관련된 정보를 확인하고 이해하는 것이 좋을 듯 하다. 여기서는 당장 필요한 부분만을 정리하도록 한다. [ Logger 찾기 ] 기본적으로 Logger가 존재하는 클래스를 기반으로 Logger 정보를 구성한다. Logger logger = LogManager.GetCurrentClassLogger(); 주로 Namespace 기반으로 Logger를 설정하는 경우에 유연하게 사용할 수 있다. 또 다른 방법으로는 지정한 문자열로 특정 Logger를 직접 선택하는 방법도 제공된다. 이를 혼용해서 Namespace와 직접 지정 방식을 같이 사용할 수도 있다. 물론 Logger 환경 설정에서 Wildcard (*)를 지정할 수도 있다. Logger logger = LogManager.GetLogger("Database.Connect"); Logger logger = LogManager.Get...