Method Dump

backend/plugin/db/hive/dump.go:59–163

(ctx context.Context, out io.Writer, _ *storepb.DatabaseSchemaMetadata)

}

func (d *Driver) Dump(ctx context.Context, out io.Writer, _ *storepb.DatabaseSchemaMetadata) error {
	if d.db == nil {
		return errors.New("connection not initialized")
	}

	var builder strings.Builder

	databaseName := d.config.ConnectionContext.DatabaseName
	database, err := d.SyncDBSchema(ctx)
	if err != nil {
		return err
	}
	if len(database.Schemas) == 0 {
		return errors.New("database schemas is empty")
	}
	schema := database.Schemas[0]

	// Set current database
	if _, err := d.db.ExecContext(ctx, fmt.Sprintf("USE %s", databaseName)); err != nil {
		return errors.Wrap(err, "failed to set database")
	}

	// Dump managed tables
	for _, table := range schema.GetTables() {
		tableDDL, err := d.showCreateDDL(ctx, "TABLE", table.Name)
		if err != nil {
			return errors.Wrapf(err, "failed to dump table %s", table.Name)
		}

		// Dump indexes
		for _, index := range table.GetIndexes() {
			indexDDL, err := genIndexDDL(&IndexDDLOptions{
				databaseName:          databaseName,
				indexName:             index.Name,
				tableName:             table.Name,
				indexType:             index.Type,
				colNames:              index.Expressions,
				isWithDeferredRebuild: true,
				idxProperties:         nil,
				indexTableName:        "",
				rowFmt:                "",
				storedAs:              "",
				storedBy:              "",
				location:              "",
				tableProperties:       nil,
				comment:               index.Comment,
			})
			if err != nil {
				return errors.Wrapf(err, "failed to generate DDL for index %s", index.Name)
			}

			_, _ = fmt.Fprintf(&builder, schemaStmtFmt, "INDEX", fmt.Sprintf("`%s`", index.Name), indexDDL)
		}
		_, _ = builder.WriteString(tableDDL)
	}

	// Dump external tables
	for _, extTable := range schema.GetExternalTables() {