닷넷에서 접근해보는 InterSystems의 Cache 데이터베이스
요즘 생소한 DB를 계속 만져보게 되는데 ^^; 이것 역시 지난 글에 소개한,
닷넷에서 접근해보는 InterSystems의 IRIS Data Platform 데이터베이스
; https://www.sysnet.pe.kr/2/0/12275
InterSystems 회사에서 제작한 데이터베이스로, 아래의 글을 보면 예전에는 다운로드도 가능했던 것 같습니다.
Installing Cache
; http://www.hardhats.org/projects/New/InstallCache.html#download-and-install-cach%C3%A9-on-microsoft-windows
(현재는 위의 링크에 IRIS DB만 다운로드할 수 있습니다.)
기본 설정으로 설치가 되고 나면,
IRIS와 마찬가지로 dotnet 폴더 하위에 ADO.NET Data Provider 라이브러리가 제공됩니다.
C:\InterSystems\Cache\dev\dotnet
├─bin
│ ├─v2.0.50727
│ ├─v3.0
│ └─v4.0.30319
├─help
└─samples
├─adoform
│ ├─cppado
│ ├─csharpado
│ └─vbado
├─bookdemos
│ └─Properties
├─console
│ ├─person
│ └─stream
├─globals
│ └─vb
├─mobiledevice
├─objbind
├─remote
│ └─test
└─xep
├─samples
│ └─flight
└─test
이후의 방식도 IRIS와 거의 동일합니다. (시작 메뉴의 "관리 포탈 [CACHE]"로 들어가 localhost의 웹 사이트에 접속해 관리 작업을 수행합니다.)
ADO.NET Data Provider의 프로그래밍 방식도,
Using Cache ADO.NET Managed Provider Classes
; https://cedocs.intersystems.com/latest/csp/docbook/Doc.View.cls?KEY=GBMP_ado#GBMP_ado_intro
IRIS에서의 클래스 구조와 비교해 단지 이름 쪽 접미사만 IRIS에서 Cache로 바꾸기만 하면 되는 식입니다.
using InterSystems.Data.CacheClient;
using System;
using System.Configuration;
using System.Data;
namespace ConsoleApp1
{
class Program
{
static void Main(string[] args)
{
TestDB();
}
static void TestDB()
{
using (CacheConnection sqlConnection = new CacheConnection())
{
// "Server=localhost; Port=1972; Namespace=SAMPLES;Password=SYS;User ID=_SYSTEM;"
sqlConnection.ConnectionString = ConfigurationManager.ConnectionStrings["my"].ConnectionString;
sqlConnection.Open();
// Create
CacheCommand insertCommand = new CacheCommand();
insertCommand.Connection = sqlConnection;
insertCommand.CommandText = "INSERT INTO Employee(ID, EMPID, NAME, AGE) VALUES (?, ?, ?, ?)";
insertCommand.Parameters.Add("ID", CacheDbType.BigInt);
insertCommand.Parameters.Add("EMPID", CacheDbType.Int);
insertCommand.Parameters.Add("NAME", CacheDbType.NVarChar, 100);
insertCommand.Parameters.Add("AGE", CacheDbType.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
CacheCommand updateCommand = new CacheCommand();
updateCommand.Connection = sqlConnection;
updateCommand.CommandText = "UPDATE Employee SET AGE=? WHERE NAME=?";
updateCommand.Parameters.Add("AGE", CacheDbType.Int);
updateCommand.Parameters.Add("NAME", CacheDbType.NVarChar, 100);
updateCommand.Parameters[0].Value = 20;
updateCommand.Parameters[1].Value = nameValue;
affected = updateCommand.ExecuteNonQuery();
Console.WriteLine("[UPDATE] # of affected row: " + affected);
// Select - ExecuteScalar
CacheCommand selectCommand = new CacheCommand();
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();
CacheDataAdapter da = new CacheDataAdapter("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
CacheCommand deleteCommand = new CacheCommand();
deleteCommand.Connection = sqlConnection;
deleteCommand.CommandText = "DELETE FROM Employee WHERE NAME=?";
deleteCommand.Parameters.Add("NAME", CacheDbType.NVarChar, 100);
deleteCommand.Parameters[0].Value = nameValue;
affected = deleteCommand.ExecuteNonQuery();
Console.WriteLine("[DELETE] # of affected row: " + affected);
}
}
}
}
아마도 추측건데, Cache DB의 설치 디렉터리에 있는 .NET 라이브러리들이 이젠 업데이트가 없고 IRIS 쪽이 최신 날짜로 업데이트가 이뤄지는 걸로 봐서는 IRIS가 Cache의 후속작이 아닌가 생각됩니다. (혹시, 이력을 아시는 분은 덧글 부탁드립니다. ^^)
(
첨부 파일은 이 글의 예제 프로젝트를 포함합니다.)
그건 그렇고, 한 가지 이상한 시행 착오를 보면 CacheConnection.Open 시에 다음과 같은 오류 발생을 경험했습니다.
Unhandled Exception: InterSystems.Data.CacheClient.CacheException: Cache Security Error
at InterSystems.Data.CacheClient.CacheADOConnection.GetServerError(Int32 rc)
at InterSystems.Data.CacheClient.CacheADOConnection.processError(Int32 error, Int32 allowError)
at InterSystems.Data.CacheClient.InStream.readHeader(CacheCommand stmt, Int32 stmt_id, Int32 type, Int32 allowError, Boolean requestData)
at InterSystems.Data.CacheClient.CacheADOConnection.Login()
at InterSystems.Data.CacheClient.CachePool.CreateNewPooledConnection(CacheADOConnection conn)
at InterSystems.Data.CacheClient.CachePool.GetPooledConnection(CacheADOConnection conn)
at InterSystems.Data.CacheClient.CachePoolManager.GetConnection(CacheADOConnection conn)
at InterSystems.Data.CacheClient.CacheADOConnection.OpenInternal()
at InterSystems.Data.CacheClient.CacheADOConnection.Open()
at InterSystems.Data.CacheClient.CacheConnection.InitBindSvr(Boolean useCache, Boolean initADO)
at InterSystems.Data.CacheClient.CacheConnection.Open()
at ConsoleApp1.Program.TestDB() in C:\...\ConsoleApp1\Program.cs:line 20
at ConsoleApp1.Program.Main(String[] args) in C:\...\ConsoleApp1\Program.cs:line 11
클라이언트 측에서의 자세한 오류 로그를 보고 싶다면 연결 문자열에 다음과 같이 "Log File" 속성을 줄 수 있는데,
Server=localhost; Log File=cprovider.log;Port=1972; Namespace=Samples; Password = SYS; User ID = _SYSTEM;";
그렇다 해도 딱히 도움이 되는 오류 메시지는 없었습니다. ^^;
*** CacheException..ctor: (16:38:26:971) [ConnID= 55530882] [SvrJob=Unknown] [ThreadID=1]
Cache Security Error
NativeError: 417 State: S1000
검색해 보면,
Getting Cache connection error: "Cache Security Error"
; https://stackoverflow.com/questions/25259768/getting-cache-connection-error-cache-security-error
Cache Security Error
; https://community.intersystems.com/post/cache-security-error
해결 방법은 아니지만, 원인을 서버 측에서 진단할 수 있도록 방법을 제시하고 있습니다. 따라서, 웹 관리 화면에서 "System Administration > Security > Auditing > Configure System Events"으로 이동해 "%System/%Security/Protect" 이벤트의 "%System/%Login/LoginFailure"를 켠 후, "System Administration > Security > Auditing"에서 "View Audit Database" 화면을 통해 로그인 실패 시 발생하는 오류 원인을 자세하게 확인할 수 있습니다.
제 경우에는 다음과 같은 로그가 보였는데,
Audit Details:
Description ConsoleApp1.exe 로그인 실패
Timestamp 2020-07-27 11:03:33.499
UTCTimestamp 2020-07-27 02:03:33.499
Event Source %System
Event Type %Login
Event LoginFailure
Username _SYSTEM
Pid 7280
JobId 2424851
JobNumber 19
IP Address 192.168.100.25
Executable ConsoleApp1.exe
System ID testdb2:CACHE
Index 20
Roles
Authentication Password
Namespace %SYS
Routine
User Info
O/S Username testusr
Status
Event Data 오류 메시지: 라이센스를 할당 할 수 없습니다.
서비스명: %Service_Bindings
$I: |TCP|1972|7280
$P: |TCP|1972|7280
글쎄요... 시스템 재부팅 후 이런 현상이 없어졌습니다. ^^; 암튼, 그래도 서버 측의 의미 있는 오류 로그를 추적하는 방법을 알아낸 정도에 만족하고 여기서 이만 접습니다. ^^
[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]