Working repository classes with most functionality complete.

backend/repository/addressRepository.js

@@ -62,6 +62,69 @@ async function addAddress(address, peopleId) {
   }
 }
 
+async function updateAddress() {
+  console.log("Update address not implemented!");
+}
+
+/*
+Function to find all address information associated with a person.
+Returns an array of address objects or an empty array if no addresses exist.
+*/
+async function getAddressesForPerson(peopleId) {
+  console.log("Finding addresses for person with ID: ", peopleId);
+
+  try {
+    const query = `
+      SELECT 
+        a.addressId, 
+        a.address1, 
+        a.address2, 
+        a.city, 
+        sl.name AS state, 
+        cl.name AS country, 
+        a.zipCode, 
+        pa.preferredAddress
+      FROM 
+        peopleXAddress pa
+      LEFT JOIN 
+        address a ON pa.addressId = a.addressId
+      LEFT JOIN 
+        stateLookup sl ON a.stateId = sl.stateId
+      LEFT JOIN 
+        countryLookup cl ON a.countryId = cl.countryId
+      WHERE 
+        pa.peopleId = ?;
+    `;
+
+    // Execute the query
+    const [results] = await pool.query(query, [peopleId]);
+
+    if (results.length === 0) {
+      console.log("No addresses found for person with ID:", peopleId);
+      return [];
+    }
+
+    // Map the results to structured address objects
+    const addresses = results.map((row) => ({
+      addressId: row.addressId,
+      address1: row.address1,
+      address2: row.address2,
+      city: row.city,
+      state: row.state,
+      country: row.country,
+      zipCode: row.zipCode,
+      preferredAddress: row.preferredAddress,
+    }));
+
+    console.log("Found addresses: ", addresses);
+
+    return addresses;
+  } catch (error) {
+    console.error("Error fetching addresses for person: ", error);
+    return [];
+  }
+}
+
 // Private helper function to look up the stateId
 async function _lookupStateId(state) {
   // for now return 1 while tables are not populated
@@ -106,4 +169,4 @@ async function _lookupCountryId(country) {
   // }
 }
 
-module.exports = { addAddress };
+module.exports = { addAddress, getAddressesForPerson };

backend/repository/contactRepository.js

@@ -2,7 +2,8 @@ const { pool } = require("../config/database/database.config");
 
 /*
 Function to add a row into the peopleContact
-table with the contact info given
+table with the contact info given. Returns the id of the new contact.
+If no contact is added, null is returned
 */
 async function addContact(contact, peopleId) {
   // extract the parts of the contact
@@ -25,11 +26,101 @@ async function addContact(contact, peopleId) {
       preferredContact,
     ]);
 
-    return results;
+    return results.insertId;
   } catch (error) {
     console.log(error);
     return null;
   }
 }
 
-module.exports = { addContact };
+/*
+Function to update the data for a specific contact. The 
+function will return true if the update was successful and false
+otherwise.
+*/
+async function updateContact(peopleContactId, peopleId, contactInfo) {
+  // extract the parts of the contact
+  let { contactNumber, contactType, preferredContact } = contactInfo;
+
+  console.log("updating contact....");
+
+  try {
+    const query = `
+        UPDATE peopleContact
+        SET
+          peopleId = ?,
+          contactNumber = ?,
+          contactType = ?,
+          preferredContact = ?
+        WHERE peopleContactId = ?
+      `;
+
+    const [results] = await pool.query(query, [
+      peopleId,
+      contactNumber,
+      contactType,
+      preferredContact,
+      peopleContactId,
+    ]);
+
+    // Check if any rows were affected
+    if (results.affectedRows === 0) {
+      console.error("Contact not found. no rows updated");
+      return false;
+    }
+
+    // return true to signify success
+    return true;
+  } catch (error) {
+    console.log("Error updating contact: ", error);
+    return false;
+  }
+}
+
+/*
+Function to find all contact information associated with a person.
+Returns an array of contact objects or an empty array if no contacts exist.
+*/
+async function getContactsForPerson(peopleId) {
+  console.log("Finding contacts for person with ID: ", peopleId);
+
+  try {
+    // get all contacts with the wanted peopleId
+    const query = `
+      SELECT 
+        peopleContactId, 
+        contactNumber, 
+        contactType, 
+        preferredContact
+      FROM 
+        peopleContact
+      WHERE 
+        peopleId = ?;
+    `;
+
+    // Execute the query
+    const [results] = await pool.query(query, [peopleId]);
+
+    if (results.length === 0) {
+      console.log("No contacts found for person with ID:", peopleId);
+      return []; // empty array, no contacts found
+    }
+
+    // Map the results to structured contact objects
+    const contacts = results.map((row) => ({
+      peopleContactId: row.peopleContactId,
+      contactNumber: row.contactNumber,
+      contactType: row.contactType,
+      preferredContact: row.preferredContact,
+    }));
+
+    console.log("Found contacts: ", contacts);
+
+    return contacts;
+  } catch (error) {
+    console.error("Error fetching contacts for person: ", error);
+    return []; // empty array, no contacts found
+  }
+}
+
+module.exports = { addContact, updateContact, getContactsForPerson };

