先核來源與已訂規則
本例 old→new 把 size 乘十,每行實際記其表示版本。第二次無門檻 UPDATE 會由 2→20→200;更正交易只選 old,轉後標 new。未知或未填版本在更改前暫停整次。
| 紀錄 | 輸入 JSON |
|---|---|
| 原例輸入 | {"runs":2,"initial":[{"id":"A","size":2,"version":"old"}],"later":[]} |
比較兩條實際路徑
更正重跑仍 20。後來 old 行 B3 可轉 30,先前 A20 不再變;跑了幾次不等於每行的轉換狀態。
| 路徑 | 輸出 JSON |
|---|---|
| 錯誤路徑 | {"error":null,"records":[{"id":"A","size":200,"version":"new"}]} |
| 更正路徑 | {"error":null,"records":[{"id":"A","size":20,"version":"new"}]} |
import {DatabaseSync} from 'node:sqlite';
import {TextDecoder} from 'node:util';
import {inflateSync} from 'node:zlib';
import {posix} from 'node:path';
import {createHash} from 'node:crypto';
const rows=(db,sql)=>db.prepare(sql).all().map(r=>({...r}));
const failed=(action)=>{try{action();return null;}catch(e){return {code:e.errcode??e.code??e.name};}};
import assert from 'node:assert/strict';
const run=function run(i,corrected=true){
const db=new DatabaseSync(':memory:');try{db.exec('CREATE TABLE target(id TEXT PRIMARY KEY,size INTEGER,version TEXT);');
const add=r=>db.prepare('INSERT INTO target VALUES(?,?,?)').run(r.id,r.size,r.version);for(const r of i.initial)add(r);let error=null;
for(let n=0;n<i.runs;n++){db.exec('BEGIN;');if(corrected&&db.prepare("SELECT COUNT(*) AS n FROM target WHERE version IS NULL OR version NOT IN('old','new')").get().n){error='incompatible-version';db.exec('ROLLBACK;');break;}
db.exec("UPDATE target SET size=size*10,version='new'"+(corrected?" WHERE version='old'":''));db.exec('COMMIT;');if(n===0)for(const r of i.later)add(r);}
return {error,records:rows(db,'SELECT * FROM target ORDER BY id')};
}finally{db.close();}
};
const cases=[{"label":"misleading base","input":{"runs":2,"initial":[{"id":"A","size":2,"version":"old"}],"later":[]},"expected":{"error":null,"records":[{"id":"A","size":200,"version":"new"}]},"corrected":false},{"label":"corrected base","input":{"runs":2,"initial":[{"id":"A","size":2,"version":"old"}],"later":[]},"expected":{"error":null,"records":[{"id":"A","size":20,"version":"new"}]},"corrected":true},{"label":"later old-version row converts once","input":{"runs":2,"initial":[{"id":"A","size":2,"version":"old"}],"later":[{"id":"B","size":3,"version":"old"}]},"expected":{"error":null,"records":[{"id":"A","size":20,"version":"new"},{"id":"B","size":30,"version":"new"}]},"corrected":true},{"label":"incompatible source version held","input":{"runs":1,"initial":[{"id":"A","size":2,"version":"other"}],"later":[]},"expected":{"error":"incompatible-version","records":[{"id":"A","size":2,"version":"other"}]},"corrected":true},{"label":"missing representation version held","input":{"runs":1,"initial":[{"id":"A","size":2,"version":null}],"later":[]},"expected":{"error":"incompatible-version","records":[{"id":"A","size":2,"version":null}]},"corrected":true}];
for(const test of cases){
const actual=run(test.input,test.corrected);
assert.deepEqual(actual,test.expected,test.label);
console.log(test.label,actual);
}
下次載入前核邊界
後加舊行只轉一次;版本 other 不合或版本 NULL 未填,都保原 2 並暫停。
| 情況 | 輸入 JSON | 預期輸出 JSON |
|---|---|---|
| 後加入仍屬舊式的行 | {"runs":2,"initial":[{"id":"A","size":2,"version":"old"}],"later":[{"id":"B","size":3,"version":"old"}]} | {"error":null,"records":[{"id":"A","size":20,"version":"new"},{"id":"B","size":30,"version":"new"}]} |
| 未知表示版本 | {"runs":1,"initial":[{"id":"A","size":2,"version":"other"}],"later":[]} | {"error":"incompatible-version","records":[{"id":"A","size":2,"version":"other"}]} |
| 表示版本未填 | {"runs":1,"initial":[{"id":"A","size":2,"version":null}],"later":[]} | {"error":"incompatible-version","records":[{"id":"A","size":2,"version":null}]} |
原 A2 經兩次已接受重跑,應是多大?
查看參考答案
20,不是 200。首轉已記 new,第二次須照留。