Microsoft MVP성태의 닷넷 이야기
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
(연관된 글이 3개 있습니다.)

닷넷에서 접근해보는 InterSystems의 IRIS Data Platform 데이터베이스

처음 듣는 데이터베이스입니다. ^^ 아래의 경로를 통해 community 버전을 다운로드 신청할 수 있고,

InterSystems IRIS Community Edition Download Registration
; http://download.intersystems.com/download/register.csp

곧바로 "IRIS_Community-2020.1.0.215.0-win_x64.exe" 식의 파일을 내려받아 설치하면 되는데, 제 경우에는 그냥 기본값으로 진행을 했습니다.

iris_db_install_1.png

이후, "시작" 메뉴를 통해 "Management Portal [IRIS]" 항목을 선택하면 웹 브라우저가 뜨고 관리 페이지로 접속이 됩니다.




DB 설치는 그게 끝이고, 이후 간단한 실습을 위해 테이블을 생성해야 하는데,

InterSystems IRIS Data Platform 2020.2 > Multi-model Data Access > InterSystems SQL Reference > SQL Commands > CREATE TABLE
; https://docs.intersystems.com/irislatest/csp/docbook/DocBook.UI.Page.cls?KEY=RSQL_createtable

어차피 생소한 DB라도 ANSI 규약의 SQL 쿼리 구문은 기본적으로 지원할 것이므로 해당 데이터베이스 문맥에서,

iris_db_install_2.png

실행해 주면 됩니다.

CREATE TABLE Employee (
     EMPID INT NOT NULL,
     NAME   CHAR(100) NOT NULL,
     AGE  INT,
     CONSTRAINT EMPLOYEEPK PRIMARY KEY (EMPID))

한 가지 재미있는 점은, 생성된 테이블을 보면 기본적으로 BIGINT 타입의 "ID"가 있다는 정도!

iris_db_install_3.png




IRIS DB 역시 닷넷으로 프로그래밍하는 방법은, ADO.NET의 사용법을 그대로 따릅니다. DB를 설치한 폴더로부터,

C:\InterSystems\IRIS\dev\dotnet> tree
Folder PATH listing
Volume serial number is D089-B7C9
C:.
└─bin
    ├─Core21
    │  └─Gateway
    │      └─runtimes
    │          └─win
    │              └─lib
    │                  └─netstandard2.0
    ├─CorePackages
    ├─v2.0.50727
    ├─v4.0.30319
    └─v4.5

원하는 패키지를 선택하면 되는데, 이 글에서는 "v4.5"의 것으로 다음과 같이 CRUD 작업을 코딩해 봤습니다.

using InterSystems.Data.IRISClient;
using System;
using System.Data;

namespace ConsoleApp1
{
    class Program
    {
        static void Main(string[] args)
        {
            TestDB();
        }

