(connstr, database string)
| 121 | } |
| 122 | |
| 123 | func connstrWithDatabase(connstr, database string) (string, error) { |
| 124 | u, err := url.Parse(connstr) |
| 125 | if err != nil { |
| 126 | return "", fmt.Errorf("invalid connstr: %q", connstr) |
| 127 | } |
| 128 | u.Path = database |
| 129 | return u.String(), nil |
| 130 | } |
| 131 | |
| 132 | func createDatabase(ctx context.Context, db *pgx.Conn, name string) error { |
| 133 | _, err := db.Exec(ctx, `CREATE DATABASE `+sanitizeDatabaseName(name)+`;`) |