Method CreateIndex

catalog/table.go:555–618

CreateIndex implements sql.IndexAlterableTable.

(ctx *sql.Context, indexDef sql.IndexDef)

}

var _ sql.RowUpdater = (*EmptyTableEditor)(nil)

// Updater implements sql.AlterableTable.
func (t *Table) Updater(ctx *sql.Context) sql.RowUpdater {
	// Called when altering a table’s default value. No update needed as DuckDB handles it internally.
	return &EmptyTableEditor{}
}

// Inserter implements sql.InsertableTable.
func (t *Table) Inserter(*sql.Context) sql.RowInserter {
	return &rowInserter{
		db:     t.db.Name(),
		table:  t.name,
		schema: t.schema.Schema,
		hasPK:  t.hasPrimaryKey,
	}
}

// Deleter implements sql.DeletableTable.
func (t *Table) Deleter(*sql.Context) sql.RowDeleter {
	return nil
}

// Truncate implements sql.TruncateableTable.
func (t *Table) Truncate(ctx *sql.Context) (int, error) {
	result, err := adapter.ExecCatalog(ctx, `TRUNCATE TABLE `+FullTableName(t.db.catalog, t.db.name, t.name))
	if err != nil {
		return 0, err
	}
	affected, err := result.RowsAffected()
	return int(affected), err
}

// Replacer implements sql.ReplaceableTable.
func (t *Table) Replacer(*sql.Context) sql.RowReplacer {
	hasKey := len(t.schema.PkOrdinals) > 0 || !sql.IsKeyless(t.schema.Schema)
	return &rowInserter{
		db:      t.db.Name(),
		table:   t.name,
		schema:  t.schema.Schema,
		hasPK:   t.hasPrimaryKey,
		replace: hasKey,
	}
}

// CreateIndex implements sql.IndexAlterableTable.
func (t *Table) CreateIndex(ctx *sql.Context, indexDef sql.IndexDef) error {
	// Lock the table to ensure thread-safety during index creation
	t.mu.Lock()
	defer t.mu.Unlock()

	// https://github.com/apecloud/myduckserver/issues/272
	if isIndexCreationDisabled(ctx) {
		return nil
	}

	if indexDef.IsPrimary() {
		return fmt.Errorf("primary key cannot be created with CreateIndex, use ALTER TABLE ... ADD PRIMARY KEY instead")