cockroach supports URL connection string
This commit is contained in:
parent
c725b4c797
commit
101017a29c
@ -4,6 +4,7 @@ package cockroach
|
|||||||
import (
|
import (
|
||||||
"database/sql"
|
"database/sql"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"net/url"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
"unicode"
|
"unicode"
|
||||||
@ -212,8 +213,13 @@ func (s *sqlStore) configure() error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
source := nodes[0]
|
source := nodes[0]
|
||||||
if !strings.Contains(source, " ") {
|
// check if it is a standard connection string eg: host=%s port=%d user=%s password=%s dbname=%s sslmode=disable
|
||||||
source = fmt.Sprintf("host=%s", source)
|
// if err is nil which means it would be a URL like postgre://xxxx?yy=zz
|
||||||
|
_, err := url.Parse(source)
|
||||||
|
if err != nil {
|
||||||
|
if !strings.Contains(source, " ") {
|
||||||
|
source = fmt.Sprintf("host=%s", source)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// create source from first node
|
// create source from first node
|
||||||
|
Loading…
Reference in New Issue
Block a user