diff --git a/server/migrations/1731486908522-AddPhaseHistory.ts b/server/migrations/1731486908522-AddPhaseHistory.ts
new file mode 100644
index 000000000..9756aadcb
--- /dev/null
+++ b/server/migrations/1731486908522-AddPhaseHistory.ts
@@ -0,0 +1,83 @@
+import { Table, TableForeignKey, TableIndex } from 'typeorm';
+import type { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddCreatedAtColumnToStudentAndUserEntities1729236109909 implements MigrationInterface {
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.createTable(
+      new Table({
+        name: 'phase_history',
+        columns: [
+          {
+            name: 'id',
+            type: 'int',
+            isPrimary: true,
+          },
+          {
+            name: 'phase',
+            type: 'tinyint',
+          },
+          {
+            name: 'startingOn',
+            type: 'date',
+          },
+          {
+            name: 'endingOn',
+            type: 'date',
+          },
+        ],
+      }),
+    );
+
+    await queryRunner.createIndex(
+      'phase_history',
+      new TableIndex({
+        name: 'IDX_PHASE_HISTORY',
+        columnNames: ['village', 'phase'],
+        isUnique: true,
+      }),
+    );
+
+    await queryRunner.createForeignKey(
+      'phase_history',
+      new TableForeignKey({
+        columnNames: ['villageId'],
+        referencedColumnNames: ['id'],
+        referencedTableName: 'village',
+        onDelete: 'CASCADE',
+      }),
+    );
+
+    const villages = await queryRunner.query(`SELECT id FROM village`);
+    const startingOn2024Phase1Date = '2024-09-30 00:00:00.000000';
+
+    for (const village of villages) {
+      await queryRunner.query(`INSERT INTO phase_history (villageId, phase, startingOn, endingOn) VALUES (?, ?, ?, ?)`, [
+        village.id,
+        1,
+        startingOn2024Phase1Date,
+        null,
+      ]);
+    }
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    const table = await queryRunner.getTable('phase_history');
+    if (table) {
+      const foreignKey = table.foreignKeys.find((fk) => fk.columnNames.indexOf('questionId') !== -1);
+      if (foreignKey) {
+        await queryRunner.dropForeignKey('phase_history', foreignKey);
+        await queryRunner.createForeignKey(
+          'phase_history',
+          new TableForeignKey({
+            columnNames: ['villageId'],
+            referencedColumnNames: ['id'],
+            referencedTableName: 'village',
+            onDelete: 'CASCADE',
+          }),
+        );
+        await queryRunner.dropIndex('phase_history', 'IDX_PHASE_HISTORY');
+        await queryRunner.dropTable('phase_history');
+      }
+    }
+  }
+}