Method extractViewDefinitions

catalog/database.go:331–371

extractViewDefinitions is a helper function to extract view definitions from DuckDB

(ctx *sql.Context, schemaName string, viewName string)

func (d *Database) CreateTemporaryTable(ctx *sql.Context, name string, schema sql.PrimaryKeySchema, collation sql.CollationID) error {
	d.mu.Lock()
	defer d.mu.Unlock()
	return d.createAllTable(ctx, name, schema, collation, "", true)
}

// DropTable implements sql.TableDropper.
func (d *Database) DropTable(ctx *sql.Context, name string) error {
	d.mu.Lock()
	defer d.mu.Unlock()

	_, err := adapter.Exec(ctx, fmt.Sprintf(`DROP TABLE %s`, FullTableName(d.catalog, d.name, name)))

	if err != nil {
		if IsDuckDBTableNotFoundError(err) {
			return sql.ErrTableNotFound.New(name)
		}
		return ErrDuckDB.New(err)
	}
	return nil
}

// RenameTable implements sql.TableRenamer.
func (d *Database) RenameTable(ctx *sql.Context, oldName string, newName string) error {
	d.mu.Lock()
	defer d.mu.Unlock()

	_, err := adapter.Exec(ctx, fmt.Sprintf(`ALTER TABLE %s RENAME TO "%s"`, FullTableName(d.catalog, d.name, oldName), newName))
	if err != nil {
		if IsDuckDBTableNotFoundError(err) {
			return sql.ErrTableNotFound.New(oldName)
		}
		if IsDuckDBTableAlreadyExistsError(err) {
			return sql.ErrTableAlreadyExists.New(newName)
		}
		return ErrDuckDB.New(err)
	}
	return nil
}

// extractViewDefinitions is a helper function to extract view definitions from DuckDB
func (d *Database) extractViewDefinitions(ctx *sql.Context, schemaName string, viewName string) ([]sql.ViewDefinition, error) {
	query := `
		SELECT DISTINCT view_name, sql, comment
		FROM duckdb_views()
		WHERE schema_name = ? AND NOT internal