        static void TestDB()
        {

            // Connecting to the InterSystems Database
            // https://docs.intersystems.com/irislatest/csp/docbook/Doc.View.cls?KEY=BNET_connect#BNET_connect_connect

            using (IRISConnection sqlConnection = new IRISConnection())
            {
                // 기본 포트: 51773
                sqlConnection.ConnectionString = "Server=192.168.0.11; Port=51773; Namespace=USER;Password=SYS;User ID=_SYSTEM;";

                sqlConnection.Open();

                // Create
                IRISCommand insertCommand = new IRISCommand();
                insertCommand.Connection = sqlConnection;
                insertCommand.CommandText = "INSERT INTO Employee(ID, EMPID, NAME, AGE) VALUES (?, ?, ?, ?)";

                insertCommand.Parameters.Add("ID", IRISDbType.BigInt);
                insertCommand.Parameters.Add("EMPID", IRISDbType.Int);
                insertCommand.Parameters.Add("NAME", IRISDbType.NVarChar, 100);
                insertCommand.Parameters.Add("AGE", IRISDbType.Int);

                string nameValue = "Name" + Guid.NewGuid().ToString();
                insertCommand.Parameters[1].Value = (int)DateTime.Now.Ticks;
                insertCommand.Parameters[2].Value = nameValue;
                insertCommand.Parameters[3].Value = 10;

                int affected = insertCommand.ExecuteNonQuery();
                Console.WriteLine("[INSERT] # of affected row: " + affected);

                // Update
                IRISCommand updateCommand = new IRISCommand();
                updateCommand.Connection = sqlConnection;
                updateCommand.CommandText = "UPDATE Employee SET AGE=? WHERE NAME=?";

                updateCommand.Parameters.Add("AGE", IRISDbType.Int);
                updateCommand.Parameters.Add("NAME", IRISDbType.NVarChar, 100);

                updateCommand.Parameters[0].Value = 20;
                updateCommand.Parameters[1].Value = nameValue;

                affected = updateCommand.ExecuteNonQuery();
                Console.WriteLine("[UPDATE] # of affected row: " + affected);

                // Select - ExecuteScalar
                IRISCommand selectCommand = new IRISCommand();
                selectCommand.Connection = sqlConnection;
                selectCommand.CommandText = "SELECT count(*) FROM Employee";

                object result = selectCommand.ExecuteScalar();
                Console.WriteLine("[SELECT] # of records: " + result);

                // Select - DataTable
                DataSet ds = new DataSet();
                IRISDataAdapter da = new IRISDataAdapter("SELECT * FROM Employee", sqlConnection);
                da.Fill(ds, "mytable");

                DataTable dt = ds.Tables["mytable"];
                foreach (DataRow dr in dt.Rows)
                {
                    Console.WriteLine(string.Format("Name = {0}, Age = {1}", dr["NAME"], dr["AGE"]));
                }

                // Delete
                IRISCommand deleteCommand = new IRISCommand();
                deleteCommand.Connection = sqlConnection;
                deleteCommand.CommandText = "DELETE FROM Employee WHERE NAME=?";

                deleteCommand.Parameters.Add("NAME", IRISDbType.NVarChar, 100);
                deleteCommand.Parameters[0].Value = nameValue;

                affected = deleteCommand.ExecuteNonQuery();
                Console.WriteLine("[DELETE] # of affected row: " + affected);
            }
        }

    }
}

(첨부 파일은 이 글의 예제 코드를 포함합니다.)

보는 바와 같이 일반적인 ADO.NET과 사용법은 같지만, SQL Server만 다루던 개발자라면 Parameterized Query에 이름을 지정할 수 없다는 것을 유의해야 합니다. 예를 들어, 본문에서 "INSERT INTO Employee(ID, EMPID, NAME, AGE) VALUES (?, ?, ?, ?)" 쿼리를 보였는데, 따라서 Parameters 컬렉션에 (이름이 없으므로) 들어가는 순서대로 "?"에 매핑이 된다는 것을 신경 써야 합니다.




한 가지 좀 안 좋은 면이 있는데요, IRISConnection 단위로 이전에 수행되지 않은 쿼리인 경우 언제나 "System.ArgumentNullException" 예외가 InterSystems.Data.IRISClient.CachedPrepareCollection.GetStatement 메서드에서 발생합니다. (그러니까, 현실적으로 거의 항상 발생한다고 보면 됩니다.)

internal CachedPrepare GetStatement(string sqlText, IRISCommand cmd)
{
    CachedPrepare prepare2;
    this.rwl.EnterReadLock();
    try
    {
        object obj2 = this.sqlToId[sqlText]; // 수행된 적이 없는 쿼리는 obj2 == null
        CachedPrepare prepare = (CachedPrepare) base[obj2]; // System.ArgumentNullException 예외 발생
        if (prepare != null)
        {
            if (prepare.ownedBy == null)
            {
                prepare.ownedBy = cmd;
                this.unownedCnt--;
                prepare.refCount++;
            }
            else
            {
                return null;
            }
        }
        prepare2 = prepare;
    }
    catch (Exception)
    {
        prepare2 = null;
    }
    finally
    {
        this.rwl.ExitReadLock();
    }
    return prepare2;
}

try/catch가 되어 있기 때문에 실행에 지장은 주지 않지만, Debug 창에 System.ArgumentNullException 오류가 끊임없이 나오는 것은 별로 좋은 사용자 경험은 아닙니다. 게다가 만약 해당 Exception을 "Break When Thrown"으로 지정해 놓았다면 매번 비주얼 스튜디오는 다음의 예외 창을 보여줍니다. (따라서 반드시 해당 옵션을 꺼두어야 합니다.)

System.ArgumentNullException
  HResult=0x80004003
  Message=Key cannot be null.
Parameter name: key
  Source=mscorlib
  StackTrace:
   at System.Collections.Hashtable.get_Item(Object key)

  This exception was originally thrown at this call stack:
    System.Collections.Hashtable.this[object].get(object)




참고로, 아래의 문서를 보면,

