Compare commits
2 Commits
39d66e5280
...
05c59937e9
Author | SHA1 | Date | |
---|---|---|---|
|
05c59937e9 | ||
|
67466b4968 |
@ -88,12 +88,14 @@ class SqliteDocumentAccessor implements DocumentAccessor {
|
||||
.executeTakeFirst() as { id: number };
|
||||
const id = id_lst.id;
|
||||
|
||||
if (tags.length > 0){
|
||||
// add tags
|
||||
await trx.insertInto("tags")
|
||||
.values(tags.map((x) => ({ name: x })))
|
||||
// on conflict is supported in sqlite and postgresql.
|
||||
.onConflict((oc) => oc.doNothing())
|
||||
.execute();
|
||||
}
|
||||
|
||||
if (tags.length > 0) {
|
||||
await trx.insertInto("doc_tag_relation")
|
||||
@ -310,10 +312,12 @@ class SqliteDocumentAccessor implements DocumentAccessor {
|
||||
.where("doc_id", "=", c.id)
|
||||
.execute();
|
||||
// update tags and doc_tag_relation
|
||||
if (tags.length > 0) {
|
||||
await trx.insertInto("tags")
|
||||
.values(tags.map((x) => ({ name: x })))
|
||||
.onConflict((oc) => oc.doNothing())
|
||||
.execute();
|
||||
}
|
||||
await trx.insertInto("doc_tag_relation")
|
||||
.values(tags.map((x) => ({ tag_name: x, doc_id: c.id }))
|
||||
)
|
||||
|
@ -22,6 +22,16 @@ export function getKysely() {
|
||||
kysely = new Kysely<DB>({
|
||||
dialect: createSqliteDialect(),
|
||||
// plugins: [new ParseJSONResultsPlugin()],
|
||||
log: (event) => {
|
||||
if (event.level === "error") {
|
||||
console.error("Query failed : ", {
|
||||
durationMs: event.queryDurationMillis,
|
||||
error: event.error,
|
||||
sql: event.query.sql,
|
||||
params: event.query.parameters,
|
||||
});
|
||||
}
|
||||
}
|
||||
});
|
||||
}
|
||||
return kysely;
|
||||
|
Loading…
Reference in New Issue
Block a user