Adding config.

lib/config/destination_types.go

@@ -11,6 +11,14 @@ type BigQuery struct {
 	Location          string `yaml:"location"`
 }
 
+type Databricks struct {
+	Host                string `yaml:"host"`
+	HttpPath            string `json:"httpPath"`
+	Port                int    `yaml:"port"`
+	Catalog             string `yaml:"catalog"`
+	PersonalAccessToken string `yaml:"personalAccessToken"`
+}
+
 type MSSQL struct {
 	Host     string `yaml:"host"`
 	Port     int    `yaml:"port"`

lib/config/destinations.go

@@ -1,8 +1,10 @@
 package config
 
 import (
+	"cmp"
 	"fmt"
 	"net/url"
+	"strings"
 
 	"github.com/artie-labs/transfer/lib/cryptography"
 	"github.com/artie-labs/transfer/lib/typing"
@@ -72,3 +74,16 @@ func (s Snowflake) ToConfig() (*gosnowflake.Config, error) {
 
 	return cfg, nil
 }
+
+func (d Databricks) DSN() string {
+	query := url.Values{}
+	query.Add("catalog", d.Catalog)
+	u := &url.URL{
+		Path:     d.HttpPath,
+		User:     url.UserPassword("token", d.PersonalAccessToken),
+		Host:     fmt.Sprintf("%s:%d", d.Host, cmp.Or(d.Port, 443)),
+		RawQuery: query.Encode(),
+	}
+
+	return strings.TrimPrefix(u.String(), "//")
+}

lib/config/destinations_test.go

@@ -0,0 +1,19 @@
+package config
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+)
+
+func TestDatabricks_DSN(t *testing.T) {
+	d := Databricks{
+		Host:                "foo",
+		HttpPath:            "/api/def",
+		Port:                443,
+		Catalog:             "catalogName",
+		PersonalAccessToken: "pat",
+	}
+
+	assert.Equal(t, "token:pat@foo:443/api/def?catalog=catalogName", d.DSN())
+}