// generate the derived table
    const derivedTableLines: SQL[] = [];
    for (const usage of usages) {
      derivedTableLines.push(
        sql`( ${usage.customerId}::uuid, ${usage.dataConsumed}::int, ${usage.zoneExternalReference} )`,
        sql`,`,
      );
    }

    derivedTableLines.pop(); // remove the last comma

    // build the query
    const dataConsumedColumn = sql.raw(CustomerPlanModel.dataConsumed.name);
    const usageStartedAt = sql.raw(CustomerPlanModel.usageStartedAt.name);
    const expirationDateColumn = sql.raw(CustomerPlanModel.expirationDate.name);
    const usageLastUpdatedAtColumn = sql.raw(
      CustomerPlanModel.usageLastUpdatedAt.name,
    );
    const query = sql.join([
      sql`
      UPDATE ${CustomerPlanModel}
      SET
        ${dataConsumedColumn} = ${CustomerPlanModel.dataConsumed} + u.dataConsumed,
        ${usageStartedAt} = COALESCE(${CustomerPlanModel.usageStartedAt}, NOW()),
        ${expirationDateColumn} = COALESCE(${CustomerPlanModel.expirationDate}, NOW() + INTERVAL '1 DAY' * ${CustomerPlanModel.initialDuration}),
        ${usageLastUpdatedAtColumn} = NOW()

      --- create a derived table with the values to update
      FROM 
      (VALUES `,
      ...derivedTableLines,
      sql`
      ) u(customerId, dataConsumed, zoneExternalReference)

      WHERE ${CustomerPlanModel.customerId} = u.customerId
      AND ${CustomerPlanModel.zoneExternalReference} = u.zoneExternalReference

      RETURNING *;
    `,
    ]);

    // execute the query
    const updatedPlans = await this.db
      .execute<CustomerPlanModel>(query)
      .catch((e) => {
        const pgDialect = new PgDialect();
        Logger.error('handleUsageEvent: error running the query', {
          query: pgDialect.sqlToQuery(query),
        });
        throw e;
      });

    // generate the derived table
    const derivedTableLines: SQL[] = [];
    for (const usage of usages) {
      derivedTableLines.push(
        sql`( ${usage.customerId}::uuid, ${usage.dataConsumed}::int, ${usage.zoneExternalReference} )`,
        sql`,`,
      );
    }

    derivedTableLines.pop(); // remove the last comma

    // build the query
    const dataConsumedColumn = sql.raw(CustomerPlanModel.dataConsumed.name);
    const usageStartedAt = sql.raw(CustomerPlanModel.usageStartedAt.name);
    const expirationDateColumn = sql.raw(CustomerPlanModel.expirationDate.name);
    const usageLastUpdatedAtColumn = sql.raw(
      CustomerPlanModel.usageLastUpdatedAt.name,
    );
    const query = sql.join([
      sql`
      UPDATE ${CustomerPlanModel}
      SET
        ${dataConsumedColumn} = ${CustomerPlanModel.dataConsumed} + u.dataConsumed,
        ${usageStartedAt} = COALESCE(${CustomerPlanModel.usageStartedAt}, NOW()),
        ${expirationDateColumn} = COALESCE(${CustomerPlanModel.expirationDate}, NOW() + INTERVAL '1 DAY' * ${CustomerPlanModel.initialDuration}),
        ${usageLastUpdatedAtColumn} = NOW()

      --- create a derived table with the values to update
      FROM 
      (VALUES `,
      ...derivedTableLines,
      sql`
      ) u(customerId, dataConsumed, zoneExternalReference)

      WHERE ${CustomerPlanModel.customerId} = u.customerId
      AND ${CustomerPlanModel.zoneExternalReference} = u.zoneExternalReference

      RETURNING *;
    `,
    ]);

    // execute the query
    const updatedPlans = await this.db
      .execute<CustomerPlanModel>(query)
      .catch((e) => {
        const pgDialect = new PgDialect();
        Logger.error('handleUsageEvent: error running the query', {
          query: pgDialect.sqlToQuery(query),
        });
        throw e;
      });

export const CustomerPlanModel = pgTable(
  'customer_plan',
  {
    id: uuid('id').primaryKey().defaultRandom(),
    initialDuration: integer('initial_duration'),
    usageStartedAt: timestamp('usage_started_at'),
...

export const CustomerPlanModel = pgTable(
  'customer_plan',
  {
    id: uuid('id').primaryKey().defaultRandom(),
    initialDuration: integer('initial_duration'),
    usageStartedAt: timestamp('usage_started_at'),
...