while (true) what about while (ran)? Declare ran as true before the first run
while (true)while (ran)ran
P
1P
1P1PP1P
N1
L
awaitawait
森森森L森L森森L Both work.森L森森LPL森
BblockConcurrencyWhile when applying migration in constructor, and also I can put the entire migration into a transactionSync to prevent the rare event that migrations succeeded but writing migration number fails.L
transaction()? blockConcurrencyWhile has a different purpose than sync/async.Bstorage.get/storage.set's implementations are sync, because applyMigration is async, .then puts continuation in the next event loop, so the log order will be before -> after -> initialized. I haven't tested it but unless DO has a different behavior to regular JS, that should be the case.this.someState is still undefinedblockConcurrencyWhile is a workaround, but if we had an actual sync API, we wouldn't even need it.Lthis.someState = -1 before the call to ctx.blockConcurrencyWhile(...) and then the property won't be considered optional.BblockConcurrencyWhile at all, because applyMigrations can just be sync.Bstorage.get/storage.set is async, you also couldn't do:awaittransactionSync already exited.Ltransaction(...) which is async. Anyway, we seem to be going in circles Btransaction with SQLite?LWhen using the SQLite-backed storage engine, the txn object is obsolete. Any storage operations performed directly on the ctx.storage object, including SQL queries using ctx.storage.sql.exec(), will be considered part of the transaction.You can use both APIs, KV and SQL, inside an SQLite DO.
BtransactionSync with SQLite.森B森
HL森森
> select * from _cf_KV;
access to _cf_KV.key is prohibited: SQLITE_AUTHblockConcurrencyWhileblockConcurrencyWhileblockConcurrencyWhileblockConcurrencyWhiletransactionSynctransactionSynctransactionSynctransaction()storage.getstorage.getstorage.setstorage.setapplyMigration.thenbeforeafterinitializedthis.someStatethis.someState = -1ctx.blockConcurrencyWhile(...)applyMigrationstransaction(...)transactionSELECT name FROM sqlite_master WHERE type='table' AND name=?;async function applyMigrations(storage: DurableObjectStorage) {
await storage.get(...)
// Do migration stuffs
await storage.set(...)
}class MyDO extends DurableObject {
someState!: number
constructor(ctx: DurableObjectState, env: Env) {
super(ctx, env)
console.log('before')
applyMigrations(ctx.storage).then(() => {
this.someState = 42
console.log('initialized')
})
console.log('after')
}
}async function applyMigrations(storage: DurableObjectStorage) {
storage.transactionSync(async () => {
const currentMigration = await storage.get(...)
// Do migration stuffs
await storage.set(...)
})
}