diff --git a/dataconnect/connector/sector/mutations.gql b/dataconnect/connector/sector/mutations.gql
new file mode 100644
index 00000000..785fb9fa
--- /dev/null
+++ b/dataconnect/connector/sector/mutations.gql
@@ -0,0 +1,35 @@
+mutation CreateSector(
+  $sectorNumber: String!,
+  $sectorName: String!,
+  $sectorType: SectorType
+) @auth(level: USER) {
+  sector_insert(
+    data: {
+      sectorNumber: $sectorNumber
+      sectorName: $sectorName
+      sectorType: $sectorType
+    }
+  )
+}
+
+mutation UpdateSector(
+  $id: UUID!,
+  $sectorNumber: String,
+  $sectorName: String,
+  $sectorType: SectorType
+) @auth(level: USER) {
+  sector_update(
+    id: $id,
+    data: {
+      sectorNumber: $sectorNumber
+      sectorName: $sectorName
+      sectorType: $sectorType
+    }
+  )
+}
+
+mutation DeleteSector(
+  $id: UUID!
+) @auth(level: USER) {
+  sector_delete(id: $id)
+}
diff --git a/dataconnect/connector/sector/queries.gql b/dataconnect/connector/sector/queries.gql
new file mode 100644
index 00000000..26297f81
--- /dev/null
+++ b/dataconnect/connector/sector/queries.gql
@@ -0,0 +1,38 @@
+query listSector @auth(level: USER) {
+  sectors {
+    id
+    sectorNumber
+    sectorName
+    sectorType
+  }
+}
+
+query getSectorById(
+  $id: UUID!
+) @auth(level: USER) {
+  sector(id: $id) {
+    id
+    sectorNumber
+    sectorName
+    sectorType
+  }
+}
+
+query filterSector(
+  $sectorNumber: String,
+  $sectorName: String,
+  $sectorType: SectorType
+) @auth(level: USER) {
+  sectors(
+    where: {
+      sectorNumber: { eq: $sectorNumber }
+      sectorName: { eq: $sectorName }
+      sectorType: { eq: $sectorType }
+    }
+  ) {
+    id
+    sectorNumber
+    sectorName
+    sectorType
+  }
+}
diff --git a/dataconnect/schema/sector.gql b/dataconnect/schema/sector.gql
new file mode 100644
index 00000000..61255652
--- /dev/null
+++ b/dataconnect/schema/sector.gql
@@ -0,0 +1,18 @@
+enum SectorType {
+  FOOD_SERVICE
+  FACILITIES
+  HEALTHCARE
+  EDUCATION
+  CORPORATE
+  SPORTS_ENTERTAINMENT
+}
+
+type Sector @table(name: "sector") {
+  id: UUID! @default(expr: "uuidV4()")
+  sectorNumber: String! 
+  sectorName: String!
+  sectorType: SectorType 
+  createdDate: Timestamp @default(expr: "request.time")
+  updatedDate: Timestamp @default(expr: "request.time")
+  createdBy: String @default(expr: "auth.uid")
+}