jusax23/dblang
1
1
Fork 0
Code Issues Pull requests Projects Releases 18 Packages Wiki Activity

better solution
All checks were successful
ci/woodpecker/push/woodpecker Pipeline was successful
Details
ci/woodpecker/pr/woodpecker Pipeline was successful
Details

Browse source
This commit is contained in:
jusax23 2023-03-24 17:48:09 +01:00
parent c9f76a0799
commit 1e396b5934
Signed by: jusax23
GPG key ID: 499E2AA870C1CD41
2 changed files with 2 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/defaultHandler.ts
View file

@ -315,7 +315,7 @@ export class Handler {
}, },
insert: (hander: Handler, q: insertQuery): QueryBuilder => { insert: (hander: Handler, q: insertQuery): QueryBuilder => {
const qb = new QueryBuilder(); const qb = new QueryBuilder();
qb.addCode("INSERT INTO "); qb.addCode("INSERT IGNORE INTO ");
qb.addCode(q.attrs[0].table.serialize(hander)); qb.addCode(q.attrs[0].table.serialize(hander));
qb.addCode("("); qb.addCode("(");
qb.addCodeCommaSeperated(q.attrs.map(a => a.serialize(hander))); qb.addCodeCommaSeperated(q.attrs.map(a => a.serialize(hander)));
@ -604,13 +604,6 @@ export class Handler {
}, },
} }
catcherrors = {
insert: (err: any) => {
if(err?.code == "ER_DUP_ENTRY") return {affectedRows: 0, insertId: -1};
throw err;
}
}
responses = { responses = {
readResponse: (resp: any) => new readResponse(resp), readResponse: (resp: any) => new readResponse(resp),
writeResponse: (resp: any) => new writeResponse(resp.affectedRows), writeResponse: (resp: any) => new writeResponse(resp.affectedRows),

7
src/query.ts
View file

@ -138,12 +138,7 @@ export class insertQuery {
const handler = db.getHandler(); const handler = db.getHandler();
const builder = this.serialize(handler); const builder = this.serialize(handler);
const s = handler.builders.query(builder); const s = handler.builders.query(builder);
let readResp: any; let readResp = await db.query(s, printQuery);
try {
readResp = await db.query(s, printQuery);
} catch (err) {
readResp = handler.catcherrors.insert(err);
}
return handler.responses.insertResponse(readResp); return handler.responses.insertResponse(readResp);
} }
} }