Method showCreateDDL

backend/plugin/db/hive/dump.go:165–199

(ctx context.Context, objectType string, objectName string)

}

func (d *Driver) showCreateDDL(ctx context.Context, objectType string, objectName string) (string, error) {
	objectName = fmt.Sprintf("`%s`", objectName)

	// 'SHOW CREATE TABLE' can also be used for dumping views
	stmt := fmt.Sprintf("SHOW CREATE %s %s", objectType, objectName)
	if objectType == "VIEW" {
		stmt = fmt.Sprintf("SHOW CREATE TABLE %s", objectName)
	}

	rows, err := d.db.QueryContext(ctx, stmt)
	if err != nil {
		return "", errors.Wrapf(err, "failed to execute %s", stmt)
	}
	defer rows.Close()

	var schemaDDL strings.Builder
	for rows.Next() {
		var ddlLine string
		if err := rows.Scan(&ddlLine); err != nil {
			return "", errors.Wrap(err, "failed to scan DDL row")
		}
		schemaDDL.WriteString(ddlLine)
		schemaDDL.WriteString("\n")
	}

	if err := rows.Err(); err != nil {
		return "", errors.Wrap(err, "error reading DDL rows")
	}

	if schemaDDL.Len() == 0 {
		return "", errors.New("empty DDL result")
	}

	return fmt.Sprintf(schemaStmtFmt, objectType, objectName, schemaDDL.String()), nil
}

func genIndexDDL(opts *IndexDDLOptions) (string, error) {
	var builder strings.Builder