cloudquery · kodiakhq · Jul 24, 2023 · Jul 19, 2023 · Jul 24, 2023
@@ -169,6 +169,7 @@
 - [azure_monitor_tenant_activity_logs](../../../../../website/tables/azure/azure_monitor_tenant_activity_logs.md)
 - [azure_mysql_servers](../../../../../website/tables/azure/azure_mysql_servers.md)
   - [azure_mysql_server_configurations](../../../../../website/tables/azure/azure_mysql_server_configurations.md)
+  - [azure_mysql_server_databases](../../../../../website/tables/azure/azure_mysql_server_databases.md)
 - [azure_mysqlflexibleservers_servers](../../../../../website/tables/azure/azure_mysqlflexibleservers_servers.md)
 - [azure_network_application_gateways](../../../../../website/tables/azure/azure_network_application_gateways.md)
 - [azure_network_application_security_groups](../../../../../website/tables/azure/azure_network_application_security_groups.md)

@@ -0,0 +1,44 @@
+package mysql
+
+import (
+	"context"
+
+	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/mysql/armmysql"
+	"github.com/cloudquery/cloudquery/plugins/source/azure/client"
+	"github.com/cloudquery/plugin-sdk/v4/schema"
+	"github.com/cloudquery/plugin-sdk/v4/transformers"
+)
+
+func databases() *schema.Table {
+	return &schema.Table{
+		Name:                 "azure_mysql_server_databases",
+		Resolver:             fetchDatabases,
+		PostResourceResolver: client.LowercaseIDResolver,
+		Description:          "https://learn.microsoft.com/en-us/rest/api/mysql/singleserver/databases/list-by-server?tabs=HTTP#database",
+		Multiplex:            client.SubscriptionMultiplexRegisteredNamespace("azure_mysql_server_databases", client.Namespacemicrosoft_dbformysql),
+		Transform:            transformers.TransformWithStruct(&armmysql.Database{}, transformers.WithPrimaryKeys("ID")),
+		Columns:              schema.ColumnList{},
+	}
+}
+
+func fetchDatabases(ctx context.Context, meta schema.ClientMeta, parent *schema.Resource, res chan<- any) error {
+	cl := meta.(*client.Client)
+	svc, err := armmysql.NewDatabasesClient(cl.SubscriptionId, cl.Creds, cl.Options)
+	if err != nil {
+		return err
+	}
+	server := parent.Item.(*armmysql.Server)
+	group, err := client.ParseResourceGroup(*server.ID)
+	if err != nil {
+		return err
+	}
+	pager := svc.NewListByServerPager(group, *server.Name, nil)
+	for pager.More() {
+		p, err := pager.NextPage(ctx)
+		if err != nil {
+			return err
+		}
+		res <- p.Value
+	}
+	return nil
+}
@@ -0,0 +1,30 @@
+package mysql
+
+import (
+	"encoding/json"
+	"net/http"
+
+	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/mysql/armmysql"
+	"github.com/cloudquery/plugin-sdk/v4/faker"
+	"github.com/gorilla/mux"
+)
+
+func createDatabases(router *mux.Router) error {
+	var item armmysql.DatabasesClientListByServerResponse
+	if err := faker.FakeObject(&item); err != nil {
+		return err
+	}
+
+	router.HandleFunc("/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DBforMySQL/servers/{serverName}/databases", func(w http.ResponseWriter, r *http.Request) {
+		b, err := json.Marshal(&item)
+		if err != nil {
+			http.Error(w, "unable to marshal request: "+err.Error(), http.StatusBadRequest)
+			return
+		}
+		if _, err := w.Write(b); err != nil {
+			http.Error(w, "failed to write", http.StatusBadRequest)
+			return
+		}
+	})
+	return nil
+}
@@ -21,6 +21,7 @@ func Servers() *schema.Table {
 
 		Relations: []*schema.Table{
 			server_configurations(),
+			databases(),
 		},
 	}
 }

@@ -29,6 +29,11 @@ func createServers(router *mux.Router) error {
 			return
 		}
 	})
+
+	if err := createDatabases(router); err != nil {
+		return err
+	}
+
 	return createServerConfigurations(router)
 }
 

@@ -0,0 +1,22 @@
+# Table: azure_mysql_server_databases
+
+This table shows data for Azure MySQL Server Databases.
+
+https://learn.microsoft.com/en-us/rest/api/mysql/singleserver/databases/list-by-server?tabs=HTTP#database
+
+The primary key for this table is **id**.
+
+## Relations
+
+This table depends on [azure_mysql_servers](azure_mysql_servers).
+
+## Columns
+
+| Name          | Type          |
+| ------------- | ------------- |
+|_cq_id|`uuid`|
+|_cq_parent_id|`uuid`|
+|properties|`json`|
+|id (PK)|`utf8`|
+|name|`utf8`|
+|type|`utf8`|
@@ -10,6 +10,7 @@ The primary key for this table is **id**.
 
 The following tables depend on azure_mysql_servers:
   - [azure_mysql_server_configurations](azure_mysql_server_configurations)
+  - [azure_mysql_server_databases](azure_mysql_server_databases)
 
 ## Columns
-Original file line number
+Diff line change
@@ Expand Up / @@ -21,6 +21,7 @@ func Servers() *schema.Table { @@
     		Relations: []*schema.Table{
     			server_configurations(),
+    			databases(),
     		},
     	}
     }
@@ Expand Down @@