Skip to content
Machbase DBMS
개발도구 및 라이브러리

개발도구 및 라이브러리

다양한 프로그래밍 언어 및 프로토콜을 사용하여 Machbase를 애플리케이션에 통합하세요. 이 섹션에서는 사용 가능한 모든 SDK, API 및 통합 방법을 다룹니다.

사용 가능한 SDK 및 API

ODBC/CLI (C/C++)

최대 성능을 위한 네이티브 C/C++ API:

  • 직접 데이터베이스 액세스
  • 대량 로딩을 위한 APPEND 프로토콜
  • 최저 지연 시간
  • 전체 기능 지원

사용 시점: C/C++ 애플리케이션 구축, 최대 성능 필요

전체 레퍼런스

JDBC (Java)

Java 애플리케이션을 위한 표준 JDBC 드라이버:

  • 표준 JDBC 인터페이스
  • 커넥션 풀링 지원
  • Spring/Hibernate 호환
  • AUTH KEY challenge 인증 지원 (Machbase 8.5 이상)
  • APPEND API 지원

사용 시점: Java 애플리케이션 구축, 표준 JDBC 필요

전체 레퍼런스

Python

Python 클라이언트 라이브러리:

  • Pythonic API
  • Pandas 통합
  • 간단한 연결 관리
  • 쉬운 데이터 가져오기/내보내기

사용 시점: 데이터 과학, 스크립팅, Python 애플리케이션

전체 레퍼런스

