Method createAllTable

catalog/database.go:127–263

(ctx *sql.Context, name string, schema sql.PrimaryKeySchema, collation sql.CollationID, comment string, temporary bool)

	return tbls, nil
}

// Name implements sql.Database.
func (d *Database) Name() string {
	return d.name
}

func (d *Database) createAllTable(ctx *sql.Context, name string, schema sql.PrimaryKeySchema, collation sql.CollationID, comment string, temporary bool) error {
	var columns []string
	var columnCommentSQLs []string
	var fullTableName string

	if temporary {
		fullTableName = FullTableName("temp", "main", name)
	} else {
		fullTableName = FullTableName(d.catalog, d.name, name)
	}

	var sequenceName, fullSequenceName string

	for _, col := range schema.Schema {
		typ, err := DuckdbDataType(col.Type)
		if err != nil {
			return err
		}
		colDef := fmt.Sprintf(`"%s" %s`, col.Name, typ.name)
		if col.Nullable {
			colDef += " NULL"
		} else {
			colDef += " NOT NULL"
		}

		if col.Default != nil {
			typ.mysql.Default = col.Default.String()
			defaultExpr, err := parseDefaultValue(typ.mysql.Default)
			if err != nil {
				return err
			}
			colDef += " DEFAULT " + defaultExpr
		} else if col.AutoIncrement {
			typ.mysql.AutoIncrement = true

			// Generate a random sequence name.
			// TODO(fan): Drop the sequence when the table is dropped or the column is removed.
			uuid, err := uuid.NewRandom()
			if err != nil {
				return err
			}
			sequenceName = SequenceNamePrefix + uuid.String()
			if temporary {
				fullSequenceName = `temp.main."` + sequenceName + `"`
			} else {
				fullSequenceName = InternalSchemas.SYS.Schema + `."` + sequenceName + `"`
			}

			defaultExpr := `nextval('` + fullSequenceName + `')`
			colDef += " DEFAULT " + defaultExpr
		}