Update.

lib/config/constants/constants.go

@@ -77,6 +77,7 @@ const (
 
 // TODO: Add Databricks here when it's live.
 var ValidDestinations = []DestinationKind{
+	Databricks,
 	BigQuery,
 	MSSQL,
 	Redshift,

lib/config/destination_types.go

@@ -53,10 +53,11 @@ type Snowflake struct {
 }
 
 type Databricks struct {
-	Host     string `yaml:"host"`
-	Port     int    `yaml:"port"`
-	Username string `yaml:"username"`
-	Password string `yaml:"password"`
-	Database string `yaml:"database"`
-	Protocol string `yaml:"protocol"`
+	Host                string `yaml:"host"`
+	Port                int    `yaml:"port"`
+	PersonalAccessToken string `yaml:"personalAccessToken"`
+	Database            string `yaml:"database"`
+	Protocol            string `yaml:"protocol"`
+	CatalogName         string `yaml:"catalogName"`
+	SchemaName          string `yaml:"schemaName"`
 }

lib/config/destinations.go

@@ -74,12 +74,15 @@ func (s Snowflake) ToConfig() (*gosnowflake.Config, error) {
 }
 
 func (d Databricks) DSN() string {
-	return fmt.Sprintf("%s://%s:%s@%s:%d/%s",
-		d.Protocol,
-		url.QueryEscape(d.Username),
-		url.QueryEscape(d.Password),
-		d.Host,
-		d.Port,
-		d.Database,
-	)
+	query := url.Values{}
+	query.Add("catalog", d.CatalogName)
+	query.Add("schema", d.SchemaName)
+	u := &url.URL{
+		Scheme:   "databricks",
+		User:     url.UserPassword("token", d.PersonalAccessToken),
+		Host:     fmt.Sprintf("%s:%d", d.Host, d.Port),
+		RawQuery: query.Encode(),
+	}
+
+	return u.String()
 }