Method schemaTables

plugins/destination/mysql/client/schema.go:82–113

TODO: in the future this could theoretically be done in a single query and then the tables could be filtered in memory

(ctx context.Context, tables schema.Tables)

// TODO: in the future this could theoretically be done in a single query and then the tables could be filtered in memory
func (c *Client) schemaTables(ctx context.Context, tables schema.Tables) (schema.Tables, error) {
	query := `SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_TYPE = 'BASE TABLE' AND (DATABASE() IS NULL OR table_SCHEMA = DATABASE());`
	rows, err := c.db.QueryContext(ctx, query)
	if err != nil {
		return nil, err
	}
	defer rows.Close()
	schemaTables := make(schema.Tables, 0)
	tableNames := make([]string, 0)
	for rows.Next() {
		var tableName string

		if err := rows.Scan(&tableName); err != nil {
			return nil, err
		}

		if tables.Get(tableName) == nil {
			continue
		}
		tableNames = append(tableNames, tableName)
	}

	for _, tableName := range tableNames {
		fields, err := c.getTableColumns(ctx, tableName)
		if err != nil {
			return nil, err
		}
		schemaTables = append(schemaTables, &schema.Table{Name: tableName, Columns: fields})
	}

	return schemaTables, nil
}

func (c *Client) addColumn(ctx context.Context, table *schema.Table, column *schema.Column) error {
	builder := strings.Builder{}