Struct Transaction 

pub struct Transaction<'a, S: TxState> { /* private fields */ }

Typestate Transaction

Active 상태에서만 쿼리/쓰기가 가능하며, commit/rollback 후에는 컴파일 타임에 사용 불가.

Implementations

impl<'a> Transaction<'a, Active>

pub fn query<T: FromRow>(&self, sql: impl Into<String>) -> Query<'_, T>

SELECT 쿼리 — 여러 행 반환

pub fn query_one<T: FromRow>(&self, sql: impl Into<String>) -> QueryOne<'_, T>

SELECT 쿼리 — 단일 행 반환 (없으면 에러)

pub fn query_optional<T: FromRow>( &self, sql: impl Into<String>, ) -> QueryOptional<'_, T>

SELECT 쿼리 — 단일 행 반환 (없으면 None)

pub fn query_scalar<T: FromScalar>( &self, sql: impl Into<String>, ) -> QueryScalar<'_, T>

SELECT 쿼리 — 단일 스칼라 값 반환

pub fn execute(&self, sql: impl Into<String>) -> Execute<'_>

INSERT/UPDATE/DELETE — 영향받은 행 수 반환

pub fn insert(&mut self, table: &str, key: &[u8], value: &[u8]) -> DbxResult<()>

트랜잭션 내 INSERT — 로컬 버퍼에 저장 (commit 전까지 미반영)

pub fn insert_batch( &mut self, table: &str, rows: Vec<(Vec<u8>, Vec<u8>)>, ) -> DbxResult<()>

트랜잭션 내 BATCH INSERT — 여러 키-값 쌍을 일괄 삽입 (최적화됨)

pub fn delete(&mut self, table: &str, key: &[u8]) -> DbxResult<bool>

트랜잭션 내 DELETE — 로컬 버퍼에 tombstone 기록

pub fn get(&self, table: &str, key: &[u8]) -> DbxResult<Option<Vec<u8>>>

트랜잭션 내 GET — 로컬 버퍼 우선, 없으면 메인 스토리지 조회

pub fn pending_ops(&self) -> usize

현재 트랜잭션의 보류 중인 연산 개수

pub fn commit(self) -> DbxResult<Transaction<'a, Committed>>

트랜잭션 커밋 — 모든 버퍼링된 쓰기를 메인 스토리지에 원자적으로 반영

MVCC Dual-Write 전략

이 구현은 MVCC versioned key와 일반 key를 모두 저장하는 dual-write 전략을 사용합니다:

1. insert_versioned(): MVCC 타임스탬프가 포함된 versioned key로 저장

   • 향후 snapshot isolation, time-travel query 지원
   • 버전 히스토리 추적 가능

2. insert(): 일반 key로도 저장

   • get() 메서드와의 backward compatibility 보장
   • Fast-path 조회 성능 유지
   • 기존 코드와의 호환성 확보

이 전략은 약간의 저장 공간 오버헤드가 있지만, 다음 이점을 제공합니다:

• 기존 CRUD API와 완벽한 호환성
• MVCC 기능을 점진적으로 활성화 가능
• 성능 저하 없이 transaction isolation 지원

pub fn rollback(self) -> DbxResult<Transaction<'a, RolledBack>>

트랜잭션 롤백 — 모든 버퍼링된 쓰기를 폐기

impl<'a> Transaction<'a, Committed>

pub fn is_committed(&self) -> bool

커밋된 트랜잭션은 더 이상 사용할 수 없음

impl<'a> Transaction<'a, RolledBack>

pub fn is_rolled_back(&self) -> bool

롤백된 트랜잭션은 더 이상 사용할 수 없음