backend/repository/degreeRepository.js

 const { pool } = require("../config/database/database.config");
 
 /*
-Add degree information into the database.
+Add degree information into the database. The method will return 
+the id of the newly inserted degree, or null if nothing was added.
 */
 async function addDegree(degree, peopleId) {
   // get all the parts of the degree
@@ -25,6 +26,14 @@ async function addDegree(degree, peopleId) {
         VALUES (?,?,?,?,?,?)
     `;
 
+    console.log("Adding degree with the following details:");
+    console.log("People ID:", peopleId);
+    console.log("Degree Type:", degreeType);
+    console.log("Degree Department:", degreeDepartment);
+    console.log("Degree College:", degreeCollege);
+    console.log("Degree Year:", degreeYear);
+    console.log("Degree Description:", degreeDescription);
+
     // insert data into db
     const [results] = await pool.query(query, [
       peopleId,
@@ -35,7 +44,14 @@ async function addDegree(degree, peopleId) {
       degreeDescription,
     ]);
 
-    return results;
+    console.log("Inserted degree: ", results.insertId);
+
+    const checkQuery = `SELECT * FROM peopleDegree WHERE peopleDegreeId = ?`;
+    const [checkResults] = await pool.query(checkQuery, [results.insertId]);
+
+    console.log(checkResults[0]);
+
+    return results.insertId;
   } catch (error) {
     // return null if there is an error
     console.error(error);
@@ -43,6 +59,96 @@ async function addDegree(degree, peopleId) {
   }
 }
 
+/*
+Function to update the information about a specific degree 
+in the database. The function will return true if a row
+was successfully updated and false otherwise.
+*/
+async function updateDegree(peopleDegreeId, peopleId, degreeInfo) {
+  console.log("updating degree....");
+
+  // get all the parts of the degree
+  let {
+    degreeType,
+    degreeDepartment,
+    degreeCollege,
+    degreeYear,
+    degreeDescription,
+  } = degreeInfo;
+
+  try {
+    // Use the helper function to determine the degreeTypeId
+    let degreeTypeId = await _lookupDegreeTypeId(degreeType);
+
+    // SQL query to update
+    const query = `
+      UPDATE peopleDegree
+      SET
+        peopleId = ?
+        degreeTypeId = ?,
+        degreeDepartment = ?,
+        degreeCollege = ?, 
+        degreeYear = ?,
+        degreeDescription = ?
+      WHERE peopleDegreeId = ?
+    `;
+
+    const [results] = await pool.query(query, [
+      peopleId,
+      degreeTypeId,
+      degreeDepartment,
+      degreeCollege,
+      degreeYear,
+      degreeDescription,
+      peopleDegreeId,
+    ]);
+
+    // Check if any rows were affected
+    if (results.affectedRows === 0) {
+      console.error("Degree not found. no rows updated");
+      return false;
+    }
+
+    console.log("degree info updated: ", peopleDegreeId);
+
+    // return true to signify success
+    return true;
+  } catch (error) {
+    console.error("error updating degree: ", error);
+    return false;
+  }
+}
+
+/*
+Function to delete a degree by its ID. 
+Returns true if the degree was successfully deleted, false otherwise.
+*/
+async function deleteDegreeById(peopleDegreeId) {
+  console.log("Deleting degree with ID: ", peopleDegreeId);
+
+  try {
+    const query = `
+      DELETE FROM peopleDegree
+      WHERE peopleDegreeId = ?
+    `;
+
+    const [results] = await pool.query(query, [peopleDegreeId]);
+
+    // Check if any rows were affected
+    if (results.affectedRows === 0) {
+      console.error("Degree not found. No rows deleted.");
+      return false;
+    }
+
+    console.log("Degree successfully deleted: ", peopleDegreeId);
+
+    return true;
+  } catch (error) {
+    console.error("Error deleting degree: ", error);
+    return false;
+  }
+}
+
 // Private helper function to look up the degreeTypeId
 async function _lookupDegreeTypeId(degreeType) {
   try {
@@ -67,4 +173,93 @@ async function _lookupDegreeTypeId(degreeType) {
   }
 }
 
-module.exports = { addDegree, _lookupDegreeTypeId };
+/*
+Function to find all degree IDs associated with a person. 
+Returns an array of peopleDegreeIds or an empty array if no degrees exist.
+*/
+async function getDegreeIdsForPerson(peopleId) {
+  console.log("Finding degree IDs for person with ID: ", peopleId);
+
+  try {
+    // get the degrees for a given peopleId
+    const query = `
+      SELECT peopleDegreeId 
+      FROM peopleDegree
+      WHERE peopleId = ?
+    `;
+
+    const [results] = await pool.query(query, [peopleId]);
+
+    // Extract the degree IDs
+    const degreeIds = results.map((row) => row.peopleDegreeId);
+
+    console.log("Found degree IDs: ", degreeIds);
+
+    return degreeIds;
+  } catch (error) {
+    console.error("Error finding degree IDs: ", error);
+    return [];
+  }
+}
+
+/*
+Function to get all degree information associated with a person.
+Returns an array of degree objects or an empty array if no degrees exist.
+*/
+async function getDegreesForPerson(peopleId) {
+  console.log("Finding degrees for person with ID: ", peopleId);
+
+  try {
+    // get the full degree information for degreees for person with peopleId
+    const query = `
+      SELECT 
+        d.peopleDegreeId, 
+        d.degreeDepartment, 
+        d.degreeCollege, 
+        d.degreeYear, 
+        d.degreeDescription, 
+        dt.degreeType
+      FROM 
+        peopleDegree d
+      LEFT JOIN 
+        degreeTypeLookup dt ON d.degreeTypeId = dt.degreeTypeId
+      WHERE 
+        d.peopleId = ?;
+    `;
+
+    const [results] = await pool.query(query, [peopleId]);
+
+    // Print out each row returned by the query
+    console.log("Raw results from query:", results);
+
+    if (results.length === 0) {
+      console.log("No degrees found for person with ID:", peopleId);
+      return [];
+    }
+
+    const degrees = results.map((row) => ({
+      peopleDegreeId: row.peopleDegreeId,
+      degreeType: row.degreeType,
+      degreeDepartment: row.degreeDepartment,
+      degreeCollege: row.degreeCollege,
+      degreeYear: row.degreeYear,
+      degreeDescription: row.degreeDescription,
+    }));
+
+    console.log("Found degrees: ", degrees);
+
+    return degrees;
+  } catch (error) {
+    console.error("Error fetching degrees for person: ", error);
+    return [];
+  }
+}
+
+module.exports = {
+  addDegree,
+  updateDegree,
+  deleteDegreeById,
+  getDegreeIdsForPerson,
+  getDegreesForPerson,
+  _lookupDegreeTypeId,
+};

backend/repository/peopleRepository.js

@@ -84,7 +84,54 @@ async function searchPeopleByName(firstName, lastName) {
   }
 }
 
-async function getPersonById() {}
+/*
+Function to get the data associated with a specific peopleId.
+If none is found, the function returns null.
+*/
+async function getPersonById(peopleId) {
+  console.log("searching for person...");
+
+  try {
+    // big query to get all of the data
+    const query = `
+    SELECT 
+      peopleId, 
+      firstName, 
+      lastName, 
+      middleName, 
+      maidenName, 
+      suffix, 
+      nickName, 
+      techAlumniChapter, 
+      classYear, 
+      gradYear, 
+      gradSemester, 
+      gender
+    FROM 
+      people
+    WHERE 
+      peopleId = ?;
+  `;
+
+    // Execute the query
+    const [rows] = await pool.query(query, [peopleId]);
+
+    if (rows.length === 0) {
+      console.log("No person found");
+      null;
+    }
+
+    // structure the data
+    console.log("data recieved... structuring now");
+
+    // create the structure of a person
+    const person = rows[0];
+    return person;
+  } catch (error) {
+    console.log("Error getting person's full details: ", error);
+    return null;
+  }
+}
 
 /*
 Function to delete a person with the peopleId given. 
@@ -114,4 +161,85 @@ async function deletePersonById(peopleId) {
   }
 }
 
-module.exports = { addPerson, searchPeopleByName, deletePersonById };
+/*
+Function to update the people table's information for
+the person with the given id.
+*/
+async function updatePerson(personId, personInfo) {
+  // extract all the values from person
+  let {
+    firstName,
+    lastName,
+    middleName,
+    maidenName,
+    suffix,
+    nickName,
+    techAlumniChapter,
+    classYear,
+    gradYear,
+    gradSemester,
+    gender,
+  } = personInfo;
+
+  // find the integer that represents the alumni chapter (for now do 2)
+  techAlumniChapter = 2;
+
+  try {
+    console.log("Updating person: ", firstName);
+
+    // SQL UPDATE query
+    const query = `
+     UPDATE people
+     SET 
+       firstName = ?, 
+       lastName = ?, 
+       middleName = ?, 
+       maidenName = ?, 
+       suffix = ?, 
+       nickName = ?, 
+       techAlumniChapter = ?, 
+       classYear = ?, 
+       gradYear = ?, 
+       gradSemester = ?, 
+       gender = ?
+     WHERE peopleId = ?
+   `;
+
+    const [results] = await pool.query(query, [
+      firstName,
+      lastName,
+      middleName,
+      maidenName,
+      suffix,
+      nickName,
+      techAlumniChapter,
+      classYear,
+      gradYear,
+      gradSemester,
+      gender,
+      personId,
+    ]);
+
+    // Check if any rows were affected
+    if (results.affectedRows === 0) {
+      console.error("Person not found. no rows updated");
+      return false;
+    }
+
+    console.log("person info updated: ", personId);
+
+    // return true to signify success
+    return true;
+  } catch (error) {
+    console.error(error);
+    return false;
+  }
+}
+
+module.exports = {
+  addPerson,
+  searchPeopleByName,
+  deletePersonById,
+  updatePerson,
+  getPersonById,
+};