Function generateCreateTableQuery

packages/node-core/src/db/sync-helper.ts:493–528

(
  model: ModelStatic<Model<any, any>>,
  schema: string,
  withoutForeignKey: boolean
)

}

export function generateCreateTableQuery(
  model: ModelStatic<Model<any, any>>,
  schema: string,
  withoutForeignKey: boolean
): QueryString[] {
  const tableName = model.tableName;

  const attributes = model.getAttributes();
  const columnDefinitions: string[] = [];
  const primaryKeyColumns: string[] = [];
  const comments: Query[] = [];

  Object.keys(attributes).forEach((key) => {
    const attr = attributes[key];

    assert(attr.field, 'Expected field to be set on attribute');

    const columnDefinition = `"${attr.field}" ${formatAttributes(attr, schema, withoutForeignKey)}`;

    columnDefinitions.push(columnDefinition);
    if (attr.comment) {
      comments.push(commentColumnQuery(schema, tableName, attr.field, attr.comment));
    }
    if (attr.primaryKey) {
      primaryKeyColumns.push(`"${attr.field}"`);
    }
  });

  const primaryKeyDefinition = `, PRIMARY KEY (${primaryKeyColumns.join(', ')})`;

  const tableQuery = `CREATE TABLE IF NOT EXISTS "${schema}"."${tableName}" (${columnDefinitions.join(
    ',\n      '
  )}${primaryKeyDefinition});`;

  return [tableQuery, ...comments];
}

export function generateCreateIndexQuery(
  indexes: readonly ModelIndexesOptions[],