Store.d1

Creates an atomic store from a Cloudflare D1 database binding.

Usage

import { Store } from 'mppx'
 
type Env = { DB: Store.d1.Database }
 
export default {
  async fetch(_request: Request, env: Env) {
    const store = Store.d1(env.DB) 
    const claimed = await Store.tryClaim(store, 'request:customer-42:1', Date.now() + 60_000)
    return Response.json({ claimed })
  },
}

Bind the database as DB. Writes use single SQL statements; updates use compare-and-swap, not interactive transactions.

Return type

type ReturnType = Store.AtomicStore

• Provides get, put, delete, atomic update, and replay claims; see the AtomicStore contract.
• Keep update callbacks synchronous and side-effect-free: conflicts rerun them.

Parameters

database

• Type: Store.d1.Database

D1 binding with prepare(sql).bind(...values).all() resolving to { results: unknown[] }.

options (optional)

• Type: Store.sql.Options

Uses ox JSON serialization, including bigints. update throws after maxAttempts conflicts. For the default schema and required nullable expires column, see SQL migrations.