This commit is contained in:
seb
2026-09-22 08:35:36 +02:00
parent dce65db435
commit 075b1f0ddc
3 changed files with 358 additions and 102 deletions

View File

@@ -33,7 +33,8 @@ export function sqliteQuery(sql) {
let result = quoteIdentifiers(sql)
.replace(/\bISNULL\s*\(/gi, 'IFNULL(')
.replace(/\bSYSUTCDATETIME\s*\(\s*\)/gi, "strftime('%Y-%m-%dT%H:%M:%fZ', 'now')")
.replace(/\bCAST\s*\(([^()]+?)\s+AS\s+INT\s*\)/gi, 'CAST($1 AS INTEGER)');
.replace(/\bCAST\s*\(([^()]+?)\s+AS\s+INT\s*\)/gi, 'CAST($1 AS INTEGER)')
.replace(/\bCONVERT\s*\(\s*VARBINARY\s*\(\s*MAX\s*\)\s*,\s*([^)]+?)\s*\)/gi, '$1');
result = moveReturning(result);
result = moveTop(result);
return result;

View File

@@ -43,13 +43,11 @@ export default function queryBySku(provider) {
return async (articleId, languageId, tx) => {
const runner = makeRunner(provider, tx);
const [detail, categories, photos, eans, prices] = await Promise.all([
runner.query(queries.GET_DETAIL_BY_ARTICLE_ID, { articleId, languageId }),
runner.query(queries.GET_CATEGORY_IDS_BY_ARTICLE_ID, { articleId }),
runner.query(queries.GET_PHOTOS_BY_ARTICLE_ID, { articleId }),
runner.query(queries.GET_EANS_BY_ARTICLE_ID, { articleId }),
runner.query(queries.GET_PRICES_BY_ARTICLE_ID, { articleId }),
]);
const detail = await runner.query(queries.GET_DETAIL_BY_ARTICLE_ID, { articleId, languageId });
const categories = await runner.query(queries.GET_CATEGORY_IDS_BY_ARTICLE_ID, { articleId });
const photos = await runner.query(queries.GET_PHOTOS_BY_ARTICLE_ID, { articleId });
const eans = await runner.query(queries.GET_EANS_BY_ARTICLE_ID, { articleId });
const prices = await runner.query(queries.GET_PRICES_BY_ARTICLE_ID, { articleId });
const row = detail.rows[0];
if (!row) {