Function generateTableChangePlan

src/lib/sql/sql-execute-helper.ts:15–69

({
  tableSchema,
  data,
}: {
  tableSchema: DatabaseTableSchema;
  data: OptimizeTableState;
})

}

function generateTableChangePlan({
  tableSchema,
  data,
}: {
  tableSchema: DatabaseTableSchema;
  data: OptimizeTableState;
}): ExecutePlan[] {
  const rowChangeList = data.getChangedRows();
  const plans: ExecutePlan[] = [];

  for (const row of rowChangeList) {
    const rowChange = row.change;
    if (rowChange) {
      const pk = tableSchema.pk;

      const wherePrimaryKey = pk.reduce<Record<string, unknown>>(
        (condition, pkColumnName) => {
          condition[pkColumnName] = row.raw[pkColumnName];
          return condition;
        },
        {}
      );

      if (row.isNewRow) {
        plans.push({
          row,
          plan: {
            operation: "INSERT",
            values: rowChange,
            autoIncrementPkColumn: tableSchema.autoIncrement
              ? tableSchema.pk[0]
              : undefined,
            pk: tableSchema.pk,
          },
        });
      } else if (row.isRemoved) {
        plans.push({
          row,
          plan: { operation: "DELETE", where: wherePrimaryKey },
        });
      } else {
        plans.push({
          row,
          plan: {
            operation: "UPDATE",
            where: wherePrimaryKey,
            values: rowChange,
          },
        });
      }
    }
  }

  return plans;
}

export async function commitChange({
  driver,