Framework for creating and using the Unity Catalog connections API

databricks_cli/unity_catalog/api.py

@@ -83,6 +83,23 @@ def delete_external_location(self, name, force):
     def validate_external_location(self, validation_spec):
         return self.client.validate_external_location(validation_spec)
 
+    # Connections APIs
+
+    def create_connection(self, con_spec):
+        return self.client.create_connection(con_spec)
+
+    def list_connections(self):
+        return self.client.list_connections()
+
+    def get_connection(self, name):
+        return self.client.get_connection(name)
+
+    def update_connnection(self, name, con_spec):
+        return self.client.update_connection(name, con_spec)
+
+    def delete_connection(self, name):
+        return self.client.delete_connection(name)
+
     # Data Access Configuration APIs
 
     def create_dac(self, metastore_id, dac_spec, skip_validation):

databricks_cli/unity_catalog/cli.py

@@ -35,6 +35,7 @@
 from databricks_cli.unity_catalog.delta_sharing_cli import register_delta_sharing_commands
 from databricks_cli.unity_catalog.perms_cli import register_perms_commands
 from databricks_cli.unity_catalog.lineage_cli import register_lineage_commands
+from databricks_cli.unity_catalog.connection_cli import register_connection_commands
 
 
 @click.group(context_settings=CONTEXT_SETTINGS)
@@ -56,3 +57,4 @@ def unity_catalog_group():  # pragma: no cover
 register_delta_sharing_commands(unity_catalog_group)
 register_perms_commands(unity_catalog_group)
 register_lineage_commands(unity_catalog_group)
+register_connection_commands(unity_catalog_group)