jlelse
/
GoBlog
mirror of https://github.com/jlelse/GoBlog
1
Fork 0
Code Packages Releases Activity

Fix transactions

This commit is contained in:
Jan-Lukas Else 2023-11-21 10:37:06 +01:00
parent a70e22f996
commit d0ee8bd960
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
postsDb.go
View File

@ -215,20 +215,20 @@ func (db *database) savePost(p *post, o *postCreationOptions) error {
// Update or create post // Update or create post
if o.new { if o.new {
// New post, create it // New post, create it
sqlBuilder.WriteString("insert into posts (path, content, published, updated, blog, section, status, visibility, priority) values (?, ?, ?, ?, ?, ?, ?, ?, ?);") sqlBuilder.WriteString("insert or rollback into posts (path, content, published, updated, blog, section, status, visibility, priority) values (?, ?, ?, ?, ?, ?, ?, ?, ?);")
sqlArgs = append(sqlArgs, p.Path, p.Content, toUTCSafe(p.Published), toUTCSafe(p.Updated), p.Blog, p.Section, p.Status, p.Visibility, p.Priority) sqlArgs = append(sqlArgs, p.Path, p.Content, toUTCSafe(p.Published), toUTCSafe(p.Updated), p.Blog, p.Section, p.Status, p.Visibility, p.Priority)
} else { } else {
// Delete post parameters // Delete post parameters
sqlBuilder.WriteString("delete from post_parameters where path = ?;") sqlBuilder.WriteString("delete from post_parameters where path = ?;")
sqlArgs = append(sqlArgs, o.oldPath) sqlArgs = append(sqlArgs, o.oldPath)
// Update old post // Update old post
sqlBuilder.WriteString("update posts set path = ?, content = ?, published = ?, updated = ?, blog = ?, section = ?, status = ?, visibility = ?, priority = ? where path = ?;") sqlBuilder.WriteString("update or rollback posts set path = ?, content = ?, published = ?, updated = ?, blog = ?, section = ?, status = ?, visibility = ?, priority = ? where path = ?;")
sqlArgs = append(sqlArgs, p.Path, p.Content, toUTCSafe(p.Published), toUTCSafe(p.Updated), p.Blog, p.Section, p.Status, p.Visibility, p.Priority, o.oldPath) sqlArgs = append(sqlArgs, p.Path, p.Content, toUTCSafe(p.Published), toUTCSafe(p.Updated), p.Blog, p.Section, p.Status, p.Visibility, p.Priority, o.oldPath)
} }
// Insert post parameters // Insert post parameters
for param, value := range p.Parameters { for param, value := range p.Parameters {
for _, value := range lo.Filter(value, loStringNotEmpty) { for _, value := range lo.Filter(value, loStringNotEmpty) {
sqlBuilder.WriteString("insert into post_parameters (path, parameter, value) values (?, ?, ?);") sqlBuilder.WriteString("insert or rollback into post_parameters (path, parameter, value) values (?, ?, ?);")
sqlArgs = append(sqlArgs, p.Path, param, value) sqlArgs = append(sqlArgs, p.Path, param, value)
} }
} }