diff --git a/apps/api/src/services/market-data/market-data.service.ts b/apps/api/src/services/market-data/market-data.service.ts index e608decca2..c1a31ce815 100644 --- a/apps/api/src/services/market-data/market-data.service.ts +++ b/apps/api/src/services/market-data/market-data.service.ts @@ -248,7 +248,7 @@ export class MarketDataService { state: state as MarketDataState }, where: { - dataSource_date_symbol: { + dataSource_symbol_date: { dataSource: dataSource as DataSource, date: date as Date, symbol: symbol as string diff --git a/apps/api/src/services/queues/data-gathering/data-gathering.service.ts b/apps/api/src/services/queues/data-gathering/data-gathering.service.ts index 1162143421..2897855b01 100644 --- a/apps/api/src/services/queues/data-gathering/data-gathering.service.ts +++ b/apps/api/src/services/queues/data-gathering/data-gathering.service.ts @@ -348,7 +348,7 @@ export class DataGatheringService { }, update: { marketPrice, isCarriedForward: false }, where: { - dataSource_date_symbol: { + dataSource_symbol_date: { dataSource, symbol, date: startOfUtcDate diff --git a/prisma/migrations/20261005000000_updated_indexes_of_market_data/migration.sql b/prisma/migrations/20261005000000_updated_indexes_of_market_data/migration.sql new file mode 100644 index 0000000000..c5482aaf29 --- /dev/null +++ b/prisma/migrations/20261005000000_updated_indexes_of_market_data/migration.sql @@ -0,0 +1,8 @@ +-- DropIndex +DROP INDEX "MarketData_dataSource_symbol_idx"; + +-- DropIndex +DROP INDEX "MarketData_dataSource_date_symbol_key"; + +-- CreateIndex +CREATE UNIQUE INDEX "MarketData_dataSource_symbol_date_key" ON "MarketData"("dataSource", "symbol", "date"); diff --git a/prisma/schema.prisma b/prisma/schema.prisma index d2181e13be..37a3506610 100644 --- a/prisma/schema.prisma +++ b/prisma/schema.prisma @@ -173,9 +173,8 @@ model MarketData { state MarketDataState @default(CLOSE) symbol String - @@unique([dataSource, date, symbol]) + @@unique([dataSource, symbol, date]) @@index([dataSource]) - @@index([dataSource, symbol]) @@index([date]) @@index([state]) @@index([symbol])