Using Cache ADO.NET Managed Provider Classes
; https://cedocs.intersystems.com/latest/csp/docbook/Doc.View.cls?KEY=GBMP_ado#GBMP_ado_intro

Installing Cache
; http://www.hardhats.org/projects/New/InstallCache.html#download-and-install-cach%C3%A9-on-microsoft-windows

"Cache" 접두사로 시작하는 Data Provider도 있었던 것 같습니다.




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]

[연관 글]






[최초 등록일: ]
[최종 수정일: 7/28/2020]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 작성자
 




... 106  107  108  109  110  111  112  113  114  [115]  116  117  118  119  120  ...
NoWriterDateCnt.TitleFile(s)
11050정성태9/24/201626617VC++: 101. 반올림하지 않고 double 변수 값 출력하는 방법 [3]
11049정성태9/24/201621056오류 유형: 357. 윈도우 백업 시 오류 - 0x81000037
11048정성태9/24/201622058VC++: 100. 전역 변수 유형별 실행 파일 크기 차이점
11047정성태9/21/201625896기타: 61. algospot.com - 양자화(Quantization) 문제 [2]파일 다운로드1
11046정성태9/15/201627528개발 환경 구성: 298. Windows 10 - bash 실행 시 시작 디렉터리 자동 변경
11045정성태9/15/201620172Windows: 119. Windows 10 - bash 명령어 창을 실행했는데 바로 닫히는 경우
11044정성태9/15/201620443VS.NET IDE: 112. Visual Studio 확장 - 편집 화면 내에서 링크를 누르면 외부 웹 브라우저에서 열기
11043정성태9/15/201621860.NET Framework: 606. .NET 스레드 콜 스택 덤프 (7) - ClrMD(Microsoft.Diagnostics.Runtime)를 이용한 방법 [1]파일 다운로드1
11042정성태9/14/201620003오류 유형: 356. Unknown custom metadata item kind: 6
11041정성태9/10/201619485.NET Framework: 605. CLR4 보안 - yield 구문 내에서 SecurityCritical 메서드 사용 불가 - 2번째 이야기
11040정성태9/10/201626767.NET Framework: 604. C# Windows Forms - Drag & Drop 예제 코드 [2]파일 다운로드1
11039정성태9/9/201623269오류 유형: 355. Visual Studio 빌드 오류 - error CS0122: '__ComObject' is inaccessible due to its protection level
11038정성태9/9/201625122VC++: 99. 서로 다른 프로세스에서 WM_DROPFILES 메시지를 전송하는 방법파일 다운로드1
11037정성태9/8/201628357.NET Framework: 603. socket - shutdown 호출이 필요한 사례파일 다운로드1
11036정성태8/29/201624800개발 환경 구성: 297. 소스 코드가 없는 닷넷 어셈블리를 디버깅할 때 지역 변숫값을 확인하는 방법
11035정성태8/29/201620471오류 유형: 354. .NET Reflector - PDB 생성 화면에서 "Clear Store"를 하면 "Index and length must refer to a location within the string" 예외 발생
11034정성태8/25/201624487개발 환경 구성: 296. .NET Core 프로젝트를 NuGet Gallery에 배포하는 방법 [2]
11033정성태8/24/201622375오류 유형: 353. coreclr 빌드 시 error C3249: illegal statement or sub-expression for 'constexpr' function
11032정성태8/23/201621587개발 환경 구성: 295. 최신의 Visual C++ 컴파일러 도구를 사용하는 방법 [1]
11031정성태8/23/201617821오류 유형: 352. Error encountered while pushing to the remote repository: Response status code does not indicate success: 403 (Forbidden).
11030정성태8/23/201620358VS.NET IDE: 111. Team Explorer - 추가한 Git Remote 저장소가 Branch에 보이지 않는 경우
11029정성태8/18/201627533.NET Framework: 602. Process.Start의 cmd.exe에서 stdin만 redirect 하는 방법 [1]파일 다운로드1
11028정성태8/15/201621544오류 유형: 351. Octave 설치 시 JRE 경로 문제
11027정성태8/15/201622642.NET Framework: 601. ElementHost 컨트롤의 메모리 누수 현상
11026정성태8/13/201623610Math: 19. 행렬 연산으로 본 해밍코드
11025정성태8/12/201622330개발 환경 구성: 294. .NET Core 프로젝트에서 "Copy to Output Directory" 처리 [1]
... 106  107  108  109  110  111  112  113  114  [115]  116  117  118  119  120  ...