try writing the values still

candiduslynx · candiduslynx · commit f42b1a9f1ad6 · 2023-09-01T18:20:42.000+03:00
diff --git a/plugins/destination/gremlin/client/write.go b/plugins/destination/gremlin/client/write.go
@@ -45,13 +45,10 @@ func (c *Client) WriteTableBatch(ctx context.Context, tableName string, msgs mes
 		// If no primary keys are defined, use all columns
 		pks = table.Columns.Names()
 	}
-	valueColumns := make([]string, 0, len(table.Columns)-len(pks))
-	if len(table.Columns)-len(pks) > 0 {
-		// not all columns are a part of "pk", so we need to account for the values
-		for _, col := range table.Columns {
-			if !col.PrimaryKey {
-				valueColumns = append(valueColumns, col.Name)
-			}
+	valueColumns := make([]string, 0, len(table.Columns))
+	for _, col := range table.Columns {
+		if !col.PrimaryKey {
+			valueColumns = append(valueColumns, col.Name)
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -45,13 +45,10 @@ func (c *Client) WriteTableBatch(ctx context.Context, tableName string, msgs mes`
`45`	`45`	`// If no primary keys are defined, use all columns`
`46`	`46`	`pks = table.Columns.Names()`
`47`	`47`	`}`
`48`		`- valueColumns := make([]string, 0, len(table.Columns)-len(pks))`
`49`		`- if len(table.Columns)-len(pks) > 0 {`
`50`		`- // not all columns are a part of "pk", so we need to account for the values`
`51`		`- for _, col := range table.Columns {`
`52`		`- if !col.PrimaryKey {`
`53`		`- valueColumns = append(valueColumns, col.Name)`
`54`		`- }`
	`48`	`+ valueColumns := make([]string, 0, len(table.Columns))`
	`49`	`+ for _, col := range table.Columns {`
	`50`	`+ if !col.PrimaryKey {`
	`51`	`+ valueColumns = append(valueColumns, col.Name)`
`55`	`52`	`}`
`56`	`53`	`}`
`57`	`54`