gofr-dev
diff --git a/‎.github/workflows/go.yml
Lines changed: 38 additions & 38 deletions b/‎.github/workflows/go.yml
Lines changed: 38 additions & 38 deletions
diff --git a/‎docs/advanced-guide/handling-data-migrations/page.md
Lines changed: 37 additions & 0 deletions b/‎docs/advanced-guide/handling-data-migrations/page.md
Lines changed: 37 additions & 0 deletions
diff --git a/‎docs/datasources/clickhouse/page.md
Lines changed: 3 additions & 4 deletions b/‎docs/datasources/clickhouse/page.md
Lines changed: 3 additions & 4 deletions
diff --git a/‎docs/datasources/dgraph/page.md
Lines changed: 1 addition & 1 deletion b/‎docs/datasources/dgraph/page.md
Lines changed: 1 addition & 1 deletion
diff --git a/‎docs/datasources/getting-started/page.md
Lines changed: 1 addition & 1 deletion b/‎docs/datasources/getting-started/page.md
Lines changed: 1 addition & 1 deletion
@@ -276,44 +276,44 @@ jobs:
           path: coverage_reports/*.cov
 
   # Job for uploading coverage to external services (CodeClimate)
-  upload_coverage:
-    name: Upload Coverage📊
-    runs-on: ubuntu-latest
-    # This job only needs example and pkg test results, not submodules
-    needs: [Example-Unit-Testing, PKG-Unit-Testing]
-    # Only run this job on pushes to the development branch
-    if: ${{ github.event_name == 'push' && github.ref == 'refs/heads/development'}}
-    steps:
-      - name: Check out code into the Go module directory
-        uses: actions/checkout@v4
-
-      # Download coverage artifacts
-      - name: Download Coverage Report
-        uses: actions/download-artifact@v4
-        with:
-          path: artifacts
-
-      # Merge coverage from example and pkg tests only
-      - name: Merge Coverage Files
-        working-directory: artifacts
-        run: |
-          echo "mode: set" > merged_profile.cov
-          tail -n +2 ./Example-Test-Report/profile.cov >> merged_profile.cov
-          tail -n +2 ./PKG-Coverage-Report/profile.cov >> merged_profile.cov
-
-          # Generate and print total coverage percentage
-          echo "Total Coverage:"
-          go tool cover -func=merged_profile.cov | tail -n 1
-        shell: bash
-
-      # Upload merged coverage to CodeClimate for analysis
-      - name: Upload
-        uses: paambaati/codeclimate-action@v9.0.0
-        env:
-          CC_TEST_REPORTER_ID: ${{ secrets.CC_TEST_REPORTER_ID }}
-        with:
-          coverageLocations: artifacts/merged_profile.cov:gocov
-          prefix: gofr.dev
+#  upload_coverage:
+#    name: Upload Coverage📊
+#    runs-on: ubuntu-latest
+#    # This job only needs example and pkg test results, not submodules
+#    needs: [Example-Unit-Testing, PKG-Unit-Testing]
+#    # Only run this job on pushes to the development branch
+#    if: ${{ github.event_name == 'push' && github.ref == 'refs/heads/development'}}
+#    steps:
+#      - name: Check out code into the Go module directory
+#        uses: actions/checkout@v4
+#
+#      # Download coverage artifacts
+#      - name: Download Coverage Report
+#        uses: actions/download-artifact@v4
+#        with:
+#          path: artifacts
+#
+#      # Merge coverage from example and pkg tests only
+#      - name: Merge Coverage Files
+#        working-directory: artifacts
+#        run: |
+#          echo "mode: set" > merged_profile.cov
+#          tail -n +2 ./Example-Test-Report/profile.cov >> merged_profile.cov
+#          tail -n +2 ./PKG-Coverage-Report/profile.cov >> merged_profile.cov
+#
+#          # Generate and print total coverage percentage
+#          echo "Total Coverage:"
+#          go tool cover -func=merged_profile.cov | tail -n 1
+#        shell: bash
+#
+#      # Upload merged coverage to CodeClimate for analysis
+#      - name: Upload
+#        uses: paambaati/codeclimate-action@v9.0.0
+#        env:
+#          CC_TEST_REPORTER_ID: ${{ secrets.CC_TEST_REPORTER_ID }}
+#        with:
+#          coverageLocations: artifacts/merged_profile.cov:gocov
+#          prefix: gofr.dev
 
   # Job for code quality checks
   code_quality:
 
@@ -238,4 +238,41 @@ func createTableEmployeeCassandra() migration.Migrate {
 }
 ```
 
+## Migrations in ElasticSearch
+
+GoFr allows Elasticsearch document migrations, focusing on **single document** and **bulk operations**.
+
+### Single Document Migration
+
+```go  
+func addSingleProduct() migration.Migrate {  
+ return migration.Migrate{ 
+	 UP: func(d migration.Datasource) error { 
+			 product := map[string]any{ 
+			 "title": "Laptop", 
+			 "price": 999.99, 
+			 "category": "electronics", 
+			 } 
+			 
+		return d.Elasticsearch.IndexDocument( context.Background(), "products", "1", product, ) }, }
+		}  
+```  
+
+### Bulk Operation Migration
+
+```go  
+func bulkProducts() migration.Migrate {  
+ return migration.Migrate{ 
+ UP: func(d migration.Datasource) error { 
+		operations := []map[string]any{ 
+			{"index": map[string]any{"_index": "products", "_id": "1"}}, 
+			{"title": "Phone", "price": 699.99, "category": "electronics"}, 
+			{"index": map[string]any{"_index": "products", "_id": "2"}}, 
+			{"title": "Mug", "price": 12.99, "category": "kitchen"}, 
+			 }
+		
+		_, err := d.Elasticsearch.Bulk(context.Background(), operations) return err },}
+	}  
+``` 
+
 > ##### Check out the example to add and run migrations in GoFr: [Visit GitHub](https://github.com/gofr-dev/gofr/blob/main/examples/using-migrations/main.go)
@@ -25,14 +25,13 @@ package main
 
 import (
 	"gofr.dev/pkg/gofr"
-
 	"gofr.dev/pkg/gofr/datasource/clickhouse"
 )
 
 type User struct {
 	Id   string `ch:"id"`
 	Name string `ch:"name"`
-	Age  string `ch:"age"`
+	Age  int    `ch:"age"`
 }
 
 func main() {
@@ -52,12 +51,12 @@ func main() {
 }
 
 func Post(ctx *gofr.Context) (any, error) {
-	err := ctx.Clickhouse.Exec(ctx, "INSERT INTO users (id, name, age) VALUES (?, ?, ?)", "8f165e2d-feef-416c-95f6-913ce3172e15", "aryan", "10")
+	err := ctx.Clickhouse.Exec(ctx, "INSERT INTO users (id, name, age) VALUES (?, ?, ?)", "8f165e2d-feef-416c-95f6-913ce3172e15", "aryan", 10)
 	if err != nil {
 		return nil, err
 	}
 
-	return "successful inserted", nil
+	return "successfully inserted", nil
 }
 
 func Get(ctx *gofr.Context) (any, error) {
 
@@ -68,7 +68,7 @@ func main() {
 
 	db := dgraph.New(dgraph.Config{
 		Host: "localhost",
-		Port: "8080",
+		Port: "9080",
 	})
 
 	// Connect to Dgraph running on localhost:9080
 
@@ -167,7 +167,7 @@ as unnecessary database drivers are not being compiled and added to the build.
 - ✅
 - ✅
 - ✅
-- 
+- ✅
 
 ---
Original file line number	Diff line number	Diff line change
`@@ -25,14 +25,13 @@ package main`
`25`	`25`
`26`	`26`	`import (`
`27`	`27`	`"gofr.dev/pkg/gofr"`
`28`		`-`
`29`	`28`	`"gofr.dev/pkg/gofr/datasource/clickhouse"`
`30`	`29`	`)`
`31`	`30`
`32`	`31`	`type User struct {`
`33`	`32`	Id string `ch:"id"`
`34`	`33`	Name string `ch:"name"`
`35`		- Age string `ch:"age"`
	`34`	+ Age int `ch:"age"`
`36`	`35`	`}`
`37`	`36`
`38`	`37`	`func main() {`
`@@ -52,12 +51,12 @@ func main() {`
`52`	`51`	`}`
`53`	`52`
`54`	`53`	`func Post(ctx *gofr.Context) (any, error) {`
`55`		`- err := ctx.Clickhouse.Exec(ctx, "INSERT INTO users (id, name, age) VALUES (?, ?, ?)", "8f165e2d-feef-416c-95f6-913ce3172e15", "aryan", "10")`
	`54`	`+ err := ctx.Clickhouse.Exec(ctx, "INSERT INTO users (id, name, age) VALUES (?, ?, ?)", "8f165e2d-feef-416c-95f6-913ce3172e15", "aryan", 10)`
`56`	`55`	`if err != nil {`
`57`	`56`	`return nil, err`
`58`	`57`	`}`
`59`	`58`
`60`		`- return "successful inserted", nil`
	`59`	`+ return "successfully inserted", nil`
`61`	`60`	`}`
`62`	`61`
`63`	`62`	`func Get(ctx *gofr.Context) (any, error) {`
-Original file line number
+Diff line change
 - ✅
 - ✅
 - ✅
 --
 +- ✅
 ---