-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
postgres: Separate out common functions into own file
- Loading branch information
Showing
2 changed files
with
150 additions
and
128 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,149 @@ | ||
| // Copyright © 2024 Triad National Security, LLC. All rights reserved. | ||
| // | ||
| // This program was produced under U.S. Government contract 89233218CNA000001 | ||
| // for Los Alamos National Laboratory (LANL), which is operated by Triad | ||
| // National Security, LLC for the U.S. Department of Energy/National Nuclear | ||
| // Security Administration. All rights in the program are reserved by Triad | ||
| // National Security, LLC, and the U.S. Department of Energy/National Nuclear | ||
| // Security Administration. The Government is granted for itself and others | ||
| // acting on its behalf a nonexclusive, paid-up, irrevocable worldwide license | ||
| // in this material to reproduce, prepare derivative works, distribute copies to | ||
| // the public, perform publicly and display publicly, and to permit others to do | ||
| // so. | ||
|
|
||
| package postgres | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "regexp" | ||
| "strings" | ||
|
|
||
| "github.com/jmoiron/sqlx" | ||
| "github.com/jmoiron/sqlx/reflectx" | ||
| ) | ||
|
|
||
| const ( | ||
| xNameRegex = `^x([0-9]{1,4})c([0-7])(s([0-9]{1,4}))?b([0])(n([0-9]{1,4}))?$` | ||
| ) | ||
|
|
||
| // makeKey creates a key from a key and subkey. If key is not empty, it will | ||
| // be prepended with a '/' if it does not already start with one. If subkey is | ||
| // not empty, it will be appended with a '/' if it does not already end with | ||
| // one. The two will be concatenated with no '/' between them. | ||
| func makeKey(key, subkey string) string { | ||
| ret := key | ||
| if key != "" && key[0] != '/' { | ||
| ret = "/" + key | ||
| } | ||
| if subkey != "" { | ||
| if subkey[0] != '/' { | ||
| ret += "/" | ||
| } | ||
| ret += subkey | ||
| } | ||
| return ret | ||
| } | ||
|
|
||
| // tagToColName extracts the field name from the JSON struct tag. Replace - with | ||
| // _. | ||
| // E.g: From `json:"params,omitempty"` comes `params`. | ||
| func tagToColName(tag string) string { | ||
| re := regexp.MustCompile(`json:"([a-z0-9-]+)(?:,[a-z0-9-]+)*"`) | ||
| colName := re.FindString(tag) | ||
| return strings.Replace(colName, "-", "_", -1) | ||
| } | ||
|
|
||
| // fieldNameToColName converts the struct field name (in Pascal case) into | ||
| // the format for the database column (in snake case). | ||
| func fieldNameToColName(fieldName string) string { | ||
| firstCap := regexp.MustCompile(`(.)([A-Z][a-z]+)`) | ||
| allCaps := regexp.MustCompile(`([a-z0-9])([A-Z])`) | ||
| colName := firstCap.ReplaceAllString(fieldName, `${1}_${2}`) | ||
| colName = allCaps.ReplaceAllString(colName, `${1}_${2}`) | ||
| return strings.ToLower(colName) | ||
| } | ||
|
|
||
| func stringSliceToSql(ss []string) string { | ||
| if len(ss) == 0 { | ||
| return "('')" | ||
| } | ||
| sep := "" | ||
| s := "(" | ||
| for i, st := range ss { | ||
| s += sep + fmt.Sprintf("'%s'", st) | ||
| if i == len(ss)-1 { | ||
| sep = "" | ||
| } else { | ||
| sep = ", " | ||
| } | ||
| } | ||
| s += ")" | ||
| return s | ||
| } | ||
|
|
||
| func int32SliceToSql(is []int32) string { | ||
| sep := "" | ||
| s := "(" | ||
| for i, in := range is { | ||
| s += sep + fmt.Sprintf("%d", in) | ||
| if i == len(is)-1 { | ||
| sep = "" | ||
| } else { | ||
| sep = ", " | ||
| } | ||
| } | ||
| s += ")" | ||
| return s | ||
| } | ||
|
|
||
| // Return the intersection of a and b (matches) and those elements in b but not in a (exclusions). | ||
| func getMatches(a, b []string) (matches, exclusions []string) { | ||
| for _, aVal := range a { | ||
| aInB := false | ||
| for _, bVal := range b { | ||
| if aVal == bVal { | ||
| matches = append(matches, aVal) | ||
| aInB = true | ||
| break | ||
| } | ||
| } | ||
| if !aInB { | ||
| exclusions = append(exclusions, aVal) | ||
| } | ||
| } | ||
| return matches, exclusions | ||
| } | ||
|
|
||
| // Connect opens a new connections to a Postgres database and ensures it is reachable. | ||
| // If not, an error is thrown. | ||
| func Connect(host string, port uint, dbName, user, password string, ssl bool, extraDbOpts string) (BootDataDatabase, error) { | ||
| var ( | ||
| sslmode string | ||
| bddb BootDataDatabase | ||
| ) | ||
| if ssl { | ||
| sslmode = "verify-full" | ||
| } else { | ||
| sslmode = "disable" | ||
| } | ||
| connStr := fmt.Sprintf("user=%s password=%s host=%s port=%d dbname=%s sslmode=%s", user, password, host, port, dbName, sslmode) | ||
| if extraDbOpts != "" { | ||
| connStr += " " + extraDbOpts | ||
| } | ||
| db, err := sqlx.Connect("postgres", connStr) | ||
| if err != nil { | ||
| return bddb, err | ||
| } | ||
| // Create a new mapper which will use the struct field tag "json" instead of "db", | ||
| // and ignore extra JSON config values, e.g. "omitempty". | ||
| db.Mapper = reflectx.NewMapperTagFunc("json", fieldNameToColName, tagToColName) | ||
| bddb.DB = db | ||
|
|
||
| return bddb, err | ||
| } | ||
|
|
||
| // Close calls the Close() method on the database object within the BootDataDatabase. If it errs, an | ||
| // error is returned. | ||
| func (bddb BootDataDatabase) Close() error { | ||
| return bddb.DB.Close() | ||
| } |