diff --git a/sdks/go/pkg/beam/io/databaseio/writer.go b/sdks/go/pkg/beam/io/databaseio/writer.go
index 4719831581ff..ebd805b080d7 100644
--- a/sdks/go/pkg/beam/io/databaseio/writer.go
+++ b/sdks/go/pkg/beam/io/databaseio/writer.go
@@ -108,7 +108,7 @@ type valueTemplateGenerator struct {
 
 func (v *valueTemplateGenerator) generate(rowCount int, columnColunt int) string {
 	switch v.driver {
-	case "postgres":
+	case "postgres", "pgx":
 		// the point is to generate ($1,$2),($3,$4)
 		valueTemplates := make([]string, rowCount)
 		for i := 0; i < rowCount; i++ {
diff --git a/sdks/go/pkg/beam/io/databaseio/writer_test.go b/sdks/go/pkg/beam/io/databaseio/writer_test.go
index 24f617a9b857..91d7fb9246dd 100644
--- a/sdks/go/pkg/beam/io/databaseio/writer_test.go
+++ b/sdks/go/pkg/beam/io/databaseio/writer_test.go
@@ -39,6 +39,12 @@ func TestValueTemplateGenerator_generate(t *testing.T) {
 			columnCount: 10,
 			expected:    "",
 		},
+		{
+			generator:   &valueTemplateGenerator{"pgx"},
+			rowCount:    4,
+			columnCount: 3,
+			expected:    "($1,$2,$3),($4,$5,$6),($7,$8,$9),($10,$11,$12)",
+		},
 		{
 			generator:   &valueTemplateGenerator{"mysql"},
 			rowCount:    4,