Method createsqlPrimaryTableQuery

provider/sql.go:293–304

primaryTableCreate creates a query for table creation based on the specified TableSchema. Returns the query if successful. Returns an error if there is an invalid column type.

(name string, schema TableSchema)

// specified TableSchema. Returns the query if successful. Returns an error
// if there is an invalid column type.
func (store *sqlOfflineStore) createsqlPrimaryTableQuery(name string, schema TableSchema) (string, error) {
	columns := make([]string, 0)
	for _, column := range schema.Columns {
		columnType, err := store.query.determineColumnType(column.ValueType)
		if err != nil {
			return "", err
		}
		columns = append(columns, fmt.Sprintf("%s %s", column.Name, columnType))
	}
	columnString := strings.Join(columns, ", ")
	return store.query.primaryTableCreate(name, columnString), nil
}

func (store *sqlOfflineStore) GetPrimaryTable(id ResourceID) (PrimaryTable, error) {
	name, err := GetPrimaryTableName(id)