Change Database

app/api/mahasiswa/statistik/route.ts

@@ -1,8 +1,7 @@
 import { NextResponse } from 'next/server';
-import pool from '@/lib/db';
-import { RowDataPacket } from 'mysql2';
+import supabase from '@/lib/db';
 
-interface MahasiswaStatistik extends RowDataPacket {
+interface MahasiswaStatistik {
   tahun_angkatan: number;
   total_mahasiswa: number;
   pria: number;
@@ -23,19 +22,52 @@ export async function OPTIONS() {
 }
 
 export async function GET() {
-  const connection = await pool.getConnection();
-  
   try {
-    // Query untuk mendapatkan statistik mahasiswa per tahun angkatan
-    const [results] = await connection.query<MahasiswaStatistik[]>(`
-      SELECT 
-        tahun_angkatan,
-        COUNT(*) as total_mahasiswa,
-        SUM(CASE WHEN jk = 'Pria' THEN 1 ELSE 0 END) as pria,
-        SUM(CASE WHEN jk = 'Wanita' THEN 1 ELSE 0 END) as wanita
-      FROM mahasiswa
-      GROUP BY tahun_angkatan
-    `);
+    // Get all mahasiswa data
+    const { data, error } = await supabase
+      .from('mahasiswa')
+      .select('tahun_angkatan, jk');
+
+    if (error) {
+      console.error('Error fetching mahasiswa statistik:', error);
+      return NextResponse.json(
+        { error: 'Failed to fetch mahasiswa statistik' },
+        { 
+          status: 500,
+          headers: {
+            'Access-Control-Allow-Origin': '*',
+            'Access-Control-Allow-Methods': 'GET, OPTIONS',
+            'Access-Control-Allow-Headers': 'Content-Type, Authorization',
+          },
+        }
+      );
+    }
+
+    // Group by tahun_angkatan and calculate statistics
+    const groupedData = data.reduce((acc, item) => {
+      const tahun = item.tahun_angkatan;
+      if (!acc[tahun]) {
+        acc[tahun] = {
+          tahun_angkatan: tahun,
+          total_mahasiswa: 0,
+          pria: 0,
+          wanita: 0
+        };
+      }
+      
+      acc[tahun].total_mahasiswa += 1;
+      if (item.jk === 'Pria') {
+        acc[tahun].pria += 1;
+      } else if (item.jk === 'Wanita') {
+        acc[tahun].wanita += 1;
+      }
+      
+      return acc;
+    }, {} as Record<number, MahasiswaStatistik>);
+
+    // Convert to array and sort by tahun_angkatan
+    const results: MahasiswaStatistik[] = Object.values(groupedData)
+      .sort((a, b) => a.tahun_angkatan - b.tahun_angkatan);
 
     // Menambahkan header cache dan CORS
     return NextResponse.json(results, {
@@ -59,7 +91,5 @@ export async function GET() {
         },
       }
     );
-  } finally {
-    connection.release();
   }
 }