Gleipnir/nidus-sync
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Get proprely typed results.

Browse source
This commit is contained in:
Eli Ribble 2025-12-03 21:52:43 +00:00
parent 9308097ff0
commit 38b5f9816f
No known key found for this signature in database
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
db/prepared.go
View file

@ -124,13 +124,13 @@ func TestPreparedQuery(ctx context.Context, row *fslayer.RodentLocation) error {
}
query := psql.RawQuery(q)
log.Info().Str("query", q).Msg("querying")
result, err := bob.One[InsertResult](ctx, PGInstance.BobDB, query, scan.StructMapper[InsertResult]())
result, err := bob.One[InsertResultRow](ctx, PGInstance.BobDB, query, scan.StructMapper[InsertResultRow]())
if err != nil {
return fmt.Errorf("Failed to execute test function: %w", err)
}
//log.Info().Int("version", result.NextVersion).Msg("got result")
//log.Info().Bool("added", result.Row.Added).Int("version", result.Row.Version).Msg("done")
log.Info().Str("row", result.Row).Msg("done")
log.Info().Bool("inserted", result.Added).Int("version", result.Version).Msg("done")
return nil
}
@ -272,7 +272,7 @@ func (p TimestamptzParam) ToSql() string {
func queryStoredProcedure(procedure string, params ...SqlParam) string {
if len(params) == 0 {
return fmt.Sprintf("SELECT %s()", procedure)
return fmt.Sprintf("SELECT * FROM %s()", procedure)
}
// Convert each parameter to its SQL representation
@ -282,7 +282,7 @@ func queryStoredProcedure(procedure string, params ...SqlParam) string {
}
// Join parameters and return the execute statement
return fmt.Sprintf("SELECT %s(%s)", procedure, strings.Join(paramStrings, ", "))
return fmt.Sprintf("SELECT * FROM %s(%s)", procedure, strings.Join(paramStrings, ", "))
}
func executeFunction(functionName string, params ...SqlParam) string {