Skip to content

Commit e538cdf

Browse files
checking delete old data
1 parent b2d5e9e commit e538cdf

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

modules/module-postgres-storage/src/storage/PostgresReportStorageFactory.ts

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -355,7 +355,7 @@ export class PostgresReportStorageFactory implements storage.ReportStorageFactor
355355
async deleteOldSdkData(data: DeleteOldSdkData): Promise<void> {
356356
const { timeframe, interval } = data;
357357
const { lt } = this.timeFrameDeleteQuery(timeframe, interval);
358-
await this.db.sql`
358+
const result = await this.db.sql`
359359
DELETE FROM sdk_report_events
360360
WHERE
361361
connect_at < ${{ type: 1184, value: lt }}
@@ -367,6 +367,11 @@ export class PostgresReportStorageFactory implements storage.ReportStorageFactor
367367
)
368368
);
369369
`.execute();
370+
if (result.rows.length > 0) {
371+
result.rows.forEach((row) => {
372+
console.log(row);
373+
});
374+
}
370375
}
371376

372377
async [Symbol.asyncDispose]() {

0 commit comments

Comments
 (0)