Added OrganizationRoster support for owners

phase 1.sql

@@ -43,12 +43,23 @@ CREATE TABLE IF NOT EXISTS ORGANIZATION_ROSTER (
     roster_id INT AUTO_INCREMENT NOT NULL,
     user_email VARCHAR(128) NOT NULL,
     organization_id INT NOT NULL,
-    type ENUM('MEMBER', 'MANAGER') NOT NULL,
+    type ENUM('MEMBER', 'MANAGER', 'OWNER') NOT NULL,
     PRIMARY KEY (roster_id),
     CONSTRAINT fk_user_manager FOREIGN KEY (user_email) REFERENCES USER (email),
     CONSTRAINT fk_organization_manager FOREIGN KEY (organization_id) REFERENCES ORGANIZATION (organization_id)
 );
 
+INSERT INTO ORGANIZATION_ROSTER (user_email, organization_id, type)
+SELECT owner_email, organization_id, 'OWNER'
+FROM ORGANIZATION;
+
+SELECT * FROM ORGANIZATION_ROSTER WHERE ORGANIZATION_ROSTER.user_email LIKE 'emilyjohnson@example.com';
+SELECT DISTINCT o.*
+FROM ORGANIZATION o
+         JOIN ORGANIZATION_ROSTER r ON o.organization_id = r.organization_id
+WHERE r.user_email = 'emilyjohnson@example.com'
+   OR o.owner_email = 'emilyjohnson@example.com';
+
 CREATE TABLE IF NOT EXISTS REQUEST (
 	request_id INT AUTO_INCREMENT NOT NULL,
     user_email VARCHAR(128) NOT NULL,

src/main/java/com/example/accessingdatamysql/myorg/MyOrgRosterRepository.java

+package com.example.accessingdatamysql.myorg;
+
+import com.example.accessingdatamysql.org.Organization;
+import jakarta.persistence.EntityManager;
+import jakarta.persistence.PersistenceContext;
+import jakarta.persistence.Query;
+import jakarta.persistence.TypedQuery;
+import jakarta.transaction.Transactional;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+import java.util.Optional;
+
+@Repository
+public class MyOrgRosterRepository implements OrgRosterRepository{
+
+    @Autowired
+    private EntityManager entityManager;
+
+    @Transactional
+    public List<Organization> findUserOrgs(String userEmail)
+    {
+        String nativeQuery = "SELECT DISTINCT o.* " +
+                "FROM ORGANIZATION o " +
+                "JOIN ORGANIZATION_ROSTER r ON o.organization_id = r.organization_id " +
+                "WHERE r.user_email = :userEmail OR o.owner_email = :userEmail";
+        List<Organization> organizations = entityManager
+                .createNativeQuery(nativeQuery, Organization.class)
+                .setParameter("userEmail", userEmail)
+                .getResultList();
+        return organizations;
+    }
+
+
+    @Override
+    public <S extends OrganizationRoster> S save(S entity) {
+        return null;
+    }
+
+    @Override
+    public <S extends OrganizationRoster> Iterable<S> saveAll(Iterable<S> entities) {
+        return null;
+    }
+
+    @Override
+    public Optional<OrganizationRoster> findById(Integer integer) {
+        return Optional.empty();
+    }
+
+    @Override
+    public boolean existsById(Integer integer) {
+        return false;
+    }
+
+    @Override
+    @Transactional
+    public List<OrganizationRoster> findAll() {
+        TypedQuery<OrganizationRoster> query = entityManager.createQuery("SELECT o FROM Organization o", OrganizationRoster.class);
+        return query.getResultList();
+    }
+
+    @Override
+    public Iterable<OrganizationRoster> findAllById(Iterable<Integer> integers) {
+        return null;
+    }
+
+    @Override
+    public long count() {
+        return 0;
+    }
+
+    @Override
+    public void deleteById(Integer integer) {
+
+    }
+
+    @Override
+    public void delete(OrganizationRoster entity) {
+
+    }
+
+    @Override
+    public void deleteAllById(Iterable<? extends Integer> integers) {
+
+    }
+
+    @Override
+    public void deleteAll(Iterable<? extends OrganizationRoster> entities) {
+
+    }
+
+    @Override
+    public void deleteAll() {
+
+    }
+}

src/main/java/com/example/accessingdatamysql/myorg/OrgRosterController.java

+package com.example.accessingdatamysql.myorg;
+
+import com.example.accessingdatamysql.org.Organization;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@CrossOrigin
+@RestController // This means that this class is a Controller
+@RequestMapping(path="/myorg") // This means URL's start with /orgauth (after Application path)
+public class OrgRosterController {
+
+    @Autowired // This means to get the bean called userRepository
+    // Which is auto-generated by Spring, we will use it to handle the data
+    private OrgRosterRepository orgRosterRepository;
+
+    @Autowired
+    private MyOrgRosterRepository myOrgRosterRepository;
+
+    @GetMapping(path="/all")
+    public @ResponseBody Iterable<OrganizationRoster> getOrgs()
+    {
+        return myOrgRosterRepository.findAll();
+    }
+
+    @PostMapping(path="/user")
+    public @ResponseBody Map<String, Object> getUsersOrgs(@RequestBody Map<String, String> json)
+    {
+        Map<String, Object> response = new HashMap<>();
+//        System.out.println(json.entrySet());
+        if (json.containsKey("email"))
+        {
+            response.put("result", "success");
+            response.put("data", myOrgRosterRepository.findUserOrgs(json.get("email")));
+            return response;
+        }
+        response.put("result", "failure - bad request");
+        return response;
+    }
+}
+

src/main/java/com/example/accessingdatamysql/myorg/OrgRosterRepository.java

@@ -5,5 +5,5 @@ import org.springframework.data.repository.CrudRepository;
 // This will be AUTO IMPLEMENTED by Spring into a Bean called userRepository
 // CRUD refers Create, Read, Update, Delete
 
-public interface OrgRosterRepository extends CrudRepository<Organization_Roster, Integer>{
+public interface OrgRosterRepository extends CrudRepository<OrganizationRoster, Integer>{
 }

src/main/java/com/example/accessingdatamysql/myorg/Organization_Roster.java → src/main/java/com/example/accessingdatamysql/myorg/OrganizationRoster.java

@@ -2,12 +2,11 @@ package com.example.accessingdatamysql.myorg;
 
 import jakarta.persistence.*;
 
-import java.io.Serializable;
 import java.util.Objects;
 
 @Entity
-@Table(name="Organization_Roster")
-public class Organization_Roster {
+@Table(name="OrganizationRoster")
+public class OrganizationRoster {
 
     @Id
     @GeneratedValue(strategy=GenerationType.IDENTITY)
@@ -25,11 +24,17 @@ public class Organization_Roster {
         this.rosterId = rosterId;
     }
 
+    public OrganizationRoster(String userEmail, Integer organizationId, Type type) {
+        this.userEmail = userEmail;
+        this.organizationId = organizationId;
+        this.type = type;
+    }
+
     @Override
     public boolean equals(Object o) {
         if (this == o) return true;
         if (o == null || getClass() != o.getClass()) return false;
-        Organization_Roster that = (Organization_Roster) o;
+        OrganizationRoster that = (OrganizationRoster) o;
         return getRosterId().equals(that.getRosterId()) && userEmail.equals(that.userEmail) && organizationId.equals(that.organizationId) && type == that.type;
     }
 
@@ -38,10 +43,10 @@ public class Organization_Roster {
         return Objects.hash(getRosterId(), userEmail, organizationId, type);
     }
 
-    public Organization_Roster() {
+    public OrganizationRoster() {
     }
 
-    enum Type {
+    public enum Type {
         OWNER,
         MANAGER,
         MEMBER

src/main/java/com/example/accessingdatamysql/org/OrgController.java

 package com.example.accessingdatamysql.org;
 
 
+import com.example.accessingdatamysql.myorg.OrgRosterRepository;
+import com.example.accessingdatamysql.myorg.OrganizationRoster;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -12,13 +14,18 @@ public class OrgController {
     // Which is auto-generated by Spring, we will use it to handle the data
     private OrgRepository orgRepository;
 
+    @Autowired // This means to get the bean called userRepository
+    // Which is auto-generated by Spring, we will use it to handle the data
+    private OrgRosterRepository orgRosterRepository;
 
     @PostMapping(path = "/add") // Map ONLY POST Requests
     @ResponseBody
     public Organization addJsonOrg(@RequestBody Organization org) {
         // @ResponseBody means the returned String is the response, not a view name
         // @RequestParam means it is a parameter from the GET or POST request
-        orgRepository.save(org);
+        Organization org2 = orgRepository.save(org);
+        OrganizationRoster orgRoster = new OrganizationRoster(org2.getOwnerEmail(), org2.getOrgId(), OrganizationRoster.Type.OWNER);
+        orgRosterRepository.save(orgRoster);
         return org;
     }