add postgresql_script resource #18
Conversation
|
|
||
| # postgresql\_script | ||
|
|
||
| The ``postgresql_script`` execute a script given as parameter. |
There was a problem hiding this comment.
| The ``postgresql_script`` execute a script given as parameter. | |
| The ``postgresql_script`` execute a script given as parameter. This script will be executed each time it changes. |
|
|
||
| func executeCommands(db *DBConnection, commands []any, tries int, timeout int) error { | ||
| for _, command := range commands { | ||
| for i := 1; ; i++ { |
There was a problem hiding this comment.
@fuyar Should we retry all commands, or just the last one. I think we need to retry the whole batch, may be with a session reset between the retries.
There was a problem hiding this comment.
Depends on if the failed SQL query is within a BEGIN END block I guess ?
If not, you can just retry latest.
If within, it's harder ... You'd have to rollback and retry the whole block
| const ( | ||
| scriptCommandsAttr = "commands" | ||
| scriptTriesAttr = "tries" | ||
| scriptTimeoutAttr = "timeout" |
There was a problem hiding this comment.
that's not really a timeout. More a backoff ?
|
|
||
| func executeCommands(db *DBConnection, commands []any, tries int, timeout int) error { | ||
| for _, command := range commands { | ||
| for i := 1; ; i++ { |
There was a problem hiding this comment.
Depends on if the failed SQL query is within a BEGIN END block I guess ?
If not, you can just retry latest.
If within, it's harder ... You'd have to rollback and retry the whole block
|
|
||
| if err != nil { | ||
| log.Println("[DEBUG] Error catched:", err) | ||
| if _, err := db.Query("ROLLBACK"); err != nil { |
Co-authored-by: Bertrand Paquet <bertrand.paquet@gmail.com>
Co-authored-by: Bertrand Paquet <bertrand.paquet@gmail.com>
Add a
postgresql_scriptresource enabling to execute an array of sql queries.