Function commitChange

src/lib/sql/sql-execute-helper.ts:71–108

({
  driver,
  tableName,
  tableSchema,
  data,
}: {
  driver: BaseDriver;
  tableName: string;
  tableSchema: DatabaseTableSchema;
  data: OptimizeTableState;
})

}

export async function commitChange({
  driver,
  tableName,
  tableSchema,
  data,
}: {
  driver: BaseDriver;
  tableName: string;
  tableSchema: DatabaseTableSchema;
  data: OptimizeTableState;
}): Promise<{ errorMessage?: string }> {
  const plans = generateTableChangePlan({
    tableSchema,
    data,
  });

  try {
    const result = await driver.updateTableData(
      tableSchema.schemaName,
      tableName,
      plans.map((p) => p.plan),
      tableSchema
    );

    data.applyChanges(
      plans.map((p, idx) => {
        return {
          row: p.row,
          updated: result[idx]?.record ?? {},
        };
      })
    );
  } catch (e) {
    return { errorMessage: (e as Error).message };
  }

  return {};
}