gopkg/pgx
2
0
Fork 0
Code Activity

Expose ParseConfig

Browse Source
This commit is contained in:
Jack Christensen
2019-04-12 16:56:54 -05:00
parent 0254279df7
commit 3497f0e8f9
1 changed files with 14 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
conn.go
+14 -6
View File
@@ -139,6 +139,19 @@ func (e ProtocolError) Error() string {
// Connect establishes a connection with a PostgreSQL server with a connection string. See // Connect establishes a connection with a PostgreSQL server with a connection string. See
// pgconn.Connect for details. // pgconn.Connect for details.
func Connect(ctx context.Context, connString string) (*Conn, error) { func Connect(ctx context.Context, connString string) (*Conn, error) {
connConfig, err := ParseConfig(connString)
if err != nil {
return nil, err
}
return connect(ctx, connConfig, minimalConnInfo)
}
// Connect establishes a connection with a PostgreSQL server with a configuration struct.
func ConnectConfig(ctx context.Context, connConfig *ConnConfig) (*Conn, error) {
return connect(ctx, connConfig, minimalConnInfo)
}
func ParseConfig(connString string) (*ConnConfig, error) {
config, err := pgconn.ParseConfig(connString) config, err := pgconn.ParseConfig(connString)
if err != nil { if err != nil {
return nil, err return nil, err
@@ -147,12 +160,7 @@ func Connect(ctx context.Context, connString string) (*Conn, error) {
Config: *config, Config: *config,
} }
return connect(ctx, connConfig, minimalConnInfo) return connConfig, nil
}
// Connect establishes a connection with a PostgreSQL server with a configuration struct.
func ConnectConfig(ctx context.Context, connConfig *ConnConfig) (*Conn, error) {
return connect(ctx, connConfig, minimalConnInfo)
} }
func connect(ctx context.Context, config *ConnConfig, connInfo *pgtype.ConnInfo) (c *Conn, err error) { func connect(ctx context.Context, config *ConnConfig, connInfo *pgtype.ConnInfo) (c *Conn, err error) {