.NET (C#)

C# 애플리케이션을 위한 .NET 프로바이더:

  • ADO.NET 호환
  • 커넥션 풀링
  • LINQ 지원
  • Entity Framework 호환

사용 시점: .NET/C# 애플리케이션 구축

전체 레퍼런스

REST API

웹 애플리케이션을 위한 HTTP 기반 API:

  • 언어 독립적
  • JSON 응답
  • 쉬운 통합
  • 웹 친화적

사용 시점: 웹 애플리케이션, 마이크로서비스, HTTP 전용 환경

REST API 레퍼런스는 이 DBMS 섹션에 포함되어 있지 않습니다.

빠른 시작 예제

C/C++ (ODBC/CLI) 

#include <machbase_sqlcli.h>

SQLHENV env;
SQLHDBC conn;
SQLHSTMT stmt;

// 연결
SQLAllocEnv(&env);
SQLAllocConnect(env, &conn);
SQLConnect(conn, "127.0.0.1", SQL_NTS, "SYS", SQL_NTS, "MANAGER", SQL_NTS);

// 쿼리
SQLAllocStmt(conn, &stmt);
SQLExecDirect(stmt, "SELECT * FROM sensors DURATION 1 HOUR", SQL_NTS);

// 정리
SQLFreeStmt(stmt, SQL_DROP);
SQLDisconnect(conn);

Java (JDBC) 

Class.forName("com.machbase.jdbc.MachDriver");
Connection conn = DriverManager.getConnection(
    "jdbc:machbase://127.0.0.1:5656/MACHBASE",
    "SYS", "MANAGER"
);

Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM sensors DURATION 1 HOUR");

while (rs.next()) {
    System.out.println(rs.getString("sensor_id"));
}

Python 

from machbaseAPI import connect

conn = connect(host='127.0.0.1', port=5656, user='SYS', password='MANAGER')
cur = conn.cursor()

cur.execute("SELECT * FROM sensors DURATION 1 HOUR")
for row in cur.fetchall():
    print(row)

conn.close()

C# (.NET) 

using Mach.Data.MachClient;

string connString = "SERVER=127.0.0.1;PORT_NO=5656;UID=SYS;PWD=MANAGER;PROTOCOL=4.0-full";
MachConnection conn = new MachConnection(connString);
conn.Open();

MachCommand cmd = new MachCommand("SELECT * FROM sensors DURATION 1 HOUR", conn);
MachDataReader reader = cmd.ExecuteReader();

while (reader.Read()) {
    Console.WriteLine(reader.GetString(0));
}

REST API (JavaScript) 

const params = new URLSearchParams({
    q: 'SELECT * FROM sensors DURATION 1 HOUR'
});

const response = await fetch(`http://localhost:5657/machbase?${params}`);

const data = await response.json();
console.log(data);

통합 패턴

패턴 1: 실시간 데이터 수집 

# 센서 데이터 수집기
from machbaseAPI import connect
import time

conn = connect(host='127.0.0.1', port=5656, user='SYS', password='MANAGER')

while True:
    rows = []
    for i in range(1000):
        sensor_id = f'sensor{i % 100:03d}'
        value = read_sensor(sensor_id)
        rows.append([sensor_id, time.time(), value])

    conn.append('sensors', rows)
    time.sleep(10)

패턴 2: 대시보드 애플리케이션 

// 실시간 대시보드 백엔드
@RestController
public class DashboardController {
    @Autowired
    private DataSource dataSource;

    @GetMapping("/api/sensors/current")
    public List<SensorData> getCurrentData() {
        String sql = "SELECT * FROM sensors DURATION 5 MINUTE";
        return jdbcTemplate.query(sql, new SensorDataMapper());
    }
}

패턴 3: 배치 처리 

// 야간 배치 작업
public class BatchProcessor {
    public void ProcessDailyData() {
        using (var conn = new MachConnection(connString)) {
            conn.Open();

            var sql = @"
                SELECT sensor_id, AVG(value), MAX(value), MIN(value)
                FROM sensors
                WHERE _arrival_time >= SYSDATE - 1
                GROUP BY sensor_id
            ";

            var cmd = new MachCommand(sql, conn);
            var reader = cmd.ExecuteReader();

            while (reader.Read()) {
                ProcessSensorStats(reader);
            }
        }
    }
}

연결 관리

커넥션 풀링 (Java) 

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;

HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:machbase://127.0.0.1:5656/MACHBASE");
config.setUsername("SYS");
config.setPassword("MANAGER");
config.setMaximumPoolSize(20);
config.setMinimumIdle(5);

HikariDataSource pool = new HikariDataSource(config);

연결 재시도 (Python) 

import time
from machbaseAPI import connect

def connect_with_retry(max_retries=3):
    for i in range(max_retries):
        try:
            return connect(host='127.0.0.1', port=5656, user='SYS', password='MANAGER')
        except Exception as e:
            if i == max_retries - 1:
                raise
            time.sleep(1)

성능 팁

  1. 대량 삽입에는 APPEND API 사용
  2. 커넥션 풀링 활성화
  3. 작업 배치화 (1000-10000행)
  4. Prepared Statement 재사용
  5. 리소스를 적절히 닫기

프레임워크 통합

Spring Boot (Java) 

# application.yml
spring:
  datasource:
    url: jdbc:machbase://127.0.0.1:5656/MACHBASE
    username: SYS
    password: MANAGER
    driver-class-name: com.machbase.jdbc.MachDriver

일반 DB-API (Python) 

from machbaseAPI import connect

conn = connect(host='127.0.0.1', port=5656, user='SYS', password='MANAGER')
cur = conn.cursor()
cur.execute("SELECT * FROM sensors DURATION 1 HOUR")
rows = cur.fetchall()
conn.close()

보안 모범 사례

  1. 자격 증명에는 환경 변수 사용
  2. 연결에 SSL/TLS 활성화
  3. 리포팅에는 읽기 전용 사용자 사용
  4. 연결 타임아웃 구현
  5. 입력 유효성 검사 및 살균

문제 해결

연결 실패 

# 서버 상태 확인
import socket

try:
    sock = socket.socket()
    sock.connect(('127.0.0.1', 5656))
    print("Server is reachable")
except:
    print("Cannot connect to server")

성능 문제

  • 대량 삽입에는 APPEND API 사용
  • 커넥션 풀링 활성화
  • 작업 배치화
  • 네트워크 지연 확인

메모리 문제

  • 결과 집합 크기 제한
  • 서버측 커서 사용
  • 데이터를 청크로 처리
  • 리소스를 즉시 닫기

예제 애플리케이션

완전한 Python 애플리케이션 

#!/usr/bin/env python3
from machbaseAPI import connect
import time
from datetime import datetime

class SensorMonitor:
    def __init__(self):
        self.conn = connect(host='127.0.0.1', port=5656, user='SYS', password='MANAGER')

    def collect_data(self, sensor_id, value):
        self.conn.append('sensors', [[sensor_id, datetime.now(), value]])

    def get_recent_data(self):
        cur = self.conn.cursor()
        cur.execute("SELECT * FROM sensors DURATION 1 HOUR")
        return cur.fetchall()

    def close(self):
        self.conn.close()

# 사용법
monitor = SensorMonitor()
monitor.collect_data('sensor01', 25.3)
data = monitor.get_recent_data()
monitor.close()

다음 단계

개발 환경에 맞는 SDK를 선택하세요:

관련 문서

최근 업데이트