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

비밀번호

댓글 작성자
 




... 31  32  33  34  35  36  37  38  39  40  41  42  43  [44]  45  ...
NoWriterDateCnt.TitleFile(s)
12536정성태2/9/202110133개발 환경 구성: 542. BDP(Bandwidth-delay product)와 TCP Receive Window
12535정성태2/9/20219241개발 환경 구성: 541. Wireshark로 확인하는 LSO(Large Send Offload), RSC(Receive Segment Coalescing) 옵션
12534정성태2/8/20219812개발 환경 구성: 540. Wireshark + C/C++로 확인하는 TCP 연결에서의 closesocket 동작 [1]파일 다운로드1
12533정성태2/8/20219474개발 환경 구성: 539. Wireshark + C/C++로 확인하는 TCP 연결에서의 shutdown 동작파일 다운로드1
12532정성태2/6/20219955개발 환경 구성: 538. Wireshark + C#으로 확인하는 ReceiveBufferSize(SO_RCVBUF), SendBufferSize(SO_SNDBUF) [3]
12531정성태2/5/20218982개발 환경 구성: 537. Wireshark + C#으로 확인하는 PSH flag와 Nagle 알고리듬파일 다운로드1
12530정성태2/4/202113160개발 환경 구성: 536. Wireshark + C#으로 확인하는 TCP 통신의 Receive Window
12529정성태2/4/202110208개발 환경 구성: 535. Wireshark + C#으로 확인하는 TCP 통신의 MIN RTO [1]
12528정성태2/1/20219603개발 환경 구성: 534. Wireshark + C#으로 확인하는 TCP 통신의 MSS(Maximum Segment Size) - 윈도우 환경
12527정성태2/1/20219814개발 환경 구성: 533. Wireshark + C#으로 확인하는 TCP 통신의 MSS(Maximum Segment Size) - 리눅스 환경파일 다운로드1
12526정성태2/1/20217668개발 환경 구성: 532. Azure Devops의 파이프라인 빌드 시 snk 파일 다루는 방법 - Secure file
12525정성태2/1/20217396개발 환경 구성: 531. Azure Devops - 파이프라인 실행 시 빌드 이벤트를 생략하는 방법
12524정성태1/31/20218488개발 환경 구성: 530. 기존 github 프로젝트를 Azure Devops의 빌드 Pipeline에 연결하는 방법 [1]
12523정성태1/31/20218553개발 환경 구성: 529. 기존 github 프로젝트를 Azure Devops의 Board에 연결하는 방법
12522정성태1/31/202110052개발 환경 구성: 528. 오라클 클라우드의 리눅스 VM - 9000 MTU Jumbo Frame 테스트
12521정성태1/31/202110001개발 환경 구성: 527. 이더넷(Ethernet) 환경의 TCP 통신에서 MSS(Maximum Segment Size) 확인 [1]
12520정성태1/30/20218567개발 환경 구성: 526. 오라클 클라우드의 VM에 ping ICMP 여는 방법
12519정성태1/30/20217607개발 환경 구성: 525. 오라클 클라우드의 VM을 외부에서 접근하기 위해 포트 여는 방법
12518정성태1/30/202125061Linux: 37. Ubuntu에 Wireshark 설치 [2]
12517정성태1/30/202112698Linux: 36. 윈도우 클라이언트에서 X2Go를 이용한 원격 리눅스의 GUI 접속 - 우분투 20.04
12516정성태1/29/20219337Windows: 188. Windows - TCP default template 설정 방법
12515정성태1/28/202110590웹: 41. Microsoft Edge - localhost에 대해 http 접근 시 무조건 https로 바뀌는 문제 [3]
12514정성태1/28/202110839.NET Framework: 1021. C# - 일렉트론 닷넷(Electron.NET) 소개 [1]파일 다운로드1
12513정성태1/28/20218902오류 유형: 698. electronize - User Profile 디렉터리에 공백 문자가 있는 경우 빌드가 실패하는 문제 [1]
12512정성태1/28/20218671오류 유형: 697. The program can't start because VCRUNTIME140.dll is missing from your computer. Try reinstalling the program to fix this problem.
12511정성태1/27/20218426Windows: 187. Windows - 도스 시절의 8.3 경로를 알아내는 방법
... 31  32  33  34  35  36  37  38  39  40  41  42  43  [44]  